C# 可等待集合

Question

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

到目前为止，我发现了以下方法：

• 使用 TaskCompletionSource 变量(需要与其他任务/线程共享(
• 使用BlockingCollection并执行while(!collection.IsAddingCompleted) {}(非异步(
• 使用 TPL 数据流中的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();
    }
}

Answer 1

是否有标准方法可以等待集合被另一个任务标记为完成？

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

要解决您的每个问题：

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