ScheduledExecutorService的主要作用就是可以將定時(shí)任務(wù)與線程池功能結(jié)合使用。今天我們來學(xué)習(xí)一下ScheduledExecutorService的用法。我們都太渺小了，那么容易便湮沒于各自的殊途。

?

ScheduledExecutorService的簡(jiǎn)單使用

一、使用scheduleAtFixedRate()方法實(shí)現(xiàn)周期性執(zhí)行

public class ScheduledExecutorServiceTest {public static void main(String[] args) {ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();executorService.scheduleAtFixedRate(new Runnable() {@Overridepublic void run() {System.out.println("run "+ System.currentTimeMillis());}}, 0, 100, TimeUnit.MILLISECONDS);} }

?運(yùn)行的結(jié)果如下：立刻執(zhí)行，而且每隔100毫秒執(zhí)行一次。

run 1501051231331 run 1501051231427 run 1501051231527 run 1501051231628 run 1501051231726 run 1501051231827 run 1501051231926 run 1501051232026 run 1501051232127 .......

?

二、ScheduledExecutorService使用Callable延遲運(yùn)行

package com.linux.thread;import java.util.ArrayList; import java.util.List; import java.util.concurrent.*;public class CallableRun {public static void main(String[] args) {try {List<Callable> callableList = new ArrayList<>();callableList.add(new MyCallableA());callableList.add(new MyCallableB());ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();ScheduledFuture futureA = executorService.schedule(callableList.get(0), 4L, TimeUnit.SECONDS);ScheduledFuture futureB = executorService.schedule(callableList.get(1), 4L, TimeUnit.SECONDS);System.out.println(" X = " + System.currentTimeMillis());System.out.println("返回值A(chǔ)：" + futureA.get());System.out.println("返回值B：" + futureB.get());System.out.println(" Y = " + System.currentTimeMillis());executorService.shutdown();} catch (InterruptedException e) {e.printStackTrace();} catch (ExecutionException e) {e.printStackTrace();}}static class MyCallableA implements Callable<String> {@Overridepublic String call() throws Exception{try {System.out.println("callA begin " + Thread.currentThread().getName() + ", " + System.currentTimeMillis());TimeUnit.SECONDS.sleep(3); // 休眠3秒System.out.println("callA end " + Thread.currentThread().getName() + ", " + System.currentTimeMillis());} catch (Exception e) {e.printStackTrace();}return "returnA";}}static class MyCallableB implements Callable<String> {@Overridepublic String call() throws Exception{System.out.println("callB begin " + Thread.currentThread().getName() + ", " + System.currentTimeMillis());System.out.println("callB end " + Thread.currentThread().getName() + ", " + System.currentTimeMillis());return "returnB";}} }

運(yùn)行的結(jié)果如下：

?

三、使用scheduleWithFixedDelay()方法實(shí)現(xiàn)周期性執(zhí)行

package com.linux.thread;import java.util.concurrent.Executors; import java.util.concurrent.ScheduledExecutorService; import java.util.concurrent.TimeUnit;public class RunMain {public static void main(String[] args) {ScheduledExecutorService executorService = Executors.newSingleThreadScheduledExecutor();System.out.println(" x = " + System.currentTimeMillis());executorService.scheduleWithFixedDelay(new MyRunable(), 1, 2, TimeUnit.SECONDS);System.out.println(" y = " + System.currentTimeMillis());}static class MyRunable implements Runnable {@Overridepublic void run() {try {System.out.println(" begin = " + System.currentTimeMillis() + ", name: " + Thread.currentThread().getName());TimeUnit.SECONDS.sleep(4);System.out.println(" end = " + System.currentTimeMillis() + ", name: " + Thread.currentThread().getName());} catch (InterruptedException e) {e.printStackTrace();}}} }

運(yùn)行的結(jié)果如下：

?

友情鏈接

• 可以參考博客：http://blog.csdn.net/cages/article/details/7300992
• 關(guān)于spring中的定時(shí)器：http://blog.csdn.net/tsyj810883979/article/details/8481621

轉(zhuǎn)自：https://www.cnblogs.com/huhx/p/baseusejavaScheduledExecutorService.html

轉(zhuǎn)載于:https://www.cnblogs.com/zhi-xing/p/10399905.html

總結(jié)

以上是生活随笔為你收集整理的java高级----Thread之ScheduledExecutorService的使用的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。