任务开始顺序而不是并行

Question

我需要并行启动任务，但我选择使用Task.Run 而不是Parallel.Foreach，这样我可以在所有任务完成后获得一些反馈并启用 UI 控件。

private async void buttonStart_Click(object sender, EventArgs e)
{
    var cells = objectListView.CheckedObjects;
    if(cells != null)
    {
        List<Task> tasks = new List<Task>();
        foreach (Cell c in cells)
        {
            Cell cell = c;
            var progressHandler = new Progress<string>(value =>
            {
                cell.Status = value;
            });
            var progress = progressHandler as IProgress<string>;

            Task t = Task.Run(() =>
            {
                progress.Report("Starting...");
                int a = 123;
                for (int i = 0; i < 200000; i++)
                {
                    a = a + i;
                    Task.Delay(500).Wait();
                }

                progress.Report("Done");
            });
            tasks.Add(t);

        }

        await Task.WhenAll(tasks);
        Console.WriteLine("Done, enabld UI controls");
    }
}

所以我期望在 UI 中几乎立即看到所有项目的“正在启动...”。我实际看到的是前 4 个项目是“正在启动...”（我猜是因为每个线程都使用了所有 4 个 CPU 内核），然后每秒或更少的新项目是“启动”。我总共有 37 个项目，所有项目启动所有任务大约需要 30 秒。

我怎样才能让它尽可能平行？

Answer 1

我怎样才能让它尽可能平行？

内部for循环的部分是模拟长时间运行的CPU密集型作业，我希望尽可能同时开始。

它已经尽可能并行了。启动 37 个需要 CPU 密集型工作的线程不会使其运行得更快，因为您显然是在 4 核机器上运行它。有 4 个内核，因此一次实际上只能运行 4 个线程。其他 33 个线程将等待，而 4 个线程正在运行。它们只会看起来同时运行。

也就是说，如果你真的想要启动所有这些线程池线程，你可以通过调用ThreadPool.SetMinThreads来做到这一点。

我需要并行启动任务，但我选择使用 Task.Run 而不是 Parallel.Foreach，因此我可以在所有任务完成后获得一些反馈并启用 UI 控件。

由于您有并行工作要做，您应该使用Parallel。如果您想要 await 的良好的恢复 UI 线程行为，那么您可以使用单个 await Task.Run，如下所示：

private async void buttonStart_Click(object sender, EventArgs e)
{
  var cells = objectListView.CheckedObjects;
  if (cells == null)
    return;

  var workItems = cells.Select(c => new
  {
    Cell = c,
    Progress = new Progress<string>(value => { c.Status = value; }),
  }).ToList();

  await Task.Run(() => Parallel.ForEach(workItems, item =>
  {
    var progress = item.Progress as IProgress<string>();
    progress.Report("Starting...");
    int a = 123;
    for (int i = 0; i < 200000; i++)
    {
      a = a + i;
      Thread.Sleep(500);
    }

    progress.Report("Done");
  }));

  Console.WriteLine("Done, enabld UI controls");
}

Answer 2

我会说，它尽可能平行。如果您有 4 个内核，则可以并行运行 4 个线程。

如果您可以在等待“延迟”的同时做一些事情，请查看异步编程（一个线程可以“一次”运行多个任务，因为它们中的大多数都在等待某事）。

编辑：您也可以在自己的任务中运行Parallel.ForEach 和await：

private async void buttonStart_Click(object sender, EventArgs e)
{
    var cells = objectListView.CheckedObjects;
    if(cells != null)
    {
        await Task.Run( () => Parallel.ForEach( cells, c => ... ) );
    }
}

Answer 3

我认为这取决于您的任务创建选项。

TaskCreationOptions.LongRunning

在这里您可以找到更多信息：

https://msdn.microsoft.com/en-us/library/system.threading.tasks.taskcreationoptions(v=vs.110).aspx

但是您必须知道，该任务使用具有有限最大线程数的线程池。您可以使用 LongRunning 发出信号，表明此任务需要很长时间并且不应阻塞您的池。我认为创建一个长时间运行的任务更复杂，因为调度程序可能会创建一个新线程。

using System;
using System.Collections.Generic;
using System.Threading.Tasks;

namespace TaskTest
{
    internal class Program
    {
        private static void Main(string[] args)
        {
            var demo = new Program();
            demo.SimulateClick();
            Console.ReadLine();
        }

        public void SimulateClick()
        {
            buttonStart_Click(null, null);
        }

        private async void buttonStart_Click(object sender, EventArgs e)
        {
            var tasks = new List<Task>();
            for (var i = 0; i < 36; i++)
            {
                var taskId = i;
                var t = Task.Factory.StartNew((() =>
                {
                    Console.WriteLine($"Starting Task ({taskId})");
                    for (var ii = 0; ii < 200000; ii++)
                    {
                        Task.Delay(TimeSpan.FromMilliseconds(500)).Wait();
                        var s1 = new string(' ', taskId);
                        var s2 = new string(' ', 36-taskId);
                        Console.WriteLine($"Updating Task {s1}X{s2} ({taskId})");
                    }
                    Console.Write($"Done ({taskId})");
                }),TaskCreationOptions.LongRunning);
                tasks.Add(t);
            }
            await Task.WhenAll(tasks);
            Console.WriteLine("Done, enabld UI controls");
        }
    }
}