ITEEDU

Java Gossip: Callable 与 Future

Callable与Future类别可以协助您完成 Future 模式 。

Callable是个接口，与Runnable类似，有个必须实作的方法，可以启动为另一个执行绪来执行，不过Callable工作完成后，可以传回结果对象，Callable接口的定义如下：

public interface Callable { 
	V call() throws Exception; 
} 

例如您可以使用Callable来完成某个费时的工作，工作结束后传回结果对象，例如求质数：

PrimeCallable.java

package onlyfun.caterpillar;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
public class PrimeCallable implements Callable {
	private int max;
	public PrimeCallable(int max) {
		this.max = max;
	}
	public int[] call() throws Exception {
		int[] prime = new int[max+1];
		List list = new ArrayList();
		for(int i = 2; i <= max; i++)
		prime[i] = 1;
		for(int i = 2; i*i <= max; i++) { // 这边可以改进
			if(prime[i] == 1) {
				for(int j = 2*i; j <= max; j++) {
					if(j % i == 0)
					prime[j] = 0;
				}
			}
		}
		for(int i = 2; i < max; i++) {
			if(prime[i] == 1) {
				list.add(i);
			}
		}
		int[] p = new int[list.size()];
		for(int i = 0; i < p.length; i++) {
			p[i] = list.get(i).intValue();
		}
		return p;
	}
}

假设现在求质数的需求是在启动PrimeCallable后的几秒之后，则我们可以搭配Future来取得Callable执行的结果，在未来的时间点取得结果，例如：

FutureDemo.java

package onlyfun.caterpillar;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.FutureTask;
public class FutureDemo {
	public static void main(String[] args) {
		Callable primeCallable = new PrimeCallable(1000);
		FutureTask primeTask = new FutureTask(primeCallable);
		Thread t = new Thread(primeTask);
		t.start();
		try {
			// 假设现在做其它事情
			Thread.sleep(5000);
			// 回来看看质数找好了吗
			if(primeTask.isDone()) {
				int[] primes = primeTask.get();
				for(int prime : primes) {
					System.out.print(prime + " ");
				}
				System.out.println();
			}
		} catch (InterruptedException e) {
			e.printStackTrace();
		} catch (ExecutionException e) {
			e.printStackTrace();
		}
	}
}