从头认识java-17.6 Callable、Future和FutureTask
2016-01-16 22:59
423 查看
这一章节我们来讨论一下Callable、Future和FutureTask的用法与关系。
1.关系
(1)Callable是Runnable的封装的异步运算任务
(2)Future用来保存Callable异步运算的结果
(3)FutureTask封装Future的实体类
2.Future
我们在这里详细介绍一下Future,因为它比较复杂,首先看看他的源代码:
它里面包含了几个方法
get:得到结果
get(timeout,unit)计算是否超时得到结果
cancle:取消任务
isDone、isCancle:判断任务状态
3.例子:
Callable和FutureTask
我们只需要将上面main方法里面的两个if互换就可以得出不同的结果。
Callable和Future
总结:这一章节主要介绍了Callable、Future和FutureTask的用法与关系。
这一章节就到这里,谢谢。-----------------------------------目录
1.关系
(1)Callable是Runnable的封装的异步运算任务
(2)Future用来保存Callable异步运算的结果
(3)FutureTask封装Future的实体类
2.Future
我们在这里详细介绍一下Future,因为它比较复杂,首先看看他的源代码:
public interface Future<V> { boolean cancel(boolean mayInterruptIfRunning); boolean isCancelled(); boolean isDone(); V get() throws InterruptedException, ExecutionException; V get(long timeout, TimeUnit unit) throws InterruptedException, ExecutionException, TimeoutException; }
它里面包含了几个方法
get:得到结果
get(timeout,unit)计算是否超时得到结果
cancle:取消任务
isDone、isCancle:判断任务状态
3.例子:
Callable和FutureTask
package com.ray.ch17; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.FutureTask; public class Test { public static void main(String[] args) throws InterruptedException, ExecutionException { Callable<Integer> callable = new MyCall(); FutureTask<Integer> futureTask = new FutureTask<Integer>(callable); Thread thread = new Thread(futureTask); thread.start(); Thread.sleep(100); if (!futureTask.isDone()) { System.out.println(futureTask.get()); } if (!futureTask.isCancelled()) { futureTask.cancel(true); System.out.println("cancelled"); } } } class MyCall implements Callable<Integer> { @Override public Integer call() throws Exception { System.out.println("doing something..."); Thread.sleep(1000); return new Random().nextInt(50); } }
我们只需要将上面main方法里面的两个if互换就可以得出不同的结果。
Callable和Future
package com.ray.ch17; import java.util.Random; import java.util.concurrent.Callable; import java.util.concurrent.ExecutionException; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class Test { public static void main(String[] args) throws InterruptedException, ExecutionException { ExecutorService executors = Executors.newCachedThreadPool(); Callable<Integer> callable = new MyCall(); Future<Integer> future = executors.submit(callable); System.out.println(future.get()); } } class MyCall implements Callable<Integer> { @Override public Integer call() throws Exception { System.out.println("doing something..."); Thread.sleep(1000); return new Random().nextInt(50); } }
总结:这一章节主要介绍了Callable、Future和FutureTask的用法与关系。
这一章节就到这里,谢谢。-----------------------------------目录
相关文章推荐
- Java解析XML的三种方式
- 每天学习十分钟15之Java学习笔记
- java.lang.IllegalStateException: commit already called
- Spring原理简单分析
- 利用java语言将csv格式数据导入mysql数据库
- Java异常笔记整理
- java 中byte[] 数组的合并
- Java 入门 之 开发环境的安装
- JavaConfig @Import 和 @ImportResource注解的使用
- java操作xml
- 标识符、常量、进制、运算
- Eclipse关联Android系统源码的2种方法
- Vert.x 实现REST
- MyEclipse下安装插件方法(properties文件编辑器Propedit为例)
- 深入探索 Java 热部署
- 在Eclipse中配置并使用UI控件CardView
- JDK 动态代理的简单理解
- Java免费开源数据库、Java嵌入式数据库、Java内存数据库
- 堆排序JAVA代码
- JDK,JRE,JVM区别与联系