产生工作线程

Question

在 C# 中，

如何产生多个线程，然后在返回整个结果集之前按顺序将结果添加到列表中？

有哪些最佳做法？

到目前为止，我一直在使用 ManualResetEvent 来发出最后一个元素已被线程处理的信号。

但是当它返回时，我需要让它们按顺序合并结果集，这样我们就不会遇到返回值列表（总结果）的争用问题。

Answer 1

当您启动每个线程时，将您的序列标识符和回调方法传递给它，并增加一个指示正在运行的线程总数的计数器。当每个线程完成时，它会调用回调方法，该方法会减少正在运行的线程计数并将结果插入到SortedDictionary 中，并以序列 ID 为键。当最后一个线程完成时，回调可以向您的主程序发出信号。

Answer 2

如果您使用的是 .Net 4，例如，您可以使用 Task 类。这是一个合并列表的示例

Task<List<string>> task1 = new Task<List<string>>(SomeFunction);
Task<List<string>> task2 = new Task<List<string>>(SomeFunction);
task1.Start();
task2.Start();

var taskList = new List<Task<List<string>>> {task1, task2};

Task.WaitAll(taskList.ToArray());

List<string> res = new List<string>();
foreach (Task<List<string>> t in taskList)
{
    res.AddRange(t.Result);
}

和你的功能

List<string> SomeFunction()
{
    return new List<string>{"1","2"};
}

Answer 3

现在是Reactive Extensions for .NET Framework 的一部分的任务并行库使这样的事情变得微不足道。有一组 Parallel 构造用于并行化您的代码，还有一组线程安全的 Concurrent{Container}s 可以与它​​们一起使用。

以下是对一组数字进行平方的示例，使用Parallel.For 和ConcurrentBag 来存储结果。

using System.Threading.Tasks;
using System.Collections.Concurrent;

namespace ParallelTest
{
    class Program
    {
        static void Main(string[] args)
        {
            var results = new ConcurrentBag<int>();
            Parallel.For(0, 10, i =>
            {
                results.Add(i * i);
            });
            foreach (int i in results)
                System.Console.WriteLine(i);
        }
    }
}

ConcurrentBag 是常规的 IEnumerable，正如您所见，我使用常规的非并行 foreach 来打印最后的结果。

注意：所有这些东西在 .NET 4.0 中实际上都是标准的，如果你想要在 .NET 3.5 中使用 Rx，你只需要它。

Answer 4

如果您在生成线程之前知道最终顺序（您的“顺序”暗示），您可以将索引传递给每个线程，并将其结果写入数组中的那个“槽”。因此，当所有线程都完成了处理（以任何顺序）时，结果将已经正确排序，完全避免了后处理排序的需要。