FutureTask的用法

import java.util.concurrent.Callable;

import java.util.concurrent.ExecutionException;

import java.util.concurrent.FutureTask;

/**

* 使用FutureTask提前加载稍后所需要的数据

* @author jianlong

* @version 2016年1月15日 上午10:17:26

*/

public class FutureTaskDemo {

private final FutureTask<ProductInfo> future = new FutureTask<ProductInfo>(new Callable<ProductInfo>(){
@Override
public ProductInfo call() throws Exception{
Thread.sleep(5000);
return loadProductInfo();
}
});
private final Thread thread  = new Thread(future);

public void start(){thread.start();}

protected ProductInfo loadProductInfo() {
return new ProductInfo();
}

public ProductInfo get() throws InterruptedException, ExecutionException{
return future.get();
}

public static void main(String[] args) throws Exception{
FutureTaskDemo futureTaskDemo = new FutureTaskDemo();
System.out.println("启动线程,准备数据,这个时间需要5s");
futureTaskDemo.start();
System.out.println("模拟接下来要做很多操作/5s");
Thread.sleep(5000);
futureTaskDemo.get();

}
class ProductInfo{
public ProductInfo() {
System.out.println("ProductInfo is initing!!!!!!!!");
}
}

}