C#-并发编程 Promise, Future 和 Callback
并发编程 Promise, Future 和 Callback
在并发编程中,我们通常会用到一组非阻塞的模型:Promise,Future 和 Callback。其中的 Future 表示一个可能还没有实际完成的异步任务的结果,针对这个结果可以添加 Callback 以便在任务执行成功或失败后做出对应的操作,而 Promise 交由任务执行者,任务执行者通过 Promise 可以标记任务完成或者失败。 可以说这一套模型是很多异步非阻塞架构的基础。
这一套经典的模型在 Scala、C# 中得到了原生的支持,但 JDK 中暂时还只有无 Callback 的 Future 出现,当然也并非在 JAVA 界就没有发展了,比如 Guava 就提供了ListenableFuture 接口,而 Netty 4+ 更是提供了完整的 Promise、Future 和 Listener 机制,在 Netty 的官方文档 Using as a generic library 中也介绍了将 Netty 作为一个 lib 包依赖,并且使用 Listenable futures 的示例。在实际的项目使用中,发现 Netty 的 EventLoop 机制不一定适用其他场景,因此想去除对 EventLoop 的依赖,实现一个简化版本。
参考 Scala 和 Netty 的代码重新定义了接口和实现,先介绍下和 Netty 版本的区别:
- 去除了对 EventLoop 的依赖,Callback 的执行策略不同:任务未完成时添加的 Callback,会在结束任务的线程执行;任务完成后添加的 Callback 会在添加 Callback 线程立即执行
- 一个 Callback 执行后会立即被清理
- Callback 可以根据任务结果添加,支持添加以下三种 Callback: onComplete, onSuccess, onFailure, 不需要和 Netty 的 FutureListener 一样大部分场景下都需要检查 future.isSuccess 等
- 支持 Callback 的组合,Callback 包含一些函数式的方法,比如 compose 和 andThen 可以用来组合
- 使用 CountdownLatch 替换掉了 Netty 的 wait/notify 实现
- 去掉 Netty Future 一些不常使用的方法,同时补充一些模型间关联的方法,比如 Promise.getFuture
然后再介绍几个使用这个 commons-future 的示例:
- 异步执行任务,获得 Future 后添加 Callback
final TaskPromise promise = new DefaultTaskPromise(); final TaskFuture future = promise.getFuture(); final CountDownLatch latch = new CountDownLatch(1); future.onComplete(new TaskCallback() { // 添加结束 Callback @Override public TaskFuture apply(TaskFuture f) { latch.countDown(); return f; } }); new Thread(new Runnable() { @Override public void run() { promise.setSuccess(null); } }).start(); latch.await();
- 异步执行任务,获得 Future 后添加成功结束的 Callback
final TaskPromise promise = new DefaultTaskPromise(); final TaskFuture future = promise.getFuture(); final CountDownLatch latch = new CountDownLatch(1); future.onSuccess(new TaskCallback() { // 添加成功结束 Callback @Override public TaskFuture apply(TaskFuture f) { latch.countDown(); return f; } }); new Thread(new Runnable() { @Override public void run() { promise.setSuccess(null); } }).start(); latch.await();
- 异步执行任务,获得 Future 后,添加失败结束的组合 Callback
final TaskPromise promise = new DefaultTaskPromise(); final TaskFuture future = promise.getFuture(); final CountDownLatch latch = new CountDownLatch(2); future.onFailure(new TaskCallback() { @Override public TaskFuture apply(TaskFuture f) { latch.countDown(); return f; } }.andThen(new TaskCallback() { @Override public TaskFuture apply(TaskFuture f2) { latch.countDown(); return f2; } })); new Thread(new Runnable() { @Override public void run() { promise.setFailure(new IllegalStateException("cm")); } }).start(); latch.await();
- 异步执行任务,获得 Future 后阻塞等待任务完成
final TaskPromise promise = new DefaultTaskPromise(); final TaskFuture future = promise.getFuture(); new Thread(new Runnable() { @Override public void run() { try { TimeUnit.SECONDS.sleep(2); } catch (InterruptedException e) { } promise.setFailure(new IllegalStateException("cm")); } }).start(); future.await();
代码仓库: https://bitbucket.org/qiyi/commons-future
源文链接: http://isouth.org/archives/354.html
参考:
- http://docs.scala-lang.org/sips/completed/futures-promises.html
- http://scala-lang.org/
- https://github.com/netty/netty
- http://docs.oracle.com/javase/6/docs/api/java/util/concurrent/CountDownLatch.html
- http://biasedbit.com/countdownlatch-vs-wait-notify/
原创文章,转载请注明: 转载自并发编程网 – ifeve.com本文链接地址: 并发编程 Promise, Future 和 Callback
相关文章
- C#由转换二进制所引起的思考,了解下?
- c# 中内部类的简单介绍 C#内部类
- C#订阅与发布标准实现 visual studio code .net 开发 设计模式之☞策略模式 C#字符串转二进制、二进制转字符串 c# 接口的协变和逆变 c# 使用迭代器来创建可枚举类型 博客园首页新随笔联系订阅管理 随笔 - 117 文章 - 0 评论 - 57 c# 创建,加载,修改XML文档
- c#打包文件解压缩 C#中使用委托、接口、匿名方法、泛型委托实现加减乘除算法 一个简单例子理解C#的协变和逆变 对于过长字符串的大小比对
- ASP.NET MVC 学习笔记-2.Razor语法 ASP.NET MVC 学习笔记-1.ASP.NET MVC 基础 反射的具体应用 策略模式的具体应用 责任链模式的具体应用 ServiceStack.Redis订阅发布服务的调用 C#读取XML文件的基类实现
- C#中泛型方法与泛型接口 C#泛型接口 List<IAll> arssr = new List<IAll>(); interface IPerson<T> c# List<接口>小技巧 泛型接口协变逆变的几个问题
- 浅谈JS中的!=、== 、!==、===的用法和区别 JS中Null与Undefined的区别 读取XML文件 获取路径的方式 C#中Cookie,Session,Application的用法与区别? c#反射 抽象工厂
- 【卷土重来之C#学习笔记】(二)c#编程概述
- C#控件之TreeView
- C#【文件操作篇】保存内容到txt文件
- 《C#并发编程经典实例》—— 转换.NET事件
- C#中PostMessage和SendMessage的参数传递实例
- c#使用System.Windows.Forms.DataVisualization.Charting.dll绘制图表实例
- C# File类、Path类复习
- C# xml转化为类集合
- C# 集合-并发处理-锁OR线程
- C# 集合-并发处理-锁OR线程
- C#Color对象的使用介绍及颜色对照表
- C#根据当前时间获取,本周,本月,本季度等时间段
- C# winform 读取数据库并显示成datagrid
- C# 跨域