嵌套BackgroundWorkers：RunWorkerCompleted调用错误的线程？

Question

我正在研究异步操作，需要调用进一步的异步任务。我试图通过使用BackgroundWorkers来保持简单，结果是一个BackgroundWorker的DoWork()回调调用一个创建第二个BackgroundWorker的方法，就像这样（减去错误检查和所有那些为了简洁起见）：

class Class1
{
    private BackgroundWorker _worker = null;

    public void DoSomethingAsync()
    {
        _worker = new BackgroundWorker();
        _worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(_worker_RunWorkerCompleted);
        _worker.DoWork += new DoWorkEventHandler(_worker_DoWork);
        _worker.RunWorkerAsync();
    }

    void _worker_DoWork(object sender, DoWorkEventArgs e)
    {
        Class2 foo = new Class2();
        foo.DoSomethingElseAsync();
        while(foo.IsBusy) Thread.Sleep(0);  // try to wait for foo to finish.
    }

    void _worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    {
        // do stuff
    }
}

class Class2
{
    private BackgroundWorker _worker = null;
    Thread _originalThread = null;

    public AsyncCompletedEventHandler DoSomethingCompleted;

    public bool IsBusy { get { return _worker != null && _worker.IsBusy; } }

    public void DoSomethingElseAsync()
    {
        _originalThread = Thread.CurrentThread;

        _worker = new BackgroundWorker();
        _worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(_worker_RunWorkerCompleted);
        _worker.DoWork += new DoWorkEventHandler(_worker_DoWork);
        _worker.RunWorkerAsync();
    }

    void _worker_DoWork(object sender, DoWorkEventArgs e)
    {
        // do stuff
    }

    void _worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
    {
        Debug.Assert(Thread.CurrentThread == _originalThread);  // fails

        // Assuming the above Assert() were excluded, the following event would be raised on the wrong thread.
        if (DoSomethingCompleted != null) DoSomethingCompleted(this, new AsyncCompletedEventArgs(e.Error, e.Cancelled, null));
    }
}

所以问题是，我期望 Class2._Worker_RunWorkerCompleted() 在调用 Class2.DoSomethingElseAsync() 的同一线程上执行。这种情况永远不会发生——相反，回调在一个全新的线程上运行。

我的怀疑是：Class1 的 _worker_DoWork() 永远不会返回，这意味着线程永远不会返回到事件侦听器，即使事件侦听器存在（我怀疑有一个不存在）。另一方面，如果_worker_DoWork()确实返回，Class1的BackgroundWorker将自动提前完成——它需要等待Class2完成工作才能完成其工作。

这就引出了两个问题：

1. 我的怀疑正确吗？
2. 像这样嵌套异步操作的最佳方法是什么？我可以挽救BackgroundWorker方法，还是有其他更合适的技术？

Answer 1

如果在 UI 线程上创建 BackgroundWorker，则 DoWork 将在线程池线程上运行，而 RunWorkerCompleted 将在 UI 线程上运行。

如果 BackgroundWorker 在后台线程（即不是 UI 线程）上创建，DoWork 仍将在线程池线程上运行，并且 RunWorkerCompleted 也将运行在线程池线程上运行。

在您的情况下，由于您无法封送对任意（线程池）线程的调用，因此您将无法保证您想要的行为，尽管您可能想看看 System.Threading。同步上下文。

Answer 2

您应该使用 ManualResetEvent 在线程之间进行通信：

http://msdn.microsoft.com/en-us/library/system.threading.manualresetevent%28VS.71%29.aspx

Answer 3

首先，我看不到任何实际开始运行工作人员的地方。您可以更改 DoSomethingAsync 方法（还可以在 Class2 中添加对 DoSomethingElseAsync 方法的调用）

public void DoSomethingAsync()
{
    _worker = new BackgroundWorker();
    _worker.RunWorkerCompleted += new RunWorkerCompletedEventHandler(_worker_RunWorkerCompleted);
    _worker.DoWork += new DoWorkEventHandler(_worker_DoWork);
    _worker.RunWorkerAsync(); // add this line to start it
}

其次，工作处理程序（_worker_DoWork 方法）不能保证与对 DoSomethingAsync 的调用位于同一线程上 - 这是整个要点后台工作者。即/在另一个线程上工作。这同样适用于工作完成处理程序（_worker_RunWorkerCompleted 方法）。

最后，附加两个不同的后台工作人员似乎没有意义，除非顶级工作人员（Class1）也始终需要进行 Class2 工作。最好让一个经理来处理每个后台工作人员。