package com.yao; import java.util.concurrent.Callable; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; import java.util.concurrent.Future; public class CallableAndFuture {  /**   * 自定义一个任务类，实现Callable接口   */  public static class MyCallableClass implements Callable {   // 标志位   private int flag = 0;   public MyCallableClass(int flag) {    this.flag = flag;   }   public String call() throws Exception {    if (this.flag == 0) {     // 如果flag的值为0，则立即返回     return "flag = 0";    }    if (this.flag == 1) {     // 如果flag的值为1，做一个无限循环     try {      while (true) {       System.out.println("looping......");       Thread.sleep(2000);      }     } catch (InterruptedException e) {      System.out.println("Interrupted");     }     return "false";    } else {     // falg不为0或者1，则抛出异常     throw new Exception("Bad flag value!");    }   }  }  public static void main(String[] args) {   // 定义3个Callable类型的任务   MyCallableClass task1 = new MyCallableClass(0);   MyCallableClass task2 = new MyCallableClass(1);   MyCallableClass task3 = new MyCallableClass(2);   // 创建一个执行任务的服务   ExecutorService es = Executors.newFixedThreadPool(3);   try {    // 提交并执行任务，任务启动时返回了一个Future对象，    // 如果想得到任务执行的结果或者是异常可对这个Future对象进行操作    Future future1 = es.submit(task1);    // 获得第一个任务的结果，如果调用get方法，当前线程会等待任务执行完毕后才往下执行    System.out.println("task1: " + future1.get());    Future future2 = es.submit(task2);    // 等待5秒后，再停止第二个任务。因为第二个任务进行的是无限循环    Thread.sleep(5000);    System.out.println("task2 cancel: " + future2.cancel(true));    // 获取第三个任务的输出，因为执行第三个任务会引起异常    // 所以下面的语句将引起异常的抛出    Future future3 = es.submit(task3);    System.out.println("task3: " + future3.get());   } catch (Exception e) {    System.out.println(e.toString());   }   // 停止任务执行服务   es.shutdownNow();  } }