基于事件的异步模式有哪些替代方案？

Question

我正在考虑实现一个可以同时运行多个操作的 API。 MS 推荐了基于事件的异步模式：

// Asynchronous methods.
public void Method1Async(string param, object userState);
public event Method1CompletedEventHandler Method1Completed;

public void CancelAsync(object userState);
public bool IsBusy { get; }

但这似乎有点笨拙 - 它要求客户端过滤掉不适合他们的回复，并在完成后断开事件处理程序等。我的想法更像是：

AsyncOperation1(string parm, Action<T> callback)

每个客户端都会直接获得自己的结果。我无法弄清楚如何优雅地支持取消。我想显而易见的事情是 AsyncOperation1 返回某种可以传递给 CancelAsync 方法的令牌。我想了解更多关于 .Net 或其他可以适当翻译的语言中常用的其他异步模式

Answer 1

看看Reactive Extensions，你可以返回一个可以被客户端订阅的 Observable。

订阅返回一个实现 IDisposable 的对象，这是取消订阅的机制，只需处置该对象。

例如：

IObservable<T> o = Method1Async(params);

var observer = o.Subscribe(r => {/*do stuff with the result*/},
                           ex => {/* do stuff with the exception */);

// decide to cancel
observer.Dispose();

您可以使用 nuget 安装 Reactive Extensions 位，只需“install-package rx-main”