如何在 ASP NET Core 中定义、引发和处理异步事件

异步

使用方法时，通常会将 a 返回给调用方等待。asyncTask

async Task MyAsyncMethod()
{
    // async will implicitly create a new task and return it.
    return;
}

var task = MyAsyncMethod();

// execute the task
await task;

// the task is done

如果不这样做，关键字将执行该方法，因为它无法创建任务。async

async void MyAsyncMethod()
{
    return;
}

// the method execution is started, because it's async
MyAsyncMethod();

事件

通常，事件源 （） 只关心引发事件，它不知道有多少监听器，因此它不能排除它们返回值。MyAppEvents

要定义一个事件，你需要做两件事

• 事件处理程序签名
• 事件定义（基本上是其名称）

// event handlers signature
public delegate SomeReturnValueType MyEventDelegate(FirstArgType arg1);

// event definition
public event MyEventDelegate MyEventName;

你可以认为你可以用它来从处理程序返回值，但如果你这样做SomeReturnValueType

var result = MyEventName.Invoke();

result将设置为最后一个处理程序的返回值。

混合两者

如果将处理程序定义为返回 a 并在引发事件时尝试返回它们，则只会等待最后一个处理程序的任务。Taskawait

// task only represents the last handler
var task = MyAsyncEvent.Invoke();

await task;

这样做可能会导致混淆，因此我建议将处理程序委托定义为不返回 ，因此没有人尝试返回。Taskawait

public delegate void MyAsyncMethod();

引发事件时，执行将继续，因为事件源不知道（也不应该）知道处理程序。

解决方法

利用依赖注入，可以将服务定义为事件处理程序。

public interface IEventHandler<in TEvent>
{
     Task ExecuteAsync(TEvent @event);
}

// custom handler
public class CustomEventHandler : IEventHandler<CustomEvent>
{
     public Task ExecuteAsync(CustomEvent @event)
     {
          // do logic
     }
}

// the event source
public class MyAppEvents
{
     private readonly IEnumerable<IEventHandler<CustomEvent>> _handlers;
    
     public MyAppEvents(IEnumerable<IEventHandler<CustomEvent>> handlers)
     {
          _handlers = handlers;
     }

     private async Task RaiseCustomEventAsync()
     {
        var @event = new CustomEvent();
        
        var tasks = _handlers.Select(h => t.Execute(@event));

        // execute all task and await them
        await Task.WhenAll(tasks);
     }
}