gpt4 book ai didi

c# - ContinueWhenAll 不等待所有任务完成

转载 作者:太空狗 更新时间:2023-10-29 20:00:25 24 4
gpt4 key购买 nike

我在网上找到了一段代码,并对其进行了一些修改以查看其工作原理,但现在我遇到了 ContinueWhenAll 的问题,因为它不会等待所有任务完成完成:

List<Task> tasks = new List<Task>();
for (int i = 0; i < 20; i++)
{
int j = i;
var compute = Task.Factory.StartNew(() => results.Add(DoSomething(j)));
tasks.Add(compute);
}

我正在使用此代码将所有任务添加到列表中。 DoSomething 函数计算一些结果并将它们添加到 BlockingCollection。我有另一个显示功能,它将所有添加的结果从 BlockingCollection 写入控制台。

我已经使用这段代码等待所有任务完成,但看起来它并没有等待它们,因为程序显示标准的 “按任意键继续” 消息只是一个启动后几毫秒。 (程序完成大约需要 20 秒)

Task.Factory.ContinueWhenAll(tasks.ToArray(), result => results.CompleteAdding());

但是,如果我将 Task.WaitAll(consume) 添加到程序末尾,程序运行正常:

var consume = Task.Factory.StartNew(() => display(results));
//results = BlockingCollection that I mentioned

据我所知,该程序没有足够的时间来显示 BlockingCollection 的所有结果,但它仍然有足够的时间在等待所有任务完成时显示一些结果。

有人能解释一下为什么 Task.Factory.ContinueWhenAll 不等待所有结果被计算并且程序结束就像程序中没有那行代码一样(几毫秒后)吗?

最佳答案

Task.Factory.ContinueWhenAll 不是阻塞方法;它实际上会启动一个新任务,只有当所有提供的任务都在那里执行完毕后才会起作用,所以在程序启动后几毫秒看到一条消息是正常的,因为它不会阻塞在你的主要等待任务完成。来自 msdn :

Creates a continuation Task that will be started upon the completion of a set of provided Tasks.

Task.WaitAll 将在调用方处阻塞,等待所有提供的任务完成执行。

关于c# - ContinueWhenAll 不等待所有任务完成,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/6797453/

24 4 0
Copyright 2021 - 2024 cfsdn All Rights Reserved 蜀ICP备2022000587号
广告合作:1813099741@qq.com 6ren.com