Java實現(xiàn)多線程定時執(zhí)行任務(wù)代碼

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ù)項目有：申請域名、虛擬主機(jī)、營銷軟件、網(wǎng)站建設(shè)、眉山網(wǎng)站維護(hù)、網(wǎng)站推廣。

package timer;

import java.util.concurrent.PriorityBlockingQueue;

public class MyTimer {
PriorityBlockingQueue<MyTimerTask> queue = new PriorityBlockingQueue<>();
Worker worker;

private static class Worker extends Thread {
    PriorityBlockingQueue<MyTimerTask> queue;

    Worker(PriorityBlockingQueue<MyTimerTask> 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<MyTimerTask> {
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;
    }
}

}

當(dāng)前文章：Java實現(xiàn)多線程定時執(zhí)行任務(wù)代碼
文章起源：http://muchs.cn/article16/ighjdg.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供網(wǎng)站改版、軟件開發(fā)、電子商務(wù)、微信公眾號、定制開發(fā)、手機(jī)網(wǎng)站建設(shè)

廣告

聲明：本網(wǎng)站發(fā)布的內(nèi)容（圖片、視頻和文字）以用戶投稿、用戶轉(zhuǎn)載內(nèi)容為主，如果涉及侵權(quán)請盡快告知，我們將會在第一時間刪除。文章觀點不代表本網(wǎng)站立場，如需處理請聯(lián)系客服。電話：028-86922220；郵箱：631063699@qq.com。內(nèi)容未經(jīng)允許不得轉(zhuǎn)載，或轉(zhuǎn)載時需注明來源： 創(chuàng)新互聯(lián)