.NET TPL 无限期结束后启动任务

Question

我有一个处理从数据库中提取的图像的应用程序。我需要并行处理各种图像，因此我将 .NET TPL 与 Tasks 一起使用。

我的应用程序是 C# 中的 Winforms 应用程序。我只能选择启动多少个进程和一个“开始”按钮。我现在的做法是这样的：

private Action getBusinessAction(int numProcess) {
    return () =>
    {
        try {
            while (true) {
                (new BusinessClass()).doSomeProcess(numProcess);
                tokenCancelacion.ThrowIfCancellationRequested();
            }
        }
        catch (OperationCanceledException ex) {
            Console.WriteLine("Cancelled process");
        }
    };
}

...

for (int cnt = 0; cnt < NUM_OF_MAX_PROCESS; cnt++) {
    Task.Factory.StartNew(getBusinessAction(cnt + 1), tokenCancelacion);
}

在这种情况下，如果我选择 8 作为进程数，它将启动 8 个正在运行的任务，直到应用程序关闭。但我认为更好的方法是启动一些调用doSomeProcess 方法的任务，然后完成。但是当任务完成时，我想启动相同的任务或启动执行相同任务的新实例，以便始终并行运行该数量的进程。 TPL 中有没有办法实现这一点？

Answer 1

这听起来很适合TPL Dataflow 的ActionBlock。您在开始时创建一个块。设置它应该同时处理多少个项目（即 8 个）并将项目发布到其中：

var block = new ActionBlock<Image>(
    image => ProcessImage(image), 
    new ExecutionDataflowBlockOptions { MaxDegreeOfParallelism = 8});

foreach (var image in GetImages())
{
    block.Post(image);
}

这将负责在需要时创建多达 8 个任务，当它们不再需要时，数量会减少。

完成后，您应该发出块完成的信号并等待它完成：

block.Complete();
await block.Completion;