java自定义任务类定时执行任务示例callable和future接口使用方法

importjava.util.concurrent.Callable;
importjava.util.concurrent.ExecutorService;
importjava.util.concurrent.Executors;
importjava.util.concurrent.Future;

publicclassCallableAndFuture{

 /**
 *自定义一个任务类，实现Callable接口
 */
 publicstaticclassMyCallableClassimplementsCallable{
  //标志位
  privateintflag=0;

  publicMyCallableClass(intflag){
   this.flag=flag;
  }

  publicStringcall()throwsException{
   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(InterruptedExceptione){
     System.out.println("Interrupted");
    }
    return"false";
   }else{
    //falg不为0或者1，则抛出异常
    thrownewException("Badflagvalue!");
   }
  }
 }

 publicstaticvoidmain(String[]args){
  //定义3个Callable类型的任务
  MyCallableClasstask1=newMyCallableClass(0);
  MyCallableClasstask2=newMyCallableClass(1);
  MyCallableClasstask3=newMyCallableClass(2);

  //创建一个执行任务的服务
  ExecutorServicees=Executors.newFixedThreadPool(3);
  try{
   //提交并执行任务，任务启动时返回了一个Future对象，
   //如果想得到任务执行的结果或者是异常可对这个Future对象进行操作
   Futurefuture1=es.submit(task1);
   //获得第一个任务的结果，如果调用get方法，当前线程会等待任务执行完毕后才往下执行
   System.out.println("task1:"+future1.get());

   Futurefuture2=es.submit(task2);
   //等待5秒后，再停止第二个任务。因为第二个任务进行的是无限循环
   Thread.sleep(5000);
   System.out.println("task2cancel:"+future2.cancel(true));

   //获取第三个任务的输出，因为执行第三个任务会引起异常
   //所以下面的语句将引起异常的抛出
   Futurefuture3=es.submit(task3);
   System.out.println("task3:"+future3.get());
  }catch(Exceptione){
   System.out.println(e.toString());
  }
  //停止任务执行服务
  es.shutdownNow();
 }
}