Java FutureTask完全指南：异步编程实战与示例详解

1 年 ago
清, 宇
2 minutes

之前我写过一篇关于Java Callable和Future接口的文章，我们可以使用这些接口来获得线程并发处理的优势，同时它们能够将结果返回给调用程序。FutureTask是Future接口的基础具体实现，提供了异步处理的功能。它包含了启动和取消任务的方法，以及可以返回FutureTask状态（完成或取消）的功能。我们需要一个可调用对象来创建FutureTask，然后可以使用Java线程池执行器来异步处理这些任务。让我们通过一个简单的程序示例来了解FutureTask的用法。由于FutureTask需要一个可调用对象，我们将创建一个简单的Callable实现。

package com.Olivia.threads;

import java.util.concurrent.Callable;

public class MyCallable implements Callable<String> {

	private long waitTime;
	
	public MyCallable(int timeInMillis){
		this.waitTime=timeInMillis;
	}
	@Override
	public String call() throws Exception {
		Thread.sleep(waitTime);
        //return the thread name executing this callable task
        return Thread.currentThread().getName();
	}

}

下面是FutureTask的使用示例，展示了FutureTask常用的方法。

package com.Olivia.threads;

import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.FutureTask;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.TimeoutException;

public class FutureTaskExample {

	public static void main(String[] args) {
		MyCallable callable1 = new MyCallable(1000);
		MyCallable callable2 = new MyCallable(2000);

		FutureTask<String> futureTask1 = new FutureTask<String>(callable1);
		FutureTask<String> futureTask2 = new FutureTask<String>(callable2);

		ExecutorService executor = Executors.newFixedThreadPool(2);
		executor.execute(futureTask1);
		executor.execute(futureTask2);
		
		while (true) {
			try {
				if(futureTask1.isDone() && futureTask2.isDone()){
					System.out.println("Done");
					//shut down executor service
					executor.shutdown();
					return;
				}
				
				if(!futureTask1.isDone()){
				//wait indefinitely for future task to complete
				System.out.println("FutureTask1 output="+futureTask1.get());
				}
				
				System.out.println("Waiting for FutureTask2 to complete");
				String s = futureTask2.get(200L, TimeUnit.MILLISECONDS);
				if(s !=null){
					System.out.println("FutureTask2 output="+s);
				}
			} catch (InterruptedException | ExecutionException e) {
				e.printStackTrace();
			}catch(TimeoutException e){
				//do nothing
			}
		}
		
	}

}

当我们运行上述程序时，您将会注意到在一段时间内它没有打印任何内容，因为FutureTask的get()方法会等待任务完成然后返回输出对象。还有一种重载的方法可以只等待指定的时间，我们在futureTask2中使用了它。还请注意使用isDone()方法来确保程序在所有任务执行完毕后终止。上述程序的输出将会是：

FutureTask1 output=pool-1-thread-1
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
Waiting for FutureTask2 to complete
FutureTask2 output=pool-1-thread-2
Done

因此，FutureTask具有很多优势，特别是当我们想要覆盖一些Future接口方法并且不想实现Future接口的每个方法时，它会派上用场。它为我们提供了一个便捷的方式来处理异步任务，并能更好地控制任务的执行和结果获取。

bannerAds