阅读数:103 评论数:0

FutureTask实现了RunnableFuture接口，同时RunnableFuture又继承了Future、Runnable接口。

通过传入Runnable或者Callable的任务给FutureTask，直接调用其run方法或者放入线程池执行，之后可以通过FutureTask的get方法异步获取执行结果，另外，FutureTask还可以确保即使调用了多次run方法，它都只会执行一次Runnable或者Callable任务，或者通过cancel取消FutureTask的执行等。

public class FutureTest1 {

	public static void main(String[] args) {
		Task task = new Task();// 新建异步任务
		FutureTask<Integer> future = new FutureTask<Integer>(task) {
			// 异步任务执行完成，回调
			@Override
			protected void done() {
				try {
					System.out.println("future.done():" + get());
				} catch (InterruptedException e) {
					e.printStackTrace();
				} catch (ExecutionException e) {
					e.printStackTrace();
				}
			}
		};
		// 创建线程池（使用了预定义的配置）
		ExecutorService executor = Executors.newCachedThreadPool();
		executor.execute(future);

		try {
			Thread.sleep(1000);
		} catch (InterruptedException e1) {
			e1.printStackTrace();
		}
		// 可以取消异步任务
		// future.cancel(true);

		try {
			// 阻塞，等待异步任务执行完毕-获取异步任务的返回值
			System.out.println("future.get():" + future.get());
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}
	}

	// 异步任务
	static class Task implements Callable<Integer> {
		// 返回异步任务的执行结果
		@Override
		public Integer call() throws Exception {
			int i = 0;
			for (; i < 10; i++) {
				try {
					System.out.println(Thread.currentThread().getName() + "_"
							+ i);
					Thread.sleep(500);
				} catch (InterruptedException e) {
					e.printStackTrace();
				}
			}
			return i;
		}
	}

}