網(wǎng)站查詢服務器,深圳網(wǎng)站設計公司費用是,泰興網(wǎng)站設計,網(wǎng)站建設公司專業(yè)公司哪家好這個 Demo 主要做兩件事#xff1a;建一個 ScheduledThreadPoolExecutor(2)#xff0c;看看 2 線程時任務分配情況對比 scheduleAtFixedRate 和 scheduleWithFixedDelay 的行為每個任務打印#xff1a;當前時間、線程名、第幾次執(zhí)行你可以新建一個 ScheduledDemo.java 直接運…這個 Demo 主要做兩件事建一個ScheduledThreadPoolExecutor(2)看看 2 線程時任務分配情況對比scheduleAtFixedRate和scheduleWithFixedDelay的行為每個任務打印當前時間、線程名、第幾次執(zhí)行你可以新建一個ScheduledDemo.java直接運行import java.time.LocalTime; import java.time.format.DateTimeFormatter; import java.util.concurrent.*; public class ScheduledDemo { private static final DateTimeFormatter F DateTimeFormatter.ofPattern(HH:mm:ss.SSS); private static String now() { return LocalTime.now().format(F); } public static void main(String[] args) throws InterruptedException { // 2 個線程的定時線程池 ScheduledExecutorService ses Executors.newScheduledThreadPool(2, new ThreadFactory() { private final ThreadFactory delegate Executors.defaultThreadFactory(); private int idx 1; Override public Thread newThread(Runnable r) { Thread t delegate.newThread(r); t.setName(sched-worker- (idx)); return t; } }); System.out.println([ now() ] main start); // FixedRate 任務理論上每 5 秒一次task 執(zhí)行 3 秒 Runnable fixedRateTask new Runnable() { private int count 0; Override public void run() { String thread Thread.currentThread().getName(); int curr count; System.out.println([ now() ] [FixedRate] 第 curr 次執(zhí)行線程 thread); try { // 模擬執(zhí)行 3 秒 TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { System.out.println([ now() ] [FixedRate] 被中斷線程 thread); Thread.currentThread().interrupt(); } } }; // FixedDelay 任務每次執(zhí)行完后延遲 5 秒再執(zhí)行task 執(zhí)行 3 秒 Runnable fixedDelayTask new Runnable() { private int count 0; Override public void run() { String thread Thread.currentThread().getName(); int curr count; System.out.println([ now() ] [FixedDelay] 第 curr 次執(zhí)行線程 thread); try { // 模擬執(zhí)行 3 秒 TimeUnit.SECONDS.sleep(3); } catch (InterruptedException e) { System.out.println([ now() ] [FixedDelay] 被中斷線程 thread); Thread.currentThread().interrupt(); } } }; // 0 延時之后每 5 秒觸發(fā)一次FixedRate ses.scheduleAtFixedRate(fixedRateTask, 0, 5, TimeUnit.SECONDS); // 0 延時執(zhí)行完成之后等待 5 秒FixedDelay ses.scheduleWithFixedDelay(fixedDelayTask, 0, 5, TimeUnit.SECONDS); // 讓 Demo 跑 40 秒觀察日志 TimeUnit.SECONDS.sleep(40); System.out.println([ now() ] main shutdown); ses.shutdown(); } }你跑一下會看到類似大概意思FixedRate如果 3s 5s就基本是每 5 秒一輪FixedDelay永遠是 “執(zhí)行 3 秒 延遲 5 秒 8 秒一輪”線程名會在sched-worker-1/sched-worker-2之間分配你能清楚看到同一個周期任務不會重疊執(zhí)行但是輪次之間可能換線程。如果你想再觀察“執(zhí)行時間 間隔”的情況把sleep(3)改成sleep(7)日志會更有意思FixedRate會出現(xiàn)“補課式”緊接執(zhí)行FixedDelay節(jié)奏變慢但依舊“執(zhí)行完 延時”。