ScheduledExecutorService，是基于線程池設(shè)計的定時任務(wù)類，每個調(diào)度任務(wù)都會分配到線程池中的一個線程去執(zhí)行，也就是說任務(wù)是并發(fā)執(zhí)行互不影響。

需要注意：只有當(dāng)調(diào)度任務(wù)來的時候，ScheduledExecutorService才會真正啟動一個線程，其余時間ScheduledExecutorService都是出于輪詢?nèi)蝿?wù)的狀態(tài)。

1、線程任務(wù)

class MyScheduledExecutor implements Runnable {
  
  private String jobName;
  
  MyScheduledExecutor() {
    
  }
  
  MyScheduledExecutor(String jobName) {
    this.jobName = jobName;
  }

  @Override
  public void run() {
    
    System.out.println(jobName + " is running");
  }
}

2、定時任務(wù)

public static void main(String[] args) {
    ScheduledExecutorService service = Executors.newScheduledThreadPool(10);
    
    long initialDelay = 1;
    long period = 1;
    // 從現(xiàn)在開始1秒鐘之后，每隔1秒鐘執(zhí)行一次job1
    service.scheduleAtFixedRate(new MyScheduledExecutor("job1"), initialDelay, period, TimeUnit.SECONDS);
    
    // 從現(xiàn)在開始2秒鐘之后，每隔2秒鐘執(zhí)行一次job2
    service.scheduleWithFixedDelay(new MyScheduledExecutor("job2"), initialDelay, period, TimeUnit.SECONDS);
  }

ScheduledExecutorService 中兩種最常用的調(diào)度方法 ScheduleAtFixedRate 和 ScheduleWithFixedDelay。ScheduleAtFixedRate 每次執(zhí)行時間為上一次任務(wù)開始起向后推一個時間間隔，即每次執(zhí)行時間為 :initialDelay, initialDelay+period, initialDelay+2*period, …；ScheduleWithFixedDelay 每次執(zhí)行時間為上一次任務(wù)結(jié)束起向后推一個時間間隔，即每次執(zhí)行時間為：initialDelay, initialDelay+executeTime+delay, initialDelay+2*executeTime+2*delay。由此可見，ScheduleAtFixedRate 是基于固定時間間隔進(jìn)行任務(wù)調(diào)度，ScheduleWithFixedDelay 取決于每次任務(wù)執(zhí)行的時間長短，是基于不固定時間間隔進(jìn)行任務(wù)調(diào)度。

本文題目：【教程】如何使用ScheduledExecutorService？
網(wǎng)頁路徑：http://chinadenli.net/news31/105381.html

成都網(wǎng)站建設(shè)公司_創(chuàng)新互聯(lián)，為您提供虛擬主機(jī)、網(wǎng)站設(shè)計公司、品牌網(wǎng)站制作、網(wǎng)站制作、微信小程序、網(wǎng)站導(dǎo)航

廣告

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