Callable与Future

ExecutorService threadPool = Executors.newFixedThreadPool(2);
Future<Integer> future = threadPool.submit(new Callable<Integer>() {
public Integer call() throws Exception {
return 1;
}
});
Future<Integer> futureNew = threadPool.submit(new Callable<Integer>() {
public Integer call() throws Exception {
return 2;
}
});
try {
System.out.println(future.get());
System.out.println(futureNew.get());
} catch (Exception e) {
e.printStackTrace();
}

public static void main(String[] args) throws ParseException {
try{
ThreadPoolExecutor threadPool = ImportDataThreadPoolUtil.getInstance();
FutureTask<Boolean> futureTask = new FutureTask(new Callable() {
public Boolean call() throws Exception {
//do something
return null;
}
});
threadPool.execute(futureTask);
Boolean flag = false;
Long userTime = 0L;
while (userTime < 10) {
flag = futureTask.get();
if (futureTask.isDone() ) {
break;
}
Thread.sleep(500);//线程锁定
userTime++;
}
}catch (Exception e){
System.out.println("error ~~");
}
}