中文字幕 日本 在线 高清,久久精品国产99精品国,超碰人人香蕉,一区二区三区无码高清视频

Java定時(shí)任務(wù)之ScheduledThreadPoolExecutor

ScheduledThreadPoolExecutor是JDK5提供的可執(zhí)行定時(shí)任務(wù)的一個(gè)工具類,可以在多線程環(huán)境下延遲執(zhí)行任務(wù)或者定期執(zhí)行任務(wù);和Timer類似,它也提供了三種定時(shí)模式:

  1. 延遲執(zhí)行任務(wù)
  2. 固定延遲的定期執(zhí)行(fixed delay)
  3. 按照固定的周期執(zhí)行(fixed rate)

延遲執(zhí)行任務(wù)

任務(wù)將按照給定的時(shí)間延遲delay后開(kāi)始執(zhí)行;對(duì)應(yīng)的方法如下:

schedule(Runnable command, long delay, TimeUnit unit)  schedule(Callable<V> callable, long delay, TimeUnit unit)  

下面我們通過(guò)一個(gè)例子檢驗(yàn)下結(jié)果是否正確:

ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); PrintUtil.print("start schedule a task."); executor.schedule(new Runnable() { @Override public void run() { PrintUtil.print("task is running."); }}, 5, TimeUnit.SECONDS);

我們計(jì)劃了一個(gè)5秒鐘后執(zhí)行的任務(wù),通過(guò)打印結(jié)果可以看到確實(shí)按照給定時(shí)間執(zhí)行了:

15:44:07--start schedule a task.15:44:12--task is running.

固定延遲的定期執(zhí)行

任務(wù)第一次按照給定的初始延遲initialDelay執(zhí)行,后續(xù)每一次執(zhí)行的時(shí)間為上一次任務(wù)的結(jié)束時(shí)間加上給定的period后執(zhí)行;對(duì)應(yīng)的方法如下:

scheduleAtFixedRate(Runnable command, long initialDelay, long period, TimeUnit unit)

同樣我們通過(guò)一個(gè)例子檢驗(yàn)下結(jié)果是否正確:

ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor(); PrintUtil.print("start schedule a task."); executor.scheduleWithFixedDelay(new Runnable() { @Override public void run() { PrintUtil.print("task is running."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } }}, 0, 5, TimeUnit.SECONDS);

我們計(jì)劃了一個(gè)定期(每5秒鐘)延遲執(zhí)行的任務(wù),第一次任務(wù)立即執(zhí)行,每次任務(wù)執(zhí)行時(shí)長(zhǎng)2秒鐘,通過(guò)打印的日志我們可以看到每次任務(wù)開(kāi)始執(zhí)行的時(shí)間為:上次任務(wù)結(jié)束時(shí)間 5秒鐘:

15:55:16--start schedule a task.15:55:16--task is running.15:55:18--task is finished.15:55:23--task is running.15:55:25--task is finished.15:55:30--task is running.15:55:32--task is finished.

按照固定的周期執(zhí)行

任務(wù)第一次按照給定的初始延遲initialDelay執(zhí)行,后續(xù)每一次執(zhí)行的時(shí)間為固定的時(shí)間間隔period,如果線程池中工作線程不夠則任務(wù)順延執(zhí)行;對(duì)應(yīng)的方法如下:

scheduleWithFixedDelay(Runnable command, long initialDelay, long period, TimeUnit unit)

同樣我們通過(guò)一個(gè)例子檢驗(yàn)下結(jié)果是否正確:

ScheduledExecutorService executor = Executors.newScheduledThreadPool(10); PrintUtil.print("start schedule a task."); executor.scheduleAtFixedRate(new Runnable() { @Override public void run() { PrintUtil.print("task is running."); try { Thread.sleep(2000); } catch (InterruptedException e) { e.printStackTrace(); } PrintUtil.print("task is finished."); }}, 0, 5, TimeUnit.SECONDS);

我們創(chuàng)建了一個(gè)核心線程池為10的ScheduledThreadPoolExecutor,并計(jì)劃了一個(gè)定期(每5秒鐘)執(zhí)行一次的任務(wù),過(guò)打印的日志我們可以看到每次任務(wù)開(kāi)始執(zhí)行的時(shí)間為:上次任務(wù)開(kāi)始時(shí)間 5秒鐘:

16:02:43--start schedule a task.16:02:43--task is running.16:02:45--task is finished.16:02:48--task is running.16:02:50--task is finished.

上面的例子都是計(jì)劃了一個(gè)任務(wù),如果是有多個(gè)定時(shí)任務(wù)同時(shí)執(zhí)行會(huì)怎么樣呢?

如果線程足夠并且CPU資源足夠,那就會(huì)同時(shí)執(zhí)行,如果線程或者CPU資源不夠那只能排隊(duì)執(zhí)行了。有興趣的話可以克隆文末的測(cè)試代碼,里面提供了一些測(cè)試的例子。

