Thread类和Runnable接口和Java内存管理模型使得多线程编程简单直接。但是Thread类和Runnable接口都不允许声明检查型异常,也不能定义返回值。
Callable接口和Future接口的引入以及它们对线程池的支持优雅的解决了这两个问题。
Callable接口类似于Runnable接口,Callable接口被线程执行后,可以返回值,这个返回值可以被Future拿到,也就是说,Future可以拿到异步执行任务的返回值。Future取得的结果类型和Callable返回的结果类型必须一致,这是通过泛型来实现的。
1、Callable要采用ExecutorService的submit方法提交,返回的future对象可以取消任务
代码:
public static void main(String[] args) { ExecutorService threadPool = Executors.newSingleThreadExecutor(); // submit是提交以便返回结果 Future<String> future = threadPool.submit(new Callable<String>() { public String call() throws Exception { Thread.sleep(2000); return "hello"; }; }); System.out.println("等待结果"); try { System.out.println("拿到结果:" + future.get()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ExecutionException e) { // TODO Auto-generated catch block e.printStackTrace(); } }
结果:
Executor使我们无需显示的去管理线程的生命周期。
2、执行多个带返回值的任务,并取得多个返回值
//方式2 CompletionService用于提交一组Callable任务,其take方法返回已完成的一个Callable任务对应的Future对象 //好比我同时种了几块地的麦子,然后就等待收割。收割时,则是那块先成熟了,则先去收割哪块麦子。 ExecutorService threadPool2 = Executors.newFixedThreadPool(10); CompletionService<Integer> compeletionService = new ExecutorCompletionService<Integer>( threadPool2); for (int i = 0; i <= 10; i++) { final int seq = i; compeletionService.submit(new Callable<Integer>() { @Override public Integer call() throws Exception { Thread.sleep(new Random().nextInt(5000)); return seq; } }); } for (int i = 0; i < 10; i++) { try { //产生线程,返回结果再把结果拿回来 System.out.println(compeletionService.take().get()); } catch (InterruptedException e) { // TODO Auto-generated catch block e.printStackTrace(); } catch (ExecutionException e) { // TODO Auto-generated catch block e.printStackTrace(); } }
结果:
3、了解Callable接口以及Future接口
Callable接口与Runnable接口的区别
1)Callable定义的方法时call,而Runnable定义的方法是run
2)Callable的call方法可以由返回值,而Runnable的run方法不能有返回值
3)Callable的call方法可以抛异常,而Runnable的run方法不能抛异常
Future表示一步计算的结果,它提供了检查计算是否完成的方法,以等待计算的完成,并检索计算的结果。Future的calcel方法可以取消任务的执行,它有一布尔参数,参数为true表示立即终端任务的执行,参数为false表示允许正在运行的任务运行完成。Future的get方法等待计算完成,获取计算结果。
时间: 2024-10-22 21:34:51