调用不同：Runnable更为基础，Thread只能传Runnable对象。Runnable实例对象交由FutureTask对象来管理或者使用ExecutorService的submit返回一个国定的结果，结果是作为参数传入的。而Callable返回的结果是程序执行后的结果。ExecutorService在Runnable传入时可接受无结果的参数，调用submit默认返回空串。
☆ 并行知识点2：FutureTask和Future的异同
根本异同在于Future是个接口，而FutureTask实现了这个接口，同时还实现了Runnable接口。而Future对象定义了cancel, isCancelled, isDone, get和有超时时间的get五个方法。其中cancel方法，可以传入一个叫：“是否可以中断”的参数。FutureTask除了Future之外，就是run方法了。run方法是将Runnable或者是Callable的实例具体执行的过程。
☆ 并行知识点3：ExecutorService的execute和submit的异同
功能相同：都是添加线程到线程池中
功能不同：submit返回future，而execute没有返回值。因为future对象可以取消，也可以判断是否取消，是否完成。也可以通过future返回值来判断。
☆ 并行知识点4：ExecutorService的shutdown和shutdownNow的区别
当线程池调用shutdown方法时，线程池立即变成shutdown状态，不再往线程池里添加新任务，否则会抛出RejectedExecutionException，但是线程池会在池中所有任务都处理完毕才退出。
当线程池调用shutdownNow方法时，线程池立即变成stop状态，并试图停止所有正在执行的线程，不再处理并返回线程池中等待的任务。因为停止线程是通过Thread的中断方法来实现，所以不能保证会立即停止。
☆ 并行知识点5：java中断机制
上面的future的cancel方法参数为true和线程池的shutdownNow方法都用到了Thread.interrupt()方法。它只是设置标志位。需要线程自己去对标志位检测和响应。它只停掉线程中有sleep,wait,join的方法。
做程序最需要考虑的事情是什么呢？当然是如何改进。Java8中引入lambda函数式编程和增强型的CompletableFuture。看看使用这个的语法：
/** * <pre> * ********************************************************************************************************* * 版权所有（C） 2010 BSNS * 保留所有权利。 * .==. .==. * //'^\\ //^'\\ * // ^^\(\__/)/^ ^^\\ * //^ ^^ ^/6 6\ ^^^ \\ * //^ ^^ ^/( .. )\^ ^^ \\ * // ^^ ^/\|v""v|/\^^ ^ \\ * // ^^/\/ / '~~' \ \/\^ ^\\ * ---------------------------------------- * HERE BE DRAGONS WHICH CAN CREATE MIRACLE * ********************************************************************************************************* * 基本信息 * ********************************************************************************************************* * 系统：BRMAYI * 模块：BRMAYI CONCURRENT * 功能：用ExecutorService来执行FutureTask返回执行结果的异步例子 * 编码：静儿(xiexiaojing@le.com) * 时间: 2010.10.13 * ********************************************************************************************************* * 修改历史 * ********************************************************************************************************* * 修改者 修改内容 修改时间 * 静儿(xiexiaojing@le.com) 新建 2017.05.19 * ********************************************************************************************************* * </pre> */ public class Application { public static Map<String,String> call(String name){ Map<String,String> a = new HashMap<String,String>(); a.put(name, name); return a; } public static void main(String[] args) { try { final CompletableFuture<Map<String,String>> future1 = CompletableFuture.supplyAsync(()->call("name1")); final CompletableFuture<Map<String,String>> future2 = CompletableFuture.supplyAsync(()->call("name2")); System.out.println(future1.get(1, TimeUnit.MINUTES)); System.out.println(future2.get(1, TimeUnit.MINUTES)); } catch (Exception e) { e.printStackTrace(); } } }
因为现在已经凌晨3点多，早晨还要上班，今天分析的很浅，有空补上。仅表达一种境界，包括为了追求技术不眠不休:-)
相关文章
精彩导读
热门资讯
关注我们
