等待多个带有回调的方法完成

JPP*_*mer 1 c# multithreading asynchronous .net-2.0

我有多个异步方法需要调用并等待它们全部完成。异步方法都有回调参数,这些参数会在异步处理完成时执行。所以我想我需要在每个回调中放置一些信号设备,然后在继续之前等待所有信号到来。

在做了一些搜索之后,我想我可以使用一个数组,AutoResetEvents然后调用WaitHandle.WaitAll来等待它们。就像是:

WaitHandle[] waitHandles = new WaitHandle[] 
{
    new AutoResetEvent(false),
    new AutoResetEvent(false)
};

DoWorkA((callback) =>
{
    waitHandles[0].Set();
});

DoWorkB((callback) =>
{
    waitHandles[1].Set();
});

// wait for DoWorkA and DoWorkB to finish
WaitHandles.WaitAll(waitHandles);

// continue with the processing
Run Code Online (Sandbox Code Playgroud)

我想知道这是否是一个好方法,或者是否有更好/更简单的方法。我需要 .Net 2.0 的解决方案,但我也很想知道更高版本的 .Net 还提供哪些其他解决方案。

编辑: 尝试此代码后,我发现它不起作用。UI 线程停止WaitHandles.WaitAll(waitHandles)并且回调永远不会运行......

在 DoWork 方法中,有代码在后台线程上不时运行,然后从该后台线程我尝试通过BeginInvoke从 UI 线程调用的控件来运行回调。但是,回调永远不会在 UI 线程上执行。任何想法我做错了什么?

编辑 2: 我意识到为什么它不起作用 - 线程调用WaitHandles.WaitAll(waitHandles)与回调试图在其上运行的线程(UI 线程)相同。所以当然,如果线程正在等待信号,回调将永远不会在同一个线程上运行,因此Set()永远不会被调用。WaitAll(waitHandles) 和 Set() 应该可以工作,只要它们不打算在同一线程上运行。我想我需要修复它,以便在 UI 线程等待时回调在后台线程上运行。如果我的想法不正确,请告诉我。

Ale*_*kov 5

是的,使用事件是等待多个回调完成的合理方法,对于 2.0,如果您不能使用外部库,它可能是您能做的最好的方法。

你可以用一个事件重写代码并计算回调完成,但它可能更复杂(同时允许无限数量的回调)。或者类似的方法可以通过Semaphore实现。

如果您可以使用 4.5+,那么使用async/重写方法await可能是更好的选择。

  // use "async Task(...)" as equivalent of "void DoWorkA(...)".
  async Task<int> DoWorkAAsync(int arg1)
  {
     var serviceResult = await service.CallAsync(arg1);
     return ParseServiceResult(serviceResult);
  }

  async Task<int> DoWorkBAsync() 
  { 
     ... await SomeAsync(1,2,3);...
     return someResult;
  }

  var tasks = new[] {DoWorkAAsync(42), DoWorkBAsync() }; 
  await Task.WhenAll(tasks);

  var resultOfA = tasks[0].Result;
Run Code Online (Sandbox Code Playgroud)