等待后的 SynchronizationLockException

Question

我有一个名为HandleMessage 的方法，启动了一个新线程来处理消息。如果锁对象被成功获取，则处理它。否则将消息放入队列。 SynchronizationLockException 总是被抛出 Monitor.Exit(o)，因为在 await 之后，上下文不再在原始线程中。正确的实现方式是什么？

    public void HandleMessage(string message)
    {
        Task.Factory.StartNew(async delegate
        {
            if (Monitor.TryEnter(o))
            {
                try
                {
                    do
                    {
                        await HandleMessageAsync(message);
                    }
                    while (queue.TryDequeue(out message));
                }
                finally
                {
                    Monitor.Exit(o);
                }
            }
            else
            {
                queue.Enqueue(message);
            }
        });
    }

Answer 1

如您所见，Monitor.Enter/Exit 是线程仿射的。

在他关于创建异步友好协调原语的系列中，Stephen 包含了一个 AsyncLock，这应该是您正在寻找的 AFAICT。

Answer 2

现在我发现这里的同步锁object o没用，因为我的queue是并发的。最后的解决办法是：

public void HandleMessage(string message)
{
    Task.Factory.StartNew(async delegate
    {
        while (queue.TryDequeue(out message));
        {
           await HandleMessageAsync(message);
        }
    });
}

这解决了问题。但它本身并没有回答问题。