Creating worker "tasks" to dealing with limited resources

Question

I am looking for a mechanism already in c# that will allow me to do something like this:

10 images need to be decoded
there is only enough memory to decode 2
start decoding 2, put the rest in a job queue
ability to cancel tasks

Any recommendations on using c# accomplish something like this?

Related question: http://stackoverflow.com/questions/2898609/system-threading-tasks-limit-the-number-of-concurrent-tasks — Alexander Tsvetkov, Mar 18 '13 at 14:53

score 1 · Accepted Answer · answered Mar 18 '13 at 15:05

The BlockingCollection<T> class makes producer/consumer queues very easy to work with.

var queue = new BlockingCollection<Action>();

//put work to do in the queue
for (int i = 0; i < 10; i++)
    queue.Add(() => ProcessImage());
queue.CompleteAdding();

//create two workers
for (int i = 0; i < 2; i++)
{
    Task.Factory.StartNew(() =>
    {
        foreach (var action in queue.GetConsumingEnumerable())
            action();
    });
}

//to cancel the work, empty the queue
Task.Delay(5000)
    .ContinueWith(t =>
    {
        queue.GetConsumingEnumerable().Count();
    });

score 0 · Answer 2 · answered Mar 18 '13 at 14:52

0

use Seamphore + ConcurrentQueue combo

answered Mar 18 '13 at 14:52

TalentTuner

17,262
5
38
63

Creating worker "tasks" to dealing with limited resources

2 Answers2