多线程：WaitAll 未按预期等待

Question

我有一个线程正在调用两个单独的线程来做一些工作。每当任何作业完成时，都会调用 Waithandle.Set(0 ，并且在父工作线程结束时，我想在继续之前等待所有作业都完成。但价格A()仍然先出现，然后是PriceB ()。

new Thread(() =>
                           {
                               new Thread(() =>
                               {
                                   PriceA = _service.GetPriceA();
                                   _waithandle[0].Set();
                               }).Start();

                               new Thread(() =>
                               {
                                   PriceB = _service.GetPriceB();
                                   _waithandle[1].Set();
                               }).Start();

                               WaitHandle.WaitAll(_waithandle);
                           }).Start();
Console.WriteLine("Hello");

更新：

private EventWaitHandle[] _waithandle;

Ctor：

 _waithandle[0] = new ManualResetEvent(false);
 _waithandle[1] = new ManualResetEvent(false);

Answer 1

您正在创建一个单独的线程来等待...但是您给出的语句后面的代码将继续，因为您不在那个线程中等待。换句话说，您正在创建三个线程：

• 线程 X：创建线程 A 和 B，然后等待它们完成
• 线程 A：获取 PriceA，然后设置 waitHandle[0]
• 线程 B：获取 PriceB，然后设置 waitHandle[1]

但是线程 X 在等待之后什么也没做，那么在其中等待有什么意义呢？

此外，只需在您创建的额外线程上调用 Join 就会简单得多。事实上，如果您只需要在“当前”线程中等待，则首先只需要一个额外的线程：

Thread t = new Thread(() => { PriceA = _service.GetPriceA(); });
t.Start();
PriceB = _service.GetPriceB();
t.Join();
// Other code

当您到达“其他代码”时，PriceA 和 PriceB 都会有已设置。当然，这缺少大量的错误处理......但是当您有一个比当前过于复杂的代码更简单的起点时，添加起来会更容易。

Answer 2

new Thread(() =>
                           {
                               new Thread(() =>
                               {
                                   _priceA = _service.GetPriceA();
                                   _waithandle[0].Set();
                               }).Start();

                               new Thread(() =>
                               {
                                   _priceB = _service.GetPriceB();
                                   _waithandle[1].Set();
                               }).Start();

                               WaitHandle.WaitAll(_waithandle);
                               PriceA = _priceA;
                               PriceB = _priceB;
                           }).Start();

这为我完成了工作。罪魁祸首是 PriceA 和 PriceB 的 INotifyChangedProperty()，它过早更新了 UI，使我的等待变得多余。万一其他人也有类似的问题...

Answer 3

您是否正确重置了 _waithandle[0] 和 [1]？例如：

_waithandle[0] = new ManualResetEvent(false);
_waithandle[1] = new ManualResetEvent(false);