快速业务通道

Java中定时启动线程 - 编程入门网

作者 佚名技术 来源 NET编程 浏览 发布时间 2012-06-18
   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();    } }

Java中定时启动线程(2)

时间:2011-03-23 zhangjunhd

结果:

[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

public ScheduledFuture<?> schedule(Runnable command, long delay,TimeUnit unit)

创建并执行在给定延迟后启用的一次性操作。

指定者:

-接口 ScheduledExecutorService 中的 schedule;

参数:

-command - 要执行的任务 ;

-delay - 从现在开始延迟执行的时间 ;

-unit - 延迟参数的时间单位 ;

返回:

-表示挂起任务完成的 ScheduledFuture,并且其 get() 方法在完成后将返回 null。

[2] scheduleAtFixedRate

public ScheduledFuture<?> 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() 方法在取消后将抛出异常。

Java中定时启动线程(3)

时间:2011-03-23 zhangjunhd

4.设计带有时间延迟特性的线程执行者

类ScheduleTasked关联一个ScheduledThreadPoolExcutor,可以指定线程池的大小。通过schedule方法知道线程及延迟的时间,通过shutdown方法关闭线程池。对于具体任务(线程)的逻辑具有一定的灵活性(相比前一中设计,前一种设计必须事先定义线程的逻辑,但可以通过继承或装饰修改线程具体逻辑设计)。

ScheduleTasker.java

package com.zj.timedtask; import java.util.concurrent.ScheduledThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ScheduleTasker {    private int corePoolSize = 10;    ScheduledThreadPoolExecu

凌众科技专业提供服务器租用、服务器托管、企业邮局、虚拟主机等服务,公司网站:http://www.lingzhong.cn 为了给广大客户了解更多的技术信息,本技术文章收集来源于网络,凌众科技尊重文章作者的版权,如果有涉及你的版权有必要删除你的文章,请和我们联系。以上信息与文章正文是不可分割的一部分,如果您要转载本文章,请保留以上信息,谢谢!

分享到: 更多

Copyright ©1999-2011 厦门凌众科技有限公司 厦门优通互联科技开发有限公司 All rights reserved

地址(ADD):厦门软件园二期望海路63号701E(东南融通旁) 邮编(ZIP):361008

电话:0592-5908028 传真:0592-5908039 咨询信箱:web@lingzhong.cn 咨询OICQ:173723134

《中华人民共和国增值电信业务经营许可证》闽B2-20100024  ICP备案:闽ICP备05037997号