博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
Java并发编程高级篇(六):在执行器中延时执行任务
阅读量:5994 次
发布时间:2019-06-20

本文共 2102 字,大约阅读时间需要 7 分钟。

hot3.png

执行器框架提供了ThreadPoolExecutor类来执行Runnable和Callable任务。当任务被发送给执行器的时候,执行器会根据俄配合尽可能快地执行任务。但是如果我们不想让任务马上执行,而是想让任务过一段时间后再执行,或者周期性地执行,该怎么办呢。为了达到这个目的,执行器框架为我们提供了ScheduledThreadPoolExecutor类。

下面我们看一下如何使用这个类来实现延迟执行任务。

首先我们创建一个任务类,实现Callable接口,泛型类型为String。这个任务在控制台打印执行时间,并返回Hello World。

import java.util.Date;import java.util.concurrent.Callable;/** * 新建Task类并实现Callable
接口 * * 打印当前任务名+执行时间 * * Created by hadoop on 2016/11/3. */public class Task implements Callable
{ private String name; public Task(String name) { this.name = name; } @Override public String call() throws Exception { System.out.printf("%s: Starting at : %s\n", name, new Date()); return "Hello World!"; }}

接下来我们实现主类main方法。首先通过执行器工厂Executors类的newScheduledThreadPool()方法来创建一个定时执行器,这个方法接收一个参数作为线程池最大线程数。接下来创建5个线程,并调用schedule方法来执行线程,每个线程都给定一个延迟执行时间,每个线程的延迟时间都间隔一秒。

import java.util.concurrent.Executors;import java.util.concurrent.ScheduledThreadPoolExecutor;import java.util.concurrent.TimeUnit;/** * 在执行器中延迟执行任务 * * 我们把任务发送给执行器框架,任务会马上执行,如果你想让任务在过一段时间后才执行,那么你需要使用ScheduledThreadPoolExecutor。 * * 创建五个任务,使用ScheduledThreadPoolExecutor的schedule(Callable
callable,long delay,TimeUnit unit)方法来执行。 * 这个方法接受三个参数(实现Callable接口的任务,延迟执行时间,时间单位) * * 如果需要执行任务执行的时间点,那么你需要计算当前时间与任务执行时间之间的时间间隔。 * * Created by hadoop on 2016/11/3. */public class Main { public static void main(String[] args) throws InterruptedException { ScheduledThreadPoolExecutor executor = (ScheduledThreadPoolExecutor)Executors.newScheduledThreadPool(1); for (int i = 1; i <= 5; i++) { Task task = new Task(String.valueOf(i)); executor.schedule(task, i, TimeUnit.SECONDS); } executor.shutdown(); executor.awaitTermination(1, TimeUnit.DAYS); }}

执行结果,可以看到每个任务都比上一个任务延迟一秒执行。

1: Starting at : Sat Feb 25 21:38:49 CST 20172: Starting at : Sat Feb 25 21:38:50 CST 20173: Starting at : Sat Feb 25 21:38:51 CST 20174: Starting at : Sat Feb 25 21:38:52 CST 20175: Starting at : Sat Feb 25 21:38:53 CST 2017

转载于:https://my.oschina.net/nenusoul/blog/849159

你可能感兴趣的文章
本地远程访问服务器jupyter
查看>>
anaconda下jieba和wordcloud安装
查看>>
57.6174问题
查看>>
大专生自学Java到找到工作的经历
查看>>
GlusterFS常用命令
查看>>
lucene索引结构改进-支持单机十亿级别的索引的检索
查看>>
Ubuntu 14.04 AM335x TI-RTOS 编译
查看>>
归并排序
查看>>
java_JDBC(2)
查看>>
js属性操作之 “.”点运算符合“[ ]”中括号运算符的关系
查看>>
K8S集群搭建
查看>>
python selenium模块使用出错解决,Message: 'geckodriver' executable needs to be in PATH
查看>>
JSP(参数个数可变的函数)
查看>>
tomcat 修改编码(Java之负基础实战)
查看>>
python自学2018/03/22-文件操作
查看>>
UEFI+GPT引导实践篇(二):UEFI引导安装64位Win7/Win8
查看>>
调起windows下的“我的电脑”等特殊文件夹
查看>>
Unity UI组件实现所用到的接口类(如果UGUI的组件达不到需求的效果可以依此自己实现)...
查看>>
详解Spring3基于Annotation的依赖注入实现
查看>>
布尔值(Boolean values)
查看>>