- 浏览: 238867 次
- 性别:
- 来自: 山西
文章分类
最新评论
-
jy00509336:
wgrmmtmr 写道let g:miniBufExplMap ...
用Gvim建立IDE编程环境 (Windows篇) -
wgrmmtmr:
let g:miniBufExplMapWindowsNavV ...
用Gvim建立IDE编程环境 (Windows篇) -
jy00509336:
avi9111 写道还是同样问题,你这个代码ctrl+c和ct ...
JTextField只允许输入数字和字母 -
avi9111:
还是同样问题,
你这个代码
ctrl+c和ctrl+v粘贴 ...
JTextField只允许输入数字和字母 -
jy00509336:
ILoveDOUZHOU 写道windows下为什么使用vim ...
用Gvim建立IDE编程环境 (Windows篇)
转载自:http://zhangjunhd.blog.51cto.com/113473/74646
这里提供两种在指定时间后启动线程的方法。一是通过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
发表评论
-
禁用JavaWeb应用中URL上包含的jsessionid
2014-03-21 13:02 1533Java Web 应用似乎总有这样的情况,有事没事总是要在 ... -
java操作保存图片到oracle数据库及获取图片到页面显示
2014-03-21 13:00 1345《--------保存图片到数 ... -
jsp页面通过java调用oracle blob字段显示图片
2014-03-21 12:58 1043转载自:http://blog.csdn.net/javad ... -
正则表达式中在多个匹配的内容中间加字符
2014-03-04 21:35 848selectedText = selectedText.rep ... -
ServletFileUpload parseRequest异常处理
2013-07-16 17:31 1660今天在linux服务器上发布程序后,上传图片处理异常,详情如 ... -
log4j时区设置
2013-03-21 17:23 32212013年3月19日更新程序后,服务器上的码表一直加载不上, ... -
JDBC连接报ORA-12505,sid无法找到
2013-02-06 11:10 3586转载自:http://www.calcprofit.com/ ... -
Javascript网页打印大全
2012-10-11 09:21 1265转载自:http://www.cnblogs.com/gaku ... -
Servlet编程之用Servlet显示图片
2012-09-04 21:38 1203转载自:http://developer.51cto.com/ ... -
tomcat JNDI 连接池
2012-08-02 10:59 957一.在tomcat_home/common/lib下放入 ... -
JTextArea->JTextPane 解决文字对齐方式的问题
2012-04-09 15:08 4136转载自:http://www.blogjava.net/cer ... -
jquery下json数组的操作用法实例
2011-08-13 10:51 3175转载自:http://blog.csdn.ne ... -
能盖住Select的Div
2011-07-15 23:16 922<html> <head> ... -
jQuery.extend 函数详解
2011-07-11 10:12 895转载自:http://www.cnblogs.com/Ra ... -
利用js获取服务器时间的两个简单方法
2011-07-08 14:57 1568有时用js来获取服务器时间。一般会用System.DateTi ... -
jQuery获取表单项目以及AJAX应用
2011-07-07 09:28 1100转载自:http://www.tsingfeng.com/?p ... -
velocity date.format
2011-06-27 19:39 4070Today's date is: $dateT ... -
Java中修改derby.log文件的路径
2011-04-29 15:26 2098项目中用到derby嵌入式数据库。可是其log文件derby. ... -
socket, nio socket 及nio socket框架MINA总结
2011-04-07 16:55 1166来源:http://blog.csdn.net/lcllc ... -
PreparedStatement 数据大小超出此类型的最大值
2011-03-04 11:17 1915转载自:http://heath-derek.iteye.co ...
相关推荐
本文档 描述怎样定时 启动一个线程任务 并加了注释 希望对你有帮助
主要介绍了详解Java编程中线程同步以及定时启动线程的方法, 讲到了wait()与notify()方法以及阻塞队列等知识,需要的朋友可以参考下
java、杀死启动进程、定时执行程序、隐藏黑窗口(dos窗口)、线程异常死亡(保活):就是java自动重启JBOSS
多线程 启动控制台 精确定时 WaitForSingleObject
自己写的一小段Java程序,让程序按条件自动重新启动,3个文件都是.java文件,程序不包含包信息,可以放到C盘直接进行编译运行,其中Test是运行主程序,watch是监视检测线程
简单的来说,启动后,会一直定时的获取代理ip,并自动检测代理ip的活跃度。运用多线程的技术,在极短的时间内获取大量的ip进行筛选。架构也比较清楚,方便大家学习参考 需要主要的是,代理ip获取成功后是放在redis...
主要是GUI界面获取用户设定,与当前时间比较,利用线程休眠实现类似定时器功能,每分钟检查一次,最终启动命令。第一次自己动手,遇到了很多麻烦,程序也只是一个思路,很原始,适合新手,希望继续学习。
java监控工具源码-可集成到项目使用 内存状态、CPU负载、磁盘IO吞吐率、磁盘健康状态、网卡IO 监控 适合用于服务健康监控、线...提供多种方式使用:客户端工具跨进程attach启动、添加Java Agent启动、server独立运行启
ThreadImRunnable.java 继承Runnable接口实现多线程 mulThread.java 创建多个线程对象的类 demoJoin.java 演示使用join()以确保主线程最后结束 clicker.java 一个计数用的线程类 demoPri.java 调用上面这个类...
windows 系统下启动与结束java的jar包的脚本(包括如何设置进程名称)
写这个小程序的初衷,是因为一个我的WAP前端哥们的公司(只做PHP的公司)有一个业务逻辑需要不停的访问一个PHP方法,来实现他们业 务逻辑所以写了一个,只要输入“空秒数和URL”地址... 启动 定时访问URL.exe 文件开始
第三种:基于注解设定多线程定时任务。 一、基于@Scheduled注解的方式 1.1 cron 1.1.1 定时任务的方法在启动类里面 1.1.2 定时任务的方法在启动类之外 1.2 fixedDelay 1.3 fixedRate 1.4 initialDelay 一点五 cron...
这个bat脚本资源可以在Windows环境下实现Java程序的守护进程和自动重启。它通过一个循环监控Java程序进程,如果检测到程序异常退出,会自动重启程序。同时具有可配置的重启次数和重启间隔时间。 这个小巧但实用的bat...
(2)确保某个服务在其所依赖的所有其他服务都已经启动之后才启动 (3)等待知道某个操作的所有参与者都就绪再继续执行 CountDownLatch:可以使一个或多个线程等待一组事件发生 FutureTask ...
3 启动主线程,根据线程个数划分每个线程的下载范围。 4启动下载子线程开始下载,子线程将下载的数据量调用统计类进行累计。 4 通过下载统计类得到下载信息,包括下载速度、下载量、剩余时间估计、完成百分比等等。 ...
全书通过60多个简单而非常有效的实例,帮助读者快速掌握Java 7多线程应用程序的开发技术。学习完本书,你可以将这些开发技术直接应用到自己的应用程序中。 《Java 7并发编程实战手册》适合具有一定Java编程基础的...
·可定时启动任务或直接启动任务 ·重复启动任务(时间间隔可在任务线程中改变,范围大于100ms,否则精度降低) 引用列表: ·import psn.razerpen.thread.AccuracyTimer; ·import psn.razerpen.thread....
4.自动定时保存 用线程 5.更改字体和大小 功能: 1.所有要求功能: a) 文件→打开、保存、退出(关闭时提醒是否保存修改) b) 编辑→剪切、复制、粘贴、全选; c) 帮助→关于(注明作者、完成时间) 2.添加功能: ...
java8 集合源码分析 ...如java线程不同,akka执行完成后是不会自动退出的,需要手动杀进程,一般我们也不需要自动退出【TODO 自动退出程序?】 #####使用Sleep方法暂停一个线程 任务:每四秒打印一个信息 ...