См. ниже псевдокод
//Single or multiple Producers produce using below method
void Produce(object itemToQueue)
{
concurrentQueue.enqueue(itemToQueue);
consumerSignal.set;
}
//somewhere else we have started a consumer like this
//we have only one consumer
void StartConsumer()
{
while (!concurrentQueue.IsEmpty())
{
if (concurrentQueue.TrydeQueue(out item))
{
//long running processing of item
}
}
consumerSignal.WaitOne();
}
Как я могу портировать этот шаблон, который я использовал с незапамятных времен, чтобы использовать созданные задачи taskfactory и новые функции сигнализации сети 4. Другими словами, если кто-то должен был написать этот шаблон, используя net 4, как бы он выглядел? Псевдокод в порядке. Я уже использую .net 4 concurrentQueue, как вы можете видеть. Как использовать задачу и, возможно, использовать какой-либо новый механизм сигнализации, если это возможно. спасибо
Решение моей проблемы ниже благодаря Jon/Dan. Милая. Никакой ручной сигнализации или while (true) или while (itemstoProcess) типа, как старые дни
//Single or multiple Producers produce using below method
void Produce(object itemToQueue)
{
blockingCollection.add(item);
}
//somewhere else we have started a consumer like this
//this supports multiple consumers !
task(StartConsuming()).Start;
void StartConsuming()
{
foreach (object item in blockingCollection.GetConsumingEnumerable())
{
//long running processing of item
}
}
cancellations are handled using cancel tokens