- 浏览: 71416 次
- 性别:
- 来自: 武汉
文章分类
最新评论
当向Executor提交批处理任务时,并且希望在它们完成后获得结果,如果用FutureTask,你可以循环获取task,并用future.get()去获取结果,但是如果这个task没有完成,你就得阻塞在这里,这个实效性不高,其实在很多场合,其实你拿第一个任务结果时,此时结果并没有生成并阻塞,其实在阻塞在第一个任务时,第二个task的任务已经早就完成了,显然这种情况用future task不合适的,效率也不高。
自己维护list和CompletionService的区别:
从list中遍历的每个Future对象并不一定处于完成状态,这时调用get()方法就会被阻塞住,如果系统是设计成每个线程完成后就能根据其结果继续做后面的事,这样对于处于list后面的但是先完成的线程就会增加了额外的等待时间。
而CompletionService的实现是维护一个保存Future对象的BlockingQueue。只有当这个Future对象状态是结束的时候,才会加入到这个Queue中,take()方法其实就是Producer-Consumer中的Consumer。它会从Queue中取出Future对象,如果Queue是空的,就会阻塞在那里,直到有完成的Future对象加入到Queue中。
CompletionService采取的是BlockingQueue<Future<V>>无界队列来管理Future。则有一个线程执行完毕把返回结果放到BlockingQueue<Future<V>>里面。就可以通过completionServcie.take().get()取出结果。
方法区别:
take 方获取并移除表示下一个已完成任务的 Future,如果目前不存在这样的任务,则等待。<如果需要用到返回值建议用take>
poll 获取并移除表示下一个已完成任务的 Future,如果不存在这样的任务,则返回null。
一下是jdk关于CompletionService的简介:
public interface CompletionService<V>
将生产新的异步任务与使用已完成任务的结果分离开来的服务。生产者 submit 执行的任务。使用者 take 已完成的任务,并按照完成这些任务的顺序处理它们的结果。例如,CompletionService 可以用来管理异步 IO ,执行读操作的任务作为程序或系统的一部分提交,然后,当完成读操作时,会在程序的不同部分执行其他操作,执行操作的顺序可能与所请求的顺序不同。
通常,CompletionService 依赖于一个单独的 Executor 来实际执行任务,在这种情况下,CompletionService 只管理一个内部完成队列。ExecutorCompletionService 类提供了此方法的一个实现。
内存一致性效果:线程中向 CompletionService 提交任务之前的操作 happen-before 该任务执行的操作,后者依次 happen-before 紧跟在从对应 take() 成功返回的操作。
观察注释位置中①和②结果的不同,①中先打印了3个线程的执行结果,5秒后打印了我们模拟延迟的线程的执行结果,②中先只打印了一个线程的执行结果,5秒后才打印出剩余的3个线程的执行结果。实践证明: 单纯的Future调用get()会被阻塞,而CompletionService会将先执行完的线程结果打印。
自己维护list和CompletionService的区别:
从list中遍历的每个Future对象并不一定处于完成状态,这时调用get()方法就会被阻塞住,如果系统是设计成每个线程完成后就能根据其结果继续做后面的事,这样对于处于list后面的但是先完成的线程就会增加了额外的等待时间。
而CompletionService的实现是维护一个保存Future对象的BlockingQueue。只有当这个Future对象状态是结束的时候,才会加入到这个Queue中,take()方法其实就是Producer-Consumer中的Consumer。它会从Queue中取出Future对象,如果Queue是空的,就会阻塞在那里,直到有完成的Future对象加入到Queue中。
CompletionService采取的是BlockingQueue<Future<V>>无界队列来管理Future。则有一个线程执行完毕把返回结果放到BlockingQueue<Future<V>>里面。就可以通过completionServcie.take().get()取出结果。
方法区别:
take 方获取并移除表示下一个已完成任务的 Future,如果目前不存在这样的任务,则等待。<如果需要用到返回值建议用take>
poll 获取并移除表示下一个已完成任务的 Future,如果不存在这样的任务,则返回null。
一下是jdk关于CompletionService的简介:
public interface CompletionService<V>
将生产新的异步任务与使用已完成任务的结果分离开来的服务。生产者 submit 执行的任务。使用者 take 已完成的任务,并按照完成这些任务的顺序处理它们的结果。例如,CompletionService 可以用来管理异步 IO ,执行读操作的任务作为程序或系统的一部分提交,然后,当完成读操作时,会在程序的不同部分执行其他操作,执行操作的顺序可能与所请求的顺序不同。
通常,CompletionService 依赖于一个单独的 Executor 来实际执行任务,在这种情况下,CompletionService 只管理一个内部完成队列。ExecutorCompletionService 类提供了此方法的一个实现。
内存一致性效果:线程中向 CompletionService 提交任务之前的操作 happen-before 该任务执行的操作,后者依次 happen-before 紧跟在从对应 take() 成功返回的操作。
package com; import java.util.ArrayList; import java.util.List; import java.util.concurrent.Callable; import java.util.concurrent.CompletionService; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorCompletionService; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class CallableAndFuture { public static void main(String[] args) { ExecutorService threadPool = Executors.newCachedThreadPool(); List<Future> futures = new ArrayList<Future>(); CompletionService<Integer> cs = new ExecutorCompletionService<Integer>( threadPool); //将4个线程由CompletionService启动 for (int i = 1; i < 5; i++) { final int taskID = i; cs.submit(new Callable<Integer>() { public Integer call() throws Exception { if (taskID == 2) {//在第二个位置开始模拟延迟 Thread.sleep(5000);//模拟延迟 } return taskID; } }); } //将4个线程由threadPool启动 for (int i = 1; i < 5; i++) { final int taskID = i; Future<Integer> future = threadPool.submit(new Callable<Integer>() { public Integer call() throws Exception { if (taskID == 2) {//在第二个位置模拟延迟 Thread.sleep(5000);//模拟延迟 } return taskID; } }); futures.add(future); } for (int i = 1; i < 5; i++) { try { System.out.println(cs.take().get());//① //System.out.println(futures.get(i-1).get());//② } catch (InterruptedException e) { e.printStackTrace(); } catch (ExecutionException e) { e.printStackTrace(); } } } };
观察注释位置中①和②结果的不同,①中先打印了3个线程的执行结果,5秒后打印了我们模拟延迟的线程的执行结果,②中先只打印了一个线程的执行结果,5秒后才打印出剩余的3个线程的执行结果。实践证明: 单纯的Future调用get()会被阻塞,而CompletionService会将先执行完的线程结果打印。
发表评论
-
android中string.xml通配符以及颜色
2016-11-29 21:42 1667string.xml <resources> ... -
使用zxing实现生成二维码
2016-11-28 00:58 596github: https://github.com/bill ... -
android将视频文件转化为图片
2016-11-24 00:04 2090public void getBitmapsFromVi ... -
android通过文件管理器选择文件
2016-11-22 23:36 1827public void openSystemF ... -
将bitmap保存为文件
2016-11-22 23:28 1301public void saveBitmap(Bitma ... -
Material Design动画(一)reveal effect
2016-09-22 22:47 445Animator animator = ViewAn ... -
Android将apk放置于asset目录下安装
2016-09-13 16:32 1059ServiceApkInstaller.java publ ... -
创建自定义控件在布局中的自定义属性
2016-09-11 21:15 6131.在values目录下新建attrs.xml < ... -
androidstudio搭建NDK开发环境
2016-09-08 18:53 19841.打开SDK Manager下载NDK 2.设置根目录中的 ... -
[Android Studio 权威教程]AS添加第三方库的6种方式(Jar,module,so等)
2016-09-05 18:07 746http://blog.csdn.net/yy13003263 ... -
android启动其他应用得service
2016-08-31 10:03 702Intent i=new Intent(); i.s ... -
android屏幕分辨率适配工具
2016-07-22 17:22 600下载附件后,执行 java -jar autolayout.j ... -
android不死服务的实现方法
2015-11-20 13:36 1144大部分应用在手机长按home键删除最近程序时,进程会被杀掉,本 ... -
android开机自启广播无效果的曲线解决方案
2015-10-04 23:24 2618AndroidManifest.xml <?xml ... -
坑爹的MediaPlayer.isPlaying()
2015-09-18 14:42 2469在这个安卓手机ROM千奇百怪的时代,MediaPlayer作为 ... -
Bitmap的简单应用
2015-03-23 23:56 662package com.example.b; imp ... -
listpreference
2015-01-07 23:02 589MyPreferencesActivity.java pa ... -
李刚安卓疯狂讲义
2014-02-11 23:30 37压缩分卷5个字 -
android开发工具
2014-01-29 00:07 560android开发工具 -
android 拖动条改变屏幕亮度
2013-04-26 00:29 1151main.xml <?xml version=&qu ...
相关推荐
如果 Future 结果没有完成,调用 get() 方法,程序会 阻塞 在那里,直至获取返回结果 先来看第一种实现方式,假设任务 A 由于参数原因,执行时间相对任务 B,C,D 都要长很多,但是按照程序的执行顺序,程序在 get()...
有以下类的实例: ThreadPool ScheduledThread CyclicBarrier BlockingQueue CountDownLatch FutureTask CompletionService Semaphore
6.3.6 示例:使用CompletionService实现页面渲染器 6.3.7 为任务设置时限 6.3.8 示例:旅行预定门户网站 第7章 取消与关闭 第8章 线程池的使用 第9章 图形用户界面应用程序 第三部分 活跃性、性能与测试 第10...
6.3.6 示例:使用CompletionService实现页面渲染器 6.3.7 为任务设置时限 6.3.8 示例:旅行预定门户网站 第7章 取消与关闭 第8章 线程池的使用 第9章 图形用户界面应用程序 第三部分 活跃性、性能与测试 第10...
9)已完成任务队列CompletionService 36 10)计时器CountDownLatch 37 11)周期性同步工具CyclicBarrier 38 12)异步计算的结果Future 40 13)安排线程池ScheduledExecutorService 40 五多线程面试题 41 六其他主题 41 1)...
- CompletionService - log4j+slf4j日志 - 实现的功能 - 登录注销 - 单聊 - 群聊 - 客户端提交任务,下载图片并显示 - 上线下线公告 - 在线用户记录 - 批量下载豆瓣电影的图片,并打为压缩包传输给客户端 ...
├─第一阶段 │ 源码+ppt.rar │ 高并发编程第一阶段01讲、课程大纲及主要内容介绍.wmv │ 高并发编程第一阶段02讲、简单介绍什么是线程.wmv │ 高并发编程第一阶段03讲、创建并启动线程.mp4 ...
├─第一阶段 │ 源码+ppt.rar │ 高并发编程第一阶段01讲、课程大纲及主要内容介绍.wmv │ 高并发编程第一阶段02讲、简单介绍什么是线程.wmv │ 高并发编程第一阶段03讲、创建并启动线程.mp4 ...