使用 Monitor.Wait() 和 Monitor.Pulse() 暂停/恢复长时间运行的任务 (while(true)) 是否正确？

Question

我有以下代码，它充当异步消费者：

private readonly Object sync;

private async void ConsumeAsync()
{
    // The reason why I have an await here is to yield the control to the caller, e.g: if an exception happens inside the Listen method, it's being propagated and can be handled in caller codes.
    await Task.Run(() => this.Listen());
}

private void Listen()
{
    ...
    while (true)
    {
        lock (sync)
        {
            while (<blocking-condition>)
            {
                Monitor.Wait(sync);
            }
        }

        // Consuming happens here
    }
}

// Changing the blocking condition happens outside the infinite loop with proper Monitor.Pulse usage

我的设计关注点：

1. 我有一个异步 void 即发即弃的方法，如果没有消耗，则必须阻止该方法。这是一个正确的方法吗？
2. 我必须对任务使用 LongRunning 选项吗？
3. 我必须使用 CancellationToken 吗？
4. 我是否将异常正确地传播到更高级别的异常处理程序？

Answer 1

您的四个问题中有两个对于本论坛来说过于宽泛。只有您可以决定这是否适合您的场景。同样，是否使用CancellationToken 的问题取决于您需要什么功能。如果您需要能够取消操作，这可能是一个好方法，但不是唯一的方法，而且这里没有足够的细节来知道什么是最好的。你也不能提供足够的细节，同时让这个论坛的问题足够窄。

当然，如果您不需要能够取消操作，那么该问题的答案是“不，您不需要使用CancellationToken”:)。

至于其他两个问题，只有一个有明确的答案：

1. “我必须对任务使用 LongRunning 选项吗？”

不，你没有有。但强烈建议用于实际上长期运行的任务。这将有助于任务调度框架正确管理您的任务线程。

4. “我是否将异常正确地传播到更高级别的异常处理程序？”

你是怀疑的。由于您的ConsumeAsync() 方法是async void，因此您显然不能等待它。做这种事情的自然方法是编写更像这样的代码：

private Task ConsumeAsync()
{
    return Task.Run(() => this.Listen());
}

async Task SomeMethodSomewhereElse()
{
    try
    {
        await ConsumeAsync();
    }
    catch (...)
    {
        // An exception thrown from your long-running task will be caught here
    }
}

请注意，ConsumeAsync() 方法本身实际上并不需要是async。您可以只返回创建的 Task，并且将完全一样地工作（嗯，更有效...但主要是不要添加完全不必要的额外代码）。

按照您编写它的方式，您必须做很多额外的工作才能捕获抛出的异常（即直接从SynchronizationContext 处理它）。也许你这样做了，也许你没有。您没有显示该代码，所以我假设您没有。