1

现在我正在生成 3 个线程来做一些并发工作，我使用 Threadpooling 设置它，因为我希望所有线程同时运行，但在继续之前让所有线程完成。这是代码的要点：

_resetEvents = new ManualResetEvent[3];

_resetEvents[0] = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(DoWorkA);
_resetEvents[1] = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(DoWorkB);
_resetEvents[2] = new ManualResetEvent(false);
ThreadPool.QueueUserWorkItem(DoWorkC);

WaitHandle.WaitAll(_resetEvents);

但是我的方法都使用相同的代码库，我将其分解为 3 种方法，只是为了 set() 正确的线程。

private void DoWorkA(object o) {
    var workerClass = new WorkerClass();
        workerClass.Process();
    _resetEvents[0].Set();
}
private void DoWorkB(object o) {
    var workerClass = new WorkerClass();
        workerClass.Process();
    _resetEvents[1].Set();
}
private void DoWorkC(object o) {
    var workerClass = new WorkerClass();
        workerClass.Process();
    _resetEvents[2].Set();
}

显然它不是很干，因为我希望有 4 个或 5 个线程，但要确保 Set() 在完成时设置正确的 _resetEvent。

关于如何安全地做到这一点并使其更加干燥和可扩展的任何建议？

4

2 回答 2

5

您可以只使用 TPL 中的任务而不是线程，并且不需要等待句柄：

Action execute = () => { 
    var worker = new WorkerClass();
    worker.Process();
};

var task1 = Task.Run(execute);
var task2 = Task.Run(execute);
var task3 = Task.Run(execute);
Task.WaitAll(task1, task2, task3);

或者，或者：

Action execute = () => (new WorkerClass()).Process();

Parallel.Invoke(execute, execute, execute);

如果您需要将其扩展到 N 项，您可以切换到 PLINQ 或 Parallel.For/ForEach，并使用：

int numToRun = 42;
ParallelEnumerable.Range(0, numToRun).ForAll(i => (new WorkerClass()).Process());
于 2013-05-15T16:58:43.300 回答
1

像Parallel.ForEach这样的东西可能更好。

否则，只需将传入参数视为数组中的索引就足够了：

private void DoWork(object index) 
{
    var workerClass = new WorkerClass();
        workerClass.Process();
    _resetEvents[(int)index].Set();
}

ThreadPool.QueueUserWorkItem(DoWork, 0);
于 2013-05-15T17:01:04.013 回答