异步事件处理程序和并发

Question

在 C# 控制台应用程序的上下文中，如果我创建一个用于异步接收消息的循环，它会为收到的每条消息引发一个事件，例如：

while (true)
{
   var message = await ReceiveMessageAsync();
   ReceivedMessage(new ReceivedMessageEventArgs(message));
}

现在，如果我有多个事件订阅者（举例来说，假设为 3 个订阅者），所有订阅者都使用异步事件处理程序，例如：

async void OnReceivedMessageAsync(object sender, ReceivedMessageEventArgs args)
{
   await TreatMessageAsync(args.Message);
}

应该以线程安全的方式对消息对象进行编码吗？我认为是这样，因为来自不同事件处理程序的 TreatMessageAsync 代码可能会为所有订阅者同时运行（当引发事件时，订阅者的三个异步事件处理程序被调用，每个都启动一个异步操作，该操作可能在不同线程上同时运行由任务调度程序）。还是我错了？

谢谢！

Answer 1

您应该以线程安全的方式对其进行编码。最简单的方法是使其不可变。

如果你有一个真正的事件，那么它的参数应该是不可变的。如果您使用的事件处理程序不是真正的 event（例如 command 或 implementation），那么您可能需要修改您的API。

可以有并发的事件处理程序，因为每个处理程序将按顺序启动，但它们可以同时恢复。

Answer 2

正如 Stephen 所建议的，在这种情况下实现线程安全的最简单方法是使用不可变事件参数。

在大多数情况下，甚至 args 仅用于通知观察者，而不需要从可观察方到观察者的更改（即从事件订阅者到事件所有者）。在某些特殊情况下，例如实现责任链设计模式事件参数应该是可变的，但在所有其他情况下它们不应该。

在这种情况下，不变性不仅可以帮助您轻松实现并发处理程序，还可以带来更清晰的设计并提高可维护性，因为现在可以不正确地使用您的 API。

结论是：你应该实现你的方法线程安全，但你应该知道，如果你的事件将从非 UI 线程触发，来自事件处理程序的未处理异常将被吞没。

这是使用 async void 方法的危险：如果此方法因异常而失败，并且您将在没有同步上下文的环境中调用它（例如从控制台应用程序的线程池线程），您将获得未处理的域您的应用程序将关闭的异常：

internal class Program
{
    static Task Boo()
    {
        return Task.Run(() =>
                        {
                            throw new Exception("111");
                        });
    }

    private static async void Foo()
    {
        await Boo();
    }

    static void Main(string[] args)
    {
        // Application will blow with DomainUnhandled excpeption!
        try
        {
            Foo();
        }
        catch (Exception e)
        {
            // Will not catch it here!
            Console.WriteLine(e);
        }

        Console.ReadLine();
    }
}