Блог

Допустим, у меня есть коллекция System.Threading.Tasks.Task :

 HashSet<Task> myTasks = new HashSet<Task>();
  

… и я периодически добавляю больше в коллекцию, поскольку у меня есть больше данных, которые необходимо обработать:

 foreach (DataItem item in itemsToProcess)
    myTasks.Add(
        Task.Factory.StartNew(
            () => Process(item),
            cancellationToken,
            TaskCreationOptions.LongRunning,
            TaskScheduler.Default));    
  

Поскольку Task s остаются в TaskStatus.RanToCompletion состоянии после завершения, а не просто исчезают, они будут оставаться в коллекции до явного удаления, и коллекция будет расти бесконечно. Task s необходимо обрезать, чтобы предотвратить это.

Один из подходов, который я рассмотрел, заключается в предоставлении Task доступа к коллекции и ее удалении в самом конце. Но я также рассматриваю архитектуру, в которой мне пришлось бы удалить задачу, которую не создал мой компонент. Моя первая мысль — прикрепить триггер или событие к завершению каждой задачи, что-то вроде этого:

 foreach (Task task in createdSomewhereElse)
{
    lock (myTasks) myTasks.Add(task);
    task.WhenTaskIsCompleted  = 
        (o, ea) => { lock(myTasks) myTasks.Remove(task); };
    task.Start();
}
  

…но Task такого события нет. Есть ли какой-нибудь хороший способ выполнить то, что я ищу? Что-то вроде этого:

Вы, конечно, можете прикрепить триггер для завершения задачи: Task.ContinueWith (и его общий эквивалент). Вероятно, этого было бы достаточно для вас.

Возможно, вы также захотите использовать ConcurrentDictionary как своего рода параллельный набор для бедных — таким образом, вам не придется блокировать доступ к коллекции. Просто используйте Keys свойство при повторении и используйте все, что вам нравится, в качестве значения.

Почему вам нужно хранить задачи в коллекции?

Почему бы не использовать решение, основанное на BlockingCollection и Parallel.ForEach

 var sources = new BlockingCollection<DataItem>();

Task.Factory.StartNew(() => {
    Parallel.ForEach(sources.GetConsumingPartitioner(),
                     item => Process(item));
});
  

Теперь вы можете просто поместить свои элементы в блокирующую коллекцию, и они будут обработаны автоматически.

 foreach (DataItem item in itemsToProcess)
    sources.Add(item);
  

Вы можете использовать sources.Count и foreach (DataItem item in sources) для просмотра необработанных элементов.
(Отличие от вашего решения в том, что вы не можете видеть элементы, обрабатываемые в данный момент)

Используйте ContinueWith, чтобы задать действие, которое удаляет задачу из набора.