C# TPL 如何知道所有任务都已完成？

发布于 2024-10-18 13:08:39 字数 302 浏览 1 评论 0原文

我有生成任务的循环。

代码：

Task task = null;
foreach (Entity a in AAAA)
{
  // create the task 
  task = new Task(() => {
    myMethod(a);
  },  Token, TaskCreationOptions.None);
  task.Start();
}

正如您在每次迭代中看到的任务对象都有新的初始化（..new Task(() =>..) 我怎么知道所有任务都已完成？

原文

I have the Loop which generates tasks.

Code:

Task task = null;
foreach (Entity a in AAAA)
{
  // create the task 
  task = new Task(() => {
    myMethod(a);
  },  Token, TaskCreationOptions.None);
  task.Start();
}

As you can see in each iteration task object has new initialization (..new Task(() =>..)
How can I know that all tasks done?

分享到QQ

分享到微博

如果你对这篇内容有疑问，欢迎到本站社区发帖提问参与讨论，获取更多帮助，或者扫码二维码加入 Web 技术交流群。

发布评论

需要登录才能够评论，你可以免费注册一个本站的账号。

￡噩梦荏苒 2024-10-25 13:08:39

如果将其替换为

 Parallel.ForEach(...,  () => myMethod(a), ...)

然后，您将在 ForEach 末尾自动等待所有任务。

也许可以从单独的任务运行 ForEach。

I f you replace this with a

 Parallel.ForEach(...,  () => myMethod(a), ...)

Then you get an automatic Wait on all tasks at the end of the ForEach.

And maybe run the ForEach from a separate Task.

回复收藏 0 原文

手心的温暖 2024-10-25 13:08:39

var allTasks = new List<Task>();
foreach (Entity a in AAAA)
{
  // create the task 
  task = new Task(() => {
    myMethod(a);
  },  Token, TaskCreationOptions.None);

  // Add the tasks to a list
  allTasks.Add(task);
  task.Start();
}

// Wait until all tasks are completed.
Task.WaitAll(allTasks.ToArray());

var allTasks = new List<Task>();
foreach (Entity a in AAAA)
{
  // create the task 
  task = new Task(() => {
    myMethod(a);
  },  Token, TaskCreationOptions.None);

  // Add the tasks to a list
  allTasks.Add(task);
  task.Start();
}

// Wait until all tasks are completed.
Task.WaitAll(allTasks.ToArray());

回复收藏 0 原文

活泼老夫 2024-10-25 13:08:39

您需要保留对循环中创建的所有任务的引用。然后您可以使用 Task.WaitAll 方法（请参阅 MSDN参考）。您可以创建一个数组并将任务分配给该数组的元素（在 C# 2.0 中），也可以使用 LINQ：

var tasks = 
   AAAA.Select((Entity a) => 
      Task.Factory.StartNew(() => { myMethod(a); },
         Token, TaskCreationOptions.None)).ToArray();
Task.WaitAll(tasks)

如果您不需要（显式）使用任务，则 Henk 建议使用 Parallel.ForEach code> 可能是更好的选择。

You'll need to keep references to all the tasks created in the loop. Then you can use the Task.WaitAll method (see MSDN reference). You can either create an array and assign tasks to elements of the array (in C# 2.0) or you can use LINQ:

var tasks = 
   AAAA.Select((Entity a) => 
      Task.Factory.StartNew(() => { myMethod(a); },
         Token, TaskCreationOptions.None)).ToArray();
Task.WaitAll(tasks)

If you don't need to use tasks (explicitly) then Henk's suggestion to use Parallel.ForEach is probably a better option.

回复收藏 0 原文

~没有更多了~