码迷,mamicode.com
首页 > 编程语言 > 详细

Java_并发线程_Futrue、FutureTask、Callable

时间:2014-10-26 15:40:38      阅读:159      评论:0      收藏:0      [点我收藏+]

标签:java   android   并发   线程   

1.Futrue

public interface Future<V> //Future 表示异步计算的结果
ExecutorService threadPool = Executors.newSingleThreadExecutor();
Future<String> future = threadPool.submit(new Callable<String>() {
	public String call() throws Exception {
		Thread.sleep(2000);
		return "hello";
	};
});
System.out.println("等待结果");
try {
	System.out.println("拿到结果:" + future.get());//阻塞
} catch (InterruptedException e) {
	e.printStackTrace();
} catch (Exception e) {
	e.printStackTrace();
}

(1).常用方法

1).boolean cancel(boolean mayInterruptIfRunning)

试图取消对此任务的执行。如果任务已完成、或已取消,或者由于某些其他原因而无法取消,则此尝试将失败。当调用 cancel 时,如果调用成功,而此任务尚未启动,则此任务将永不运行。如果任务已经启动,则 mayInterruptIfRunning 参数确定是否应该以试图停止任务的方式来中断执行此任务的线程。此方法返回后,对 isDone() 的后续调用将始终返回 true。如果此方法返回 true,则对 isCancelled() 的后续调用将始终返回 true。 

2).boolean isCancelled() 

如果在任务正常完成前将其取消,则返回 true;

3).boolean isDone()

如果任务已完成,则返回 true。 可能由于正常终止、异常或取消而完成,在所有这些情况中,此方法都将返回 true;

4).V get()throws InterruptedException,ExecutionException

如有必要,等待计算完成,然后获取其结果,阻塞等待结果;

5).V get(long timeout,TimeUnit unit) throws InterruptedException,ExecutionException,TimeoutException

如有必要,最多等待为使计算完成所给定的时间之后,获取其结果(如果结果可用)。


2.FutureTask

public class FutureTask<V> extends Object implements Future<V>, Runnable
// 初始化一个Callable对象和FutureTask对象
Callable pAccount = new PrivateAccount();
FutureTask futureTask = new FutureTask(pAccount);
// 使用futureTask创建一个线程
Thread pAccountThread = new Thread(futureTask);


3.相互关系

Future通过阻塞get方法,当在执行完成后将得到callable对象的返回值;

FutureTask类是Future的一个实现,并实现了Runnable,所以可通过 Excutor和Thread对象执行。

Java_并发线程_Futrue、FutureTask、Callable

标签:java   android   并发   线程   

原文地址:http://blog.csdn.net/zimo2013/article/details/40476839

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!