底層原理

ScheduledThreadPoolExecutor是如何保證我們計(jì)劃的任務(wù)都是按照正確的時(shí)間點(diǎn)執(zhí)行的呢?

其內(nèi)部實(shí)現(xiàn)了一個(gè)阻塞隊(duì)列DelayedWorkQueue,所有的任務(wù)都會(huì)放到這個(gè)隊(duì)列里。這個(gè)阻塞隊(duì)列內(nèi)部通過(guò)一個(gè)數(shù)組來(lái)保存這些任務(wù),并且基于最小堆排序,按照每個(gè)任務(wù)的下次執(zhí)行時(shí)間進(jìn)行排序,這樣就保證了執(zhí)行線程拿到的這個(gè)隊(duì)列中的第一個(gè)元素就是最接近當(dāng)前時(shí)間執(zhí)行的任務(wù)了。

相關(guān)的源碼如下:

// 保存定時(shí)任務(wù)的隊(duì)列private RunnableScheduledFuture<?>[] queue = new RunnableScheduledFuture<?>[INITIAL_CAPACITY];// 最小堆排序相關(guān)的方法private void siftUp(int k, RunnableScheduledFuture<?> key)private void siftDown(int k, RunnableScheduledFuture<?> key)


那時(shí)間上是如何保證的呢?

DelayedWorkQueue重寫(xiě)了take和poll方法,利用了AQS的ConditionObject機(jī)制使當(dāng)前線程休眠,等時(shí)間到了再喚醒線程去拿第一個(gè)任務(wù)。

關(guān)于AQS和ConditonObject的介紹,可以參考下文末的鏈接。

