Асинхронные обработчики событий и параллелизм

Вы должны кодировать его потокобезопасным способом. Самый простой способ сделать это — сделать его неизменным.

Если у вас есть истинное событие, его аргументы должны быть неизменяемыми. Если вы используете обработчик событий для чего-то, что не является настоящим событием (например, команда или реализация), вы можете изменить свой API.

Можно иметь параллельные обработчики событий, поскольку каждый обработчик будет запускаться последовательно, но они могут возобновлять одновременно.

Как предположил Стивен, самый простой способ добиться потокобезопасности в этом случае — использовать неизменяемые аргументы событий.

В большинстве случаев даже аргументы используются только для уведомления наблюдателей без каких-либо требований для изменений от наблюдаемой стороны к наблюдателю (т.е. от подписчика события к владельцу события). В некоторых особых случаях, таких как реализация шаблона проектирования цепочки ответственности, аргументы событий должны быть изменяемыми, но во всех других случаях они не должны.

Неизменяемость в этом случае помогает вам не только легко реализовывать параллельные обработчики, но и приводит к более четкому дизайну и повышает удобство сопровождения, поскольку теперь у вас есть возможность неправильно использовать ваш API.

Вывод: вы должны реализовать потокобезопасность своих методов, но вы должны знать, что необработанное исключение из обработчика событий будет проглочено, если ваше событие будет запущено из потока, отличного от пользовательского интерфейса.

Вот опасность использования асинхронных методов 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();
    }
}