黑马程序员技术交流社区

标题: Callable、Future的理解 [打印本页]
作者: xgm    时间: 2016-3-18 00:37
标题: Callable、Future的理解
  1. * 目的：了解callable、future
  2. *
  3. */
  4. public class CallableAndFutureTest {

  6.         public static void main(String[] args) {
  7.                
  8.                 //ExecutorService singlePool = Executors.newSingleThreadExecutor();
  9.                
  10.                 /**
  11.                  * Callable有返回值，而且会抛异常
  12.                  * 在线程池中用submit调用，返回一个Future
  13.                  */
  14.                 /*Future<String> future =
  15.                 singlePool.submit(new Callable<String>(){
  16.                         public String call() throws Exception {
  17.                                 Thread.sleep(2000);
  18.                                 return "hello";
  19.                         }
  20.                        
  21.                 });
  22.                
  23.                 try {
  24.                         System.out.println(future.get());  //通过get（）方法得到结果
  25.                         System.out.println(future.get(1, TimeUnit.SECONDS)); //如果多少秒还没得到结果就抛异常
  26.                 } catch (InterruptedException e) {
  27.                         e.printStackTrace();
  28.                 } catch (ExecutionException e) {
  29.                         // TODO Auto-generated catch block
  30.                         e.printStackTrace();
  31.                 } catch (TimeoutException e) {
  32.                         // TODO Auto-generated catch block
  33.                         e.printStackTrace();
  34.                 }*/
  35.                 ExecutorService pool = Executors.newFixedThreadPool(3);
  36.                 /**
  37.                  * 等到一组Future，谁先返回，谁先加入到CompletionService的队列中
  38.                  */
  39.                 CompletionService<Integer> completionService = new ExecutorCompletionService<Integer>(pool);
  40.                 for(int i=0;i<10;i++){
  41.                         final int num = i;
  42.                         completionService.submit(new Callable<Integer>() {
  43.                                 public Integer call() throws Exception {
  44.                                         System.out.println("callable now is"+num);
  45.                                         return num;
  46.                                 }
  47.                         });
  48.                 }
  49.                 for(int i=0;i<10;i++){
  50.                         try {
  51.                                 System.out.println(completionService.take().get());
  52.                         } catch (InterruptedException e) {
  53.                                 e.printStackTrace();
  54.                         } catch (ExecutionException e) {
  55.                                 e.printStackTrace();
  56.                         }
  57.                 }
  58.         }
  59. }
复制代码




欢迎光临 黑马程序员技术交流社区 (http://bbs.itheima.com/) 黑马程序员IT技术论坛 X3.2