public RunnableScheduledFuture<?> take() throws InterruptedException { final Reentrantlock lock = this.lock; lock.lockInterruptibly(); try { for (;;) { RunnableScheduledFuture<?> first = queue[0]; if (first == null) available.await(); else { long delay = first.getDelay(NANOSECONDS); if (delay <= 0) return finishPoll(first); first = null; // don't retain ref while waiting if (leader != null) available.await(); else { Thread thisThread = Thread.currentThread(); leader = thisThread; try { available.awaitNanos(delay); } finally { if (leader == thisThread) leader = null; } } } } } finally { if (leader == null && queue[0] != null) available.signal(); lock.unlock(); }}

優(yōu)點(diǎn)

作為對(duì)JDK1.3推出的Timer的替代,ScheduledThreadPoolExecutor有如下優(yōu)點(diǎn):

  1. 它支持多個(gè)定時(shí)任務(wù)同時(shí)執(zhí)行,而Timer是單線程執(zhí)行的
  2. 它通過(guò)System.nanoTime()保證了任務(wù)執(zhí)行時(shí)間不受操作系統(tǒng)時(shí)間變化的影響
  3. 一個(gè)定時(shí)任務(wù)拋出異常,其他定時(shí)任務(wù)不受影響,而Timer卻不支持這一點(diǎn)

Demo代碼

src/main/java/net/weichitech/util/ScheduledThreadPoolExecutorDemo.java · 小西學(xué)編程/java-learning – Gitee.com

參考文章

Java定時(shí)任務(wù)之Timer原理解析

JAVA并發(fā)之ReentrantLock原理解析

版權(quán)聲明:本文內(nèi)容由互聯(lián)網(wǎng)用戶自發(fā)貢獻(xiàn),該文觀點(diǎn)僅代表作者本人。本站僅提供信息存儲(chǔ)空間服務(wù),不擁有所有權(quán),不承擔(dān)相關(guān)法律責(zé)任。如發(fā)現(xiàn)本站有涉嫌抄襲侵權(quán)/違法違規(guī)的內(nèi)容, 請(qǐng)發(fā)送郵件至 舉報(bào),一經(jīng)查實(shí),本站將立刻刪除。

(0)
上一篇 2022年12月11日 上午10:36
下一篇 2022年12月11日 上午10:50

相關(guān)推薦

  • 鳩江區(qū):積極開(kāi)展“強(qiáng)基工程”,推動(dòng)黨員教育管理走深走實(shí)(黨組織強(qiáng)基工程)

    近年來(lái),鳩江區(qū)積極開(kāi)展基層黨組織“強(qiáng)基工程”,以“向心、聚力、忠誠(chéng)、奉獻(xiàn)”為主線,著力夯實(shí)基層基礎(chǔ),強(qiáng)化黨員教育管理和為民服務(wù),把廣大黨員群眾和各類組織緊緊凝聚在黨的周圍。 立足向…

    科研百科 2023年7月9日
    248
  • 會(huì)計(jì)總賬怎么做?(會(huì)計(jì)總賬怎么做)

    會(huì)計(jì)總賬怎么做?總賬是指總分類賬簿(GeneralLedger)也稱總分類賬。是根據(jù)總分類科目開(kāi)設(shè)賬戶,用來(lái)登記全部經(jīng)濟(jì)業(yè)務(wù),進(jìn)行總分類核算,提供總括核算資料的分類賬簿。總分類賬所…

    科研百科 2022年12月17日
    327
  • 項(xiàng)目管理有哪些軟件

    項(xiàng)目管理有哪些軟件 隨著信息技術(shù)的不斷發(fā)展,項(xiàng)目管理已經(jīng)成為了許多企業(yè)和組織中不可或缺的一部分。現(xiàn)在,有許多不同的軟件可以用來(lái)進(jìn)行項(xiàng)目管理。本文將介紹一些常見(jiàn)的項(xiàng)目管理軟件,包括傳…

    科研百科 2025年1月13日
    5
  • 學(xué)科經(jīng)費(fèi)管理辦法

    學(xué)科經(jīng)費(fèi)管理辦法 隨著現(xiàn)代科學(xué)技術(shù)的發(fā)展,學(xué)科間的合作和交流變得越來(lái)越重要。為了更好地管理和支持學(xué)科的發(fā)展,制定一個(gè)有效的學(xué)科經(jīng)費(fèi)管理辦法是至關(guān)重要的。本文將介紹一個(gè)學(xué)科經(jīng)費(fèi)管理辦…

    科研百科 2024年9月12日
    4
  • 機(jī)場(chǎng)項(xiàng)目管理系統(tǒng)

    機(jī)場(chǎng)項(xiàng)目管理系統(tǒng):提升機(jī)場(chǎng)運(yùn)營(yíng)效率的關(guān)鍵技術(shù) 機(jī)場(chǎng)項(xiàng)目管理系統(tǒng)是一種用于管理機(jī)場(chǎng)項(xiàng)目的工具,可以幫助機(jī)場(chǎng)運(yùn)營(yíng)團(tuán)隊(duì)更好地協(xié)調(diào)和管理項(xiàng)目,提高機(jī)場(chǎng)運(yùn)營(yíng)效率和質(zhì)量。隨著現(xiàn)代機(jī)場(chǎng)的日益繁忙…

    科研百科 2024年12月11日
    3
  • 科研項(xiàng)目論文總結(jié)

    科研項(xiàng)目論文總結(jié) 隨著科技的不斷進(jìn)步,科研項(xiàng)目也在不斷地進(jìn)行中。在這些項(xiàng)目中,我們不斷探索新的技術(shù)和方法,為人類社會(huì)的發(fā)展做出貢獻(xiàn)。本文將總結(jié)一些常見(jiàn)的科研項(xiàng)目論文,以幫助讀者更好…

    科研百科 2025年3月5日
    1
  • 應(yīng)急響應(yīng)科研項(xiàng)目

    應(yīng)急響應(yīng)科研項(xiàng)目: 探索未來(lái)科技的新篇章 隨著科技的不斷發(fā)展,應(yīng)急響應(yīng)科研項(xiàng)目已經(jīng)成為推動(dòng)科技進(jìn)步的重要途徑之一。這些項(xiàng)目旨在應(yīng)對(duì)緊急情況,并探索新的科技領(lǐng)域。本文將介紹一個(gè)應(yīng)急響…

    科研百科 2025年2月9日
    6
  • 廣西勘察設(shè)計(jì)監(jiān)管平臺(tái)

    廣西勘察設(shè)計(jì)監(jiān)管平臺(tái) 廣西勘察設(shè)計(jì)監(jiān)管平臺(tái)是廣西自治區(qū)政府為了加強(qiáng)勘察設(shè)計(jì)行業(yè)的監(jiān)管而建立的平臺(tái),旨在保障勘察設(shè)計(jì)行業(yè)的健康發(fā)展。該平臺(tái)由自治區(qū)政府組成,由自治區(qū)經(jīng)濟(jì)和信息化委員會(huì)…

    科研百科 2024年12月1日
    412
  • 政府危大工程管理系統(tǒng)

    政府危大工程管理系統(tǒng) 政府危大工程管理系統(tǒng)是一種用于管理和監(jiān)督危大工程的計(jì)算機(jī)系統(tǒng),能夠幫助政府相關(guān)部門高效地管理和監(jiān)督工程進(jìn)度和質(zhì)量,提高工程的安全性和可靠性。本文將介紹政府危大…

    科研百科 2024年12月7日
    5
  • 項(xiàng)目管理辦法

    項(xiàng)目管理辦法 隨著項(xiàng)目經(jīng)濟(jì)的發(fā)展,項(xiàng)目管理已經(jīng)成為企業(yè)發(fā)展中不可或缺的一部分。為了更好地管理項(xiàng)目,制定一套完善的項(xiàng)目管理辦法至關(guān)重要。本文將介紹一種項(xiàng)目管理辦法,以便企業(yè)在實(shí)踐中參…

    科研百科 2024年5月27日
    39