手机
当前位置:查字典教程网 >编程开发 >Java >java自定义任务类定时执行任务示例 callable和future接口使用方法
java自定义任务类定时执行任务示例 callable和future接口使用方法
摘要:Callable和Future接口Callable是类似于Runnable的接口,实现Callable接口的类和实现Runnable的类都是...

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

}

}

【java自定义任务类定时执行任务示例 callable和future接口使用方法】相关文章:

java多线程编程之从线程返回数据的两种方法

java定时调度器(Quartz)使用实例

java开发之内部类的用法

java向文件末尾添加内容示例分享

java自定义注解接口实现方案

Java 获取指定日期的实现方法总结

Java 自定义错误类示例代码

java 读写文件[多种方法]

java中out.print和out.write的方法

Java 最重要布局管理器GridBagLayout的使用方法

精品推荐
分类导航