File d'attente des processus multithread ou des tâches

Si vous pouvez utiliser .Net 4.5, je vous suggère de regarder Flux de données à partir de la Task Parallel Library (TPL).

Cette page conduit à beaucoup d'exemple soluces comme Comment: mettre en Œuvre un Producteur-Consommateur de Flux de données de Motif et Procédure pas à pas: à l'Aide de Flux de données dans une Application Windows Forms.

Jetez un oeil à la documentation pour voir si elle pourrait vous aider. C'est beaucoup, mais je pense qu'il serait probablement votre meilleure approche.

Sinon, vous pouvez regarder dans l'aide d'une BlockingCollection avec ses GetConsumingEnumerable() méthode d'accès à des éléments dans la file d'attente.

Ce que vous faire est de diviser le travail dans les objets que vous souhaitez traiter d'une certaine façon, et d'utiliser une BlockingCollection pour gérer la file d'attente.

Un exemple de code utilisant ints plutôt que des objets comme les éléments de travail va aider à le démontrer:

Lorsqu'un thread a fini avec l'élément en cours, il permettra d'éliminer un nouvel élément à partir de la file d'attente de travail, processus de cet élément, puis l'ajouter à la file d'attente de sortie.

Séparé thread consommateur supprime complété les éléments de la file d'attente de sortie et fait quelque chose avec eux.

À la fin, on doit attendre que tous les travailleurs à la fin (de la Tâche.WaitAll(travailleurs) a) avant que nous puissions marquer la sortie de la file d'attente est terminée (outputQueue.CompleteAdding()).

using System;
using System.Collections.Concurrent;
using System.Threading;
using System.Threading.Tasks;
namespace Demo
{
class Program
{
static void Main(string[] args)
{
new Program().run();
}
void run()
{
int threadCount = 4;
Task[] workers = new Task[threadCount];
Task.Factory.StartNew(consumer);
for (int i = 0; i < threadCount; ++i)
{
int workerId = i;
Task task = new Task(() => worker(workerId));
workers[i] = task;
task.Start();
}
for (int i = 0; i < 100; ++i)
{
Console.WriteLine("Queueing work item {0}", i);
inputQueue.Add(i);
Thread.Sleep(50);
}
Console.WriteLine("Stopping adding.");
inputQueue.CompleteAdding();
Task.WaitAll(workers);
outputQueue.CompleteAdding();
Console.WriteLine("Done.");
Console.ReadLine();
}
void worker(int workerId)
{
Console.WriteLine("Worker {0} is starting.", workerId);
foreach (var workItem in inputQueue.GetConsumingEnumerable())
{
Console.WriteLine("Worker {0} is processing item {1}", workerId, workItem);
Thread.Sleep(100);          //Simulate work.
outputQueue.Add(workItem);  //Output completed item.
}
Console.WriteLine("Worker {0} is stopping.", workerId);
}
void consumer()
{
Console.WriteLine("Consumer is starting.");
foreach (var workItem in outputQueue.GetConsumingEnumerable())
{
Console.WriteLine("Consumer is using item {0}", workItem);
Thread.Sleep(25);
}
Console.WriteLine("Consumer is finished.");
}
BlockingCollection<int> inputQueue = new BlockingCollection<int>();
BlockingCollection<int> outputQueue = new BlockingCollection<int>();
}
}

OriginalL'auteur Matthew Watson