BackgroundWorker重启异常：无法等待CancelAsync方法问题咨询

我太懂这个坑了！BackgroundWorker的CancelAsync()其实只是给worker发一个取消通知，它本身不会阻塞等待worker真的停下来。你紧接着调用RunWorkerAsync()的时候，前一个worker还在运行，自然就会抛出InvalidOperationException。而且CancelAsync()是void方法，根本没法直接await，这就是你改成async方法后报错“表达式未生成值”的原因。

下面给你两种靠谱的解决方案：

方案一：利用RunWorkerCompleted事件触发重启 #

这个方法通过标记位记录重启请求，等worker真正完成停止后再自动启动，逻辑简单直接：

private BackgroundWorker _worker = new BackgroundWorker();
private bool _isRestartRequested = false;

public YourClass()
{
    // 初始化worker，必须开启支持取消
    _worker.WorkerSupportsCancellation = true;
    _worker.DoWork += Worker_DoWork;
    _worker.RunWorkerCompleted += Worker_RunWorkerCompleted;
}

private void Worker_DoWork(object sender, DoWorkEventArgs e)
{
    var worker = sender as BackgroundWorker;
    while (!worker.CancellationPending)
    {
        // 这里写你的核心工作逻辑
        // 注意：一定要定期检查CancellationPending，不然worker不会响应取消
        // 比如处理完一个任务单元就检查一次
        DoSomeWork();
    }
}

private void Worker_RunWorkerCompleted(object sender, RunWorkerCompletedEventArgs e)
{
    // 如果之前标记了需要重启，就立刻启动新的worker
    if (_isRestartRequested)
    {
        _isRestartRequested = false;
        _worker.RunWorkerAsync();
    }
}

// 对外暴露的重启方法
public void RestartWorker()
{
    if (_worker.IsBusy)
    {
        // 标记需要重启，然后发送取消信号
        _isRestartRequested = true;
        _worker.CancelAsync();
    }
    else
    {
        // 如果worker没在运行，直接启动
        _worker.RunWorkerAsync();
    }
}

方案二：用async/await封装等待逻辑 #

如果你更习惯async/await的写法，可以自己封装一个等待worker完成的Task，这样就能优雅地等待取消完成：

private BackgroundWorker _worker = new BackgroundWorker();

public YourClass()
{
    _worker.WorkerSupportsCancellation = true;
    _worker.DoWork += Worker_DoWork;
}

private void Worker_DoWork(object sender, DoWorkEventArgs e)
{
    var worker = sender as BackgroundWorker;
    while (!worker.CancellationPending)
    {
        // 同样要定期检查CancellationPending
        DoSomeWork();
    }
}

// 封装一个等待worker完成的异步方法
private async Task WaitForWorkerToStopAsync(BackgroundWorker worker)
{
    if (!worker.IsBusy)
        return;

    var completionSource = new TaskCompletionSource<bool>();
    RunWorkerCompletedEventHandler completedHandler = null;

    completedHandler = (s, e) =>
    {
        // 解绑事件，避免内存泄漏
        worker.RunWorkerCompleted -= completedHandler;
        completionSource.SetResult(true);
    };

    worker.RunWorkerCompleted += completedHandler;
    await completionSource.Task;
}

// 异步重启方法
public async Task RestartWorkerAsync()
{
    if (_worker.IsBusy)
    {
        _worker.CancelAsync();
        // 等待worker彻底停止后再启动
        await WaitForWorkerToStopAsync(_worker);
    }
    _worker.RunWorkerAsync();
}

关键注意事项 #

不管用哪种方案，DoWork方法里必须主动检查CancellationPending！如果你的工作逻辑是长时间阻塞的（比如没有循环的单次 heavy 操作），可以拆分成多个小单元，每个单元结束后检查一次取消信号，或者使用支持取消的异步API（如果有的话）。不然CancelAsync()发了信号，worker也不会停下来，重启逻辑就永远不会触发。

内容的提问来源于stack exchange，提问作者Aaron Crawley