新聞中心
Java多線程中的定時器(java.util.Timer)有定時執(zhí)行任務(wù)的功能,通過設(shè)定定時器的間隔時間,會自動在此間隔后執(zhí)行預(yù)先安排好的任務(wù)(java.util.TimerTask)。
timer.schedule(TimerTask,delay,interval time)
第一個參數(shù)是需要執(zhí)行的任務(wù)。此類的類型為java.util.TimerTask。第二個參數(shù)是執(zhí)行任務(wù)前等待時間,第三個參數(shù)是間隔時間(單位為毫秒)
讓客戶滿意是我們工作的目標(biāo),不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶,將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴,公司提供的服務(wù)項目有:申請域名、虛擬主機、營銷軟件、網(wǎng)站建設(shè)、眉山網(wǎng)站維護、網(wǎng)站推廣。
package timer;
import java.util.concurrent.PriorityBlockingQueue;
public class MyTimer {
PriorityBlockingQueue
Worker worker;
private static class Worker extends Thread {
PriorityBlockingQueue queue;
Worker(PriorityBlockingQueue queue) {
this.queue = queue;
}
@Override
public void run() {
while (true) {
try {
MyTimerTask task = queue.take();
long current = System.currentTimeMillis();
if (task.delay <= current) {
task.target.run();
} else {
queue.put(task);
Thread.sleep(task.delay - current);
}
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
MyTimer() {
worker = new Worker(queue);
worker.start();
}
void execute(Runnable target, long delay) {
queue.put(new MyTimerTask(target, delay));
}
public static void main(String[] args) {
MyTimer timer = new MyTimer();
timer.execute(new Runnable() {
@Override
public void run() {
System.out.println("該起床了");
}
}, 2000);
System.out.println("另一個人");
}
}
package timer;
public class MyTimerTask implements Comparable
Runnable target;
long delay;
MyTimerTask(Runnable target, long delay) {
this.target = target;
this.delay = System.currentTimeMillis() + delay;//延時后的時刻
}
@Override
public int compareTo(MyTimerTask o) {
if (delay == o.delay) {
//延時后的時刻
return 0;
} else if (delay < o.delay) {
return -1;
} else {
return 1;
}
}
}
文章標(biāo)題:Java實現(xiàn)多線程定時執(zhí)行任務(wù)代碼
文章轉(zhuǎn)載:http://fisionsoft.com.cn/article/ighjdg.html