有没有一种标准的方法来等待一个集合被另一个任务(线程)标记为完成,我正在寻找类似await collection.Completion.Task的东西

到目前为止,我发现了以下方法:


使用TaskCompletionSource变量(需要与其他任务/线程共享)
使用BlockingCollection并执行while(!collection.IsAddingCompleted) {}(非异步)
使用TPL Dataflow中的BufferBlock<T>并执行await bufferBlock.Completion.Task(可能会产生大量开销吗?)
使用ObservableCollection(不是异步)
任何其他?


所有想法表示赞赏

编辑:添加方案以提供更多上下文

class Program
{
    static void Main(string[] args)
    {
        var list = new List<int>();
        var tcs = new TaskCompletionSource<bool>();

        //This thread represents an independent process which will populate the list
        new Thread(() =>
            {
                for (int i = 0; i < 5; i++)
                {
                    Thread.Sleep(200); // do work
                    list.Add(i);
                }
                tcs.SetResult(true);
                Thread.Sleep(2000); //do more work
                Console.WriteLine("The End -- Press Enter");
                Console.ReadLine();
            }
        ).Start();

        //This task awaits for the list to be populated
        new Task(async () =>
        {
            await Task.Delay(300); //do work
            await tcs.Task;
            Console.WriteLine("List count = " + list.Count);
        }).Start();
    }
}

最佳答案

有没有一种标准的方法来等待另一个任务将一个集合标记为已完成?


您可以为此使用任何类型的“信号”。由于这只是一次信号,所以TaskCompletionSource<T>就可以了。它是已完成收集的信号这一事实并不重要。但是,正如您所发现的,某些集合确实具有此内置功能。

要解决您的每个问题:


TaskCompletionSource<T>-最直接的IMO,因为它可以与任何类型的集合一起使用。
BlockingCollection<T>-您不想使用BlockingCollection,但可以使用AsyncProducerConsumerQueue or AsyncCollection,它们是相同的抽象,但允许异步等待。
BufferBlock<T>-也可以。许多人将BufferBlock<T>用作异步兼容的生产者/消费者队列。
ObservableCollection<T>-不是选项,因为它没有“完成”的概念。
其他-如果您的收藏集是“基于推送的”,则可以使用IObservable<T>,而只需await即可。

10-08 04:17