java线程：Future和Callable
前两天在公司的项目看到Future和Callable的使用，有点不理解。
这个Future和cabllable到底是什么东西？我都对这个东西感到特别奇怪就我现在的理解，
因为本人在并发这方面没有多少实践经验，所以只好就着一些资料和自己的理解给它下个定义，
Future就是保存我们任务的完成信息，简单的说就是一个产生结果，一个拿到结果。
Callable有点类似于Runable接口，只是Runable接口不能返回结果，而Callable的功能更加强大点，当
线程执行的时候，它可以产生一个返回值。而这个返回值就可以被Future拿到，所以Future可以拿到异步执行任务的
返回值。
先看一个简单的例子：
public static void main(String[] args) {
Callable<Integer> callable=new Callable<Integer>(){
@Override
public Integer call() throws Exception{
return new Random().nextInt(100);
}
};
FutureTask<Integer> future=new FutureTask<Integer>(callable);
new Thread(future).start();
try {
System.out.println(future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
FutureTask实现了RunnableFuture，而RunnableFuture两个接口，Runnable和Future,说明FutureTask可以
作为Runable被线程执行，又可以作为Future得到Callable的返回值，所以我们可以想到就是在
当有一组算法执行相对较慢，又想拿到返回值的时候，那么就可以使用这个组合，用另一个线程去计算返回值，
而当前线程在使用这个返回值之前可以做其它的操作，等到需要这个返回值时，再通过Future得到。
下一种使用Future得到Callable的返回值的方法，可以使用ExecutorService的sumbit的方法
执行Callable，并用Future去到返回值
public static void main(String[] args) {
ExecutorService executorService= Executors.newSingleThreadExecutor();
Future<Integer> future=executorService.submit(new Callable<Integer>() {
@Override
public Integer call() throws Exception {
return new Random().nextInt(500);
}
});
try {
System.out.println(future.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
}
ExecutorService继承自Executor，它的目的是为我们管理Thread对象，从而简化并发编程，
Executor使我们无需显示的去管理线程的生命周期。
我们还可可以使用Future的集合，去的Callable返回的多个值
public static void main(String[] args) {
ExecutorService threadPool= Executors.newCachedThreadPool();
List<Future<Integer>> futureList=new ArrayList<>();
for (int i = 0; i <5 ; i++) {
Future<Integer> future= threadPool.submit(new Callable<Integer>() {
@Override
public Integer call() throws Exception {
return new Random().nextInt(50);
}
});
futureList.add(future);
}
futureList.stream().forEach(s->{
try {
System.out.println(s.get());
} catch (InterruptedException e) {
e.printStackTrace();
} catch (ExecutionException e) {
e.printStackTrace();
}
});
}
