Java:定时启动线程
参考:http://zhangjunhd.blog.51cto.com/113473/74646
http://www.cnblogs.com/jobs/archive/2007/04/27/730255.html
这里提供两种在指定时间后启动线程的方法。一是通过java.util.concurrent.DelayQueue实现;二是通过java.util.concurrent.ScheduledThreadPoolExecutor实现。
1. java.util.concurrent.DelayQueue
类DelayQueue是一个无界阻塞队列,只有在延迟期满时才能从中提取元素。它接受实现Delayed接口的实例作为元素。
<<interface>>Delayed.java
import java.util.*;
public interface Delayed extends Comparable<Delayed> {
long getDelay(TimeUnit unit);
}
getDelay()返回与此对象相关的剩余延迟时间,以给定的时间单位表示。此接口的实现必须定义一个 compareTo 方法,该方法提供与此接口的 getDelay 方法一致的排序。
DelayQueue队列的头部是延迟期满后保存时间最长的 Delayed 元素。当一个元素的getDelay(TimeUnit.NANOSECONDS) 方法返回一个小于等于 0 的值时,将发生到期。
2.设计带有时间延迟特性的队列
类DelayedTasker维护一个DelayQueue<DelayedTask> queue,其中DelayedTask实现了Delayed接口,并由一个内部类定义。外部类和内部类都实现Runnable接口,对于外部类来说,它的run方法是按定义的时间先后取出队列中的任务,而这些任务即内部类的实例,内部类的run方法定义每个线程具体逻辑。
这个设计的实质是定义了一个具有时间特性的线程任务列表,而且该列表可以是任意长度的。每次添加任务时指定启动时间即可。
DelayedTasker.java
import static java.util.concurrent.TimeUnit.SECONDS;
import static java.util.concurrent.TimeUnit.NANOSECONDS;
import java.util.Collection;
import java.util.Collections;
import java.util.Random;
import java.util.concurrent.DelayQueue;
import java.util.concurrent.Delayed;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class DelayedTasker implements Runnable {
DelayQueue<DelayedTask> queue = new DelayQueue<DelayedTask>();
public void addTask(DelayedTask e) {
queue.put(e);
}
public void removeTask() {
queue.poll();
}
public Collection<DelayedTask> getAllTasks() {
return Collections.unmodifiableCollection(queue);
}
public int getTaskQuantity() {
return queue.size();
}
public void run() {
while (!queue.isEmpty())
try {
queue.take().run();
} catch (InterruptedException e) {
System.out.println("Interrupted");
}
System.out.println("Finished DelayedTask");
}
public static class DelayedTask implements Delayed, Runnable {
private static int counter = 0;
private final int id = counter++;
private final int delta;
private final long trigger;
public DelayedTask(int delayInSeconds) {
delta = delayInSeconds;
trigger = System.nanoTime() + NANOSECONDS.convert(delta, SECONDS);
}
public long getDelay(TimeUnit unit) {
return unit.convert(trigger - System.nanoTime(), NANOSECONDS);
}
public int compareTo(Delayed arg) {
DelayedTask that = (DelayedTask) arg;
if (trigger < that.trigger)
return -1;
if (trigger > that.trigger)
return 1;
return 0;
}
public void run() {
//run all that you want to do
System.out.println(this);
}
public String toString() {
return "[" + delta + "s]" + "Task" + id;
}
}
public static void main(String[] args) {
Random rand = new Random();
ExecutorService exec = Executors.newCachedThreadPool();
DelayedTasker tasker = new DelayedTasker();
for (int i = 0; i < 10; i++)
tasker.addTask(new DelayedTask(rand.nextInt(5)));
exec.execute(tasker);
exec.shutdown();
}
}
结果:
[0s]Task 1
[0s]Task 2
[0s]Task 3
[1s]Task 6
[2s]Task 5
[3s]Task 8
[4s]Task 0
[4s]Task 4
[4s]Task 7
[4s]Task 9
Finished DelayedTask
3. java.util.concurrent.ScheduledThreadPoolExecutor
该类可以另行安排在给定的延迟后运行任务(线程),或者定期(重复)执行任务。在构造子中需要知道线程池的大小。最主要的方法是:
[1] schedule
创建并执行在给定延迟后启用的一次性操作。
指定者:
-接口 ScheduledExecutorService 中的 schedule;
参数:
-command - 要执行的任务 ;
-delay - 从现在开始延迟执行的时间 ;
-unit - 延迟参数的时间单位 ;
返回:
-表示挂起任务完成的 ScheduledFuture,并且其 get() 方法在完成后将返回 null。
[2] scheduleAtFixedRate
Runnable command,long initialDelay,long period,TimeUnit unit)
创建并执行一个在给定初始延迟后首次启用的定期操作,后续操作具有给定的周期;也就是将在 initialDelay 后开始执行,然后在 initialDelay+period 后执行,接着在 initialDelay + 2 * period 后执行,依此类推。如果任务的任何一个执行遇到异常,则后续执行都会被取消。否则,只能通过执行程序的取消或终止方法来终止该任务。如果此任务的任何一个执行要花费比其周期更长的时间,则将推迟后续执行,但不会同时执行。
指定者:
-接口 ScheduledExecutorService 中的 scheduleAtFixedRate;
参数:
-command - 要执行的任务 ;
-initialDelay - 首次执行的延迟时间 ;
-period - 连续执行之间的周期 ;
-unit - initialDelay 和 period 参数的时间单位 ;
返回:
-表示挂起任务完成的 ScheduledFuture,并且其 get() 方法在取消后将抛出异常。
4.设计带有时间延迟特性的线程执行者
类ScheduleTasked关联一个ScheduledThreadPoolExcutor,可以指定线程池的大小。通过schedule方法知道线程及延迟的时间,通过shutdown方法关闭线程池。对于具体任务(线程)的逻辑具有一定的灵活性(相比前一中设计,前一种设计必须事先定义线程的逻辑,但可以通过继承或装饰修改线程具体逻辑设计)。
ScheduleTasker.java
import java.util.concurrent.ScheduledThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ScheduleTasker {
private int corePoolSize = 10;
ScheduledThreadPoolExecutor scheduler;
public ScheduleTasker() {
scheduler = new ScheduledThreadPoolExecutor(corePoolSize);
}
public ScheduleTasker(int quantity) {
corePoolSize = quantity;
scheduler = new ScheduledThreadPoolExecutor(corePoolSize);
}
public void schedule(Runnable event, long delay) {
scheduler.schedule(event, delay, TimeUnit.SECONDS);
}
public void shutdown() {
scheduler.shutdown();
}
public static void main(String[] args) {
ScheduleTasker tasker = new ScheduleTasker();
tasker.schedule(new Runnable() {
public void run() {
System.out.println("[1s]Task 1");
}
}, 1);
tasker.schedule(new Runnable() {
public void run() {
System.out.println("[2s]Task 2");
}
}, 2);
tasker.schedule(new Runnable() {
public void run() {
System.out.println("[4s]Task 3");
}
}, 4);
tasker.schedule(new Runnable() {
public void run() {
System.out.println("[10s]Task 4");
}
}, 10);
tasker.shutdown();
}
}
结果:
[1s]Task 1
[2s]Task 2
[4s]Task 3
[10s]Task 4
本文出自 “子 孑” 博客,请务必保留此出处http://zhangjunhd.blog.51cto.com/113473/74646
Java:定时启动线程相关推荐
- 不允许使用java方式启动_细品 Java 中启动线程的正确和错误方式
细品 Java 中启动线程的正确和错误方式 前文回顾详细分析 Java 中实现多线程的方法有几种?(从本质上出发) start 方法和 run 方法的比较 代码演示:/** * * start() 和 ...
- 线程组多次调用_详细分析 Java 中启动线程的正确和错误方式
start 方法和 run 方法的比较 代码演示: /** * * start() 和 run() 的比较 * * * @author 踏雪彡寻梅 * @version 1.0 * @da ...
- java 中启动线程的正确方式
启动线程的正确方式是运行Thread类中的start()方法,使用run()方法只不过是运行了一个普通方法而已. 线程对象在初始化之后,由当前线程(主线程)执行的start()方法,然后去告诉jvm虚 ...
- 线程启动语句的顺序是否决定线程的执行次序。_详细分析 Java 中启动线程的正确和错误方式
start 方法和 run 方法的比较 代码演示: /** * * start() 和 run() 的比较 * * * @author 踏雪彡寻梅 * @version 1.0 * @date 202 ...
- java 怎么启动线程_线程如何正确的启动
在前面我们已经了解到如何创建线程,要么就重写Thread类的run方法,要么就实现Runnable接口的run方法,然后调用Thread类的start方法去启动它,可能我们发现了,最终执行的其实还是r ...
- java匿名启动线程_使用匿名内部类:来创建线程的两种方式
[Java]基础31:创建线程的两种方式 谢谢你的观看. 今天是我自学Java的第31天. 你的观看便是对我最大的鼓励. 话不多说,开始今天的学习: 线程的创建有两种方式,昨天学习过其中的一种: 创建 ...
- java匿名启动线程_用java实现匿名内部类启动线程
public class ThreadNoNameTest { public static void main(String[] args) { // 匿名内部类的语法格式:父类/接口类型 引用变量名 ...
- java 定时启动window程序、自动滑动鼠标
马上要放10.1假期了,结果公司通知5-8号加班,需要远程办公,本人项目模块已经编写完成,预计加班任务很少,为了更好的远程办(划)公(水),特地写了这个脚本. 脚本介绍: 程序启动后,会一直执行,每天 ...
- Java定时线程实现:scheduleAtFixedRate 和 scheduleWithFixedDelay 的差别
Java实现定时任务,一般都是用一个线程,设置个时间,让他定时执行,注意力一般都是集中在这个线程的实现,很少考虑到具体定时执行线程的这个过程.scheduleAtFixedRate 和 schedul ...
最新文章
- 无需SherlockActionbar的SlidingMenu使用详解(一)——通过SlidingMenu设置容器并解决滑动卡顿的问题
- 英国《金融时报》:全力加码早期投资,红杉中国在下一盘怎样的棋?
- Call to undefined function Workerman\posix_getpid
- C语言的结构使用和结构对齐
- UImageview加边框 加阴影
- 网易云信携手小天才电话手表 打造视频通话体验的行业标杆
- 你不是一个人在战斗!有人将吴恩达的视频教程做成了文字版
- python模拟qq空间登录_模拟登录QQ空间
- eclipse +python 修改 各种颜色 +字体
- 2DASL:目前最好的开源人脸3D重建与密集对齐算法
- Lampp Xampp配置SSL及自动http重定向https
- 区块链和数据科学:如果同时应用这两种技术,将会实现什么?
- 6个工具让网页抓取变得轻而易举
- 人工智能-动物识别专家系统Python实现
- Matlab资料汇总暨MATLAB中文论坛帖子整理(二)
- Issue during builing Android app with ant under Win7
- 显卡更新显示计算机无法识别,电脑无法识别独立显卡
- php判断合数,素数(质数)、合数计算器
- Web应用服务器——Tomcat的介绍、下载安装、环境配置与使用
- 为什么不能睁一只眼闭一只眼_“睁一只眼,闭一只眼”才是人生的最高境界