当前位置： 移动技术网 > IT编程>开发语言>Java > java自定义任务类定时执行任务示例 callable和future接口使用方法

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

2019年07月22日  | 移动技术网IT编程  | 我要评论

callable 和 future接口

callable是类似于runnable的接口，实现callable接口的类和实现runnable的类都是可被其它线程执行的任务。

callable和runnable有几点不同：
（1）callable规定的方法是call()，而runnable规定的方法是run().
（2）callable的任务执行后可返回值，而runnable的任务是不能返回值的。
（3）call()方法可抛出异常，而run()方法是不能抛出异常的。
（4）运行callable任务可拿到一个future对象， future表示异步计算的结果。

它提供了检查计算是否完成的方法，以等待计算的完成，并检索计算的结果。
通过future对象可了解任务执行情况，可取消任务的执行，还可获取任务执行的结果。


复制代码 代码如下:

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();
 }
}

您可能感兴趣的文章:

如对本文有疑问， 点击进行留言回复！！

相关文章:

验证码：
最近更新的文章
大家感兴趣的文章
移动技术网