Java并发案例04---Future和 FutureTask

4.Future和 FutureTask

4.1 Future是Callable的返回结果。

它有三个功能

• 1.判断任务是否完成
• 2.能够中断任务
• 3.能够获取任务返回结果

4.2 FutureTask

FutureTask 实现了RunnableFuture接口，RunnableFuture这个接口又继承自Runnable和Future

因此FutureTask 既可以作为Runnable被线程执行(通过包装Callable对象),又可以作为Future得到Callable返回值。

public FutureTask(Callable<V> callable) {
    if (callable == null)
            throw new NullPointerException();
        this.callable = callable;
        this.state = NEW;       // ensure visibility of callable
    }

public FutureTask(Runnable runnable, V result) {
    this.callable = Executors.callable(runnable, result);
    this.state = NEW;       // ensure visibility of callable
}

两个构造方法,FutureTask接口是Future的唯一实现类。

实现了Callable的对象

class Task implements Callable<String> {
	
	
	@Override
	public String call() throws Exception {
		TimeUnit.SECONDS.sleep(5);
		System.out.println("我睡了5s");
		return "success";
	}
}

方法1：通过FutureTask包装task，然后使用Thread的方式执行

public static void main(String[] args) throws InterruptedException, ExecutionException {
		
		Task task = new Task();
		/**
		 * 用FutureTask包装Task对象，然后给thread去执行
		 */
		FutureTask<String> ft = new FutureTask<String>(task);
		
		new Thread(ft).start();
		
		System.out.println("主线程获取运行结果为:"+ft.get());
}

方法2：通过FutureTask包装task，然后使用线程池的方式执行

public static void main(String[] args) throws InterruptedException, ExecutionException {
		
	ExecutorService executorService = Executors.newCachedThreadPool();

	Task task = new Task();
	/**
	 * 用FutureTask包装Task对象，然后给线程池去执行
	 */
	FutureTask<String> ft = new FutureTask<String>(task);
	
	
	Future<String> result = executorService.submit(task);
	
	executorService.shutdown();
	
	System.out.println("主线程获取运行结果为:"+result.get());
		
}

方法3：直接使用线程池提交Callable对象

public static void main(String[] args) throws InterruptedException, ExecutionException {
		
	ExecutorService executorService = Executors.newCachedThreadPool();

	Task task = new Task();
	
	Future<String> result = executorService.submit(task);
	
	executorService.shutdown();
	
	System.out.println("主线程获取运行结果为:"+result.get());
		
}

总结

Future是一个接口， FutureTask类是Future 的一个实现类，并实现了Runnable，因此FutureTask可以传递到线程对象Thread中新建一个线程执行。所以可通过Excutor(线程池) 来执行,也可传递给Thread对象执行。