Executors用法和@Async

@Async

查看鏈接 https://blog.csdn.net/qq_36827957/article/details/105087856

Executors接口概述

這個(gè)類定義了供Executor科侈、ExecutorService载佳、ScheduledExecutorService、ThreadFactory和Callable這些接口和類使用的工廠方法和工具方法臀栈。
Executors來(lái)自java.util.concurrent蔫慧，是Executor并發(fā)框架的主要工具類。
Executors提供了以下幾類方法：

第1類靜態(tài)方法：將Runnable轉(zhuǎn)換成Callable权薯。
第2類靜態(tài)方法：線程工廠(ThreadFactory)類姑躲。
第3類靜態(tài)方法：實(shí)例化幾類不可配置的線程池(ExecutorService和ScheduleExecutorService)。
第4類靜態(tài)方法：實(shí)例化幾類預(yù)先配置的常用線程池(ExecutorService)崭闲。
第5類靜態(tài)方法：實(shí)例化幾類預(yù)先配置的常用可調(diào)度線程池(ScheduleExecutorService)肋联。

第1類靜態(tài)方法：將Runnable轉(zhuǎn)換成Callable

通過(guò)前面的學(xué)習(xí)，我們知道Runnable并不能返回運(yùn)行結(jié)果刁俭，在某些應(yīng)用場(chǎng)景下，這種缺陷是很不不方便的韧涨。而Callable作為一種新的線程實(shí)現(xiàn)方式牍戚，能夠返回值。
Executors工具類提供了一系列方法用于將Runnable轉(zhuǎn)化成Callable虑粥，下面列出兩種：

Executors.callable(runnable)：將Runnable對(duì)象轉(zhuǎn)化成Callable<Object>對(duì)象如孝，與之結(jié)合的Future對(duì)象返回null。
Executors.callable(runnable, result)：將Runnable對(duì)象轉(zhuǎn)化成Callable<V>對(duì)象娩贷，與之結(jié)合的Future對(duì)象返回result第晰。

//定義運(yùn)行結(jié)果
final Integer[] result = {null};
//定義一個(gè)Runnable接口
Runnable runnable = new Runnable() {
    @Override
    public void run() {
        result[0] = 111111;
    }
};
//定義一個(gè)線程池
ExecutorService executorService = Executors.newCachedThreadPool();

//Executors.callable(runnable)=轉(zhuǎn)換成Callable<Object>，F(xiàn)uture返回null
Callable<Object> callable = Executors.callable(runnable);
//提交轉(zhuǎn)換成之后的Callable接口
Future future = executorService.submit(callable);
//輸出運(yùn)行結(jié)果彬祖，肯定是null
System.out.println("Executors.callable(runnable) 的future = " + future.get());

//Executors.callable(runnable, result)=轉(zhuǎn)換成Callable<V>茁瘦，future有值
Callable<Integer> callable1 = Executors.callable(runnable, result[0]);
//提交轉(zhuǎn)換成之后的Callable接口
Future future1 = executorService.submit(callable1);
//輸出運(yùn)行結(jié)果
System.out.println("Executors.callable(runnable, result) 的future = " + future1.get());

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

Executors.callable(runnable) 的future = null
Executors.callable(runnable, result) 的future = 111111

第2類靜態(tài)方法：線程工廠(ThreadFactory)類

線程工廠(ThreadFactory)類提供了線程創(chuàng)建的工廠方法。
通過(guò)線程工廠創(chuàng)建的線程位于同一線程組(ThreadGroup)储笑，并且擁有相同的優(yōu)先級(jí)(priority)甜熔。
創(chuàng)建線程工廠(ThreadFactory)類的方法如下：
Executors.defaultThreadFactory()

//創(chuàng)建線程工廠
ThreadFactory threadFactory = Executors.defaultThreadFactory();
//創(chuàng)建多個(gè)線程
for (int i = 0; i < 5; i++) {
    Thread thread = threadFactory.newThread(() -> {
        System.out.println(Thread.currentThread() + " : " + 22222);
    });
    //執(zhí)行此線程
    thread.start();
}

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

Thread[pool-2-thread-1,5,main] : 22222
Thread[pool-2-thread-2,5,main] : 22222
Thread[pool-2-thread-3,5,main] : 22222
Thread[pool-2-thread-5,5,main] : 22222
Thread[pool-2-thread-4,5,main] : 22222
//可以看到，這些線程都屬于同一線程組main突倍，且優(yōu)先級(jí)都是默認(rèn)優(yōu)先級(jí)5腔稀。

第3類靜態(tài)方法：不可配置的線程池

Executors類提供了以下兩類靜態(tài)方法，用于創(chuàng)建不可配置的線程池：

Executors.unconfigurableExecutorService(executorService)：不可配置的線程池
Executors.unconfigurableScheduledExecutorService(scheduledExecutorService)：不可配置的調(diào)度線程池
不可配置的線程池通過(guò)代理線程池對(duì)象DelegatedExecutorService來(lái)禁止方法的強(qiáng)制轉(zhuǎn)換
這種方式提供了一種安全地“凍結(jié)”配置并且不允許調(diào)整給定具體實(shí)現(xiàn)的方法羽历。
我本身并沒(méi)有對(duì)這兩個(gè)方法進(jìn)行實(shí)際編碼焊虏，只是對(duì)齊進(jìn)行基本了解，其使用思路大概如下：

//定義一個(gè)線程池服務(wù)ExecutorService
ExecutorService executorService1 = null;
//將上述的線程池服務(wù)ExecutorService 轉(zhuǎn)換成 不可配置的線程池服務(wù)
ExecutorService unconfigurableExecutorService = Executors.unconfigurableExecutorService(executorService1);
//...業(yè)務(wù)操作
//關(guān)閉服務(wù)
unconfigurableExecutorService.shutdownNow();

//定義一個(gè)可調(diào)度的線程池服務(wù)ScheduledExecutorService
ScheduledExecutorService scheduledExecutorService = null;
//將上述的線程池服務(wù)ScheduledExecutorService 轉(zhuǎn)換成 不可配置的可調(diào)度的線程池服務(wù)
ScheduledExecutorService unconfigurableScheduledExecutorService = Executors.unconfigurableScheduledExecutorService(scheduledExecutorService);
//...業(yè)務(wù)操作
//關(guān)閉服務(wù)
unconfigurableScheduledExecutorService.shutdown();

第4類靜態(tài)方法：幾類預(yù)先配置的常用線程池

newSingleThreadExecutor - 單任務(wù)線程池

使用一個(gè)單獨(dú)的工作線程和無(wú)界工作隊(duì)列的線程池秕磷。
需要注意的是：如果這個(gè)工作線程在關(guān)閉之前因?yàn)閳?zhí)行失敗而終止诵闭，則如果需要去執(zhí)行后續(xù)任務(wù)，可以新建一個(gè)線程代替它跳夭。
任務(wù)是按順序執(zhí)行的涂圆，任意時(shí)刻们镜，都不會(huì)有超過(guò)一個(gè)以上的活動(dòng)線程。
不同于等效的newFixedThreadPool(1)润歉，newSingleThreadExecutor不能通過(guò)配置而達(dá)到使用額外線程的目的模狭。
方法定義：

public static ExecutorService newSingleThreadExecutor() {
    return new FinalizableDelegatedExecutorService
        (new ThreadPoolExecutor(1, 1,
                                0L, TimeUnit.MILLISECONDS,
                                new LinkedBlockingQueue<Runnable>()));
}

從方法定義可知：

其實(shí)際是通過(guò)ThreadPoolExecutor構(gòu)造的。
使用了代理類FinalizableDelegatedExecutorService踩衩，使之無(wú)法修改配置嚼鹉。
參數(shù)說(shuō)明
corePoolSize = 1 --> 1.至多只有一個(gè)活動(dòng)線程會(huì)長(zhǎng)期存在
maximumPoolSize = 1 --> 2.因?yàn)闊o(wú)界隊(duì)列，此參數(shù)無(wú)實(shí)際意義
keepAliveTime = 0L --> 3.因?yàn)闊o(wú)界隊(duì)列驱富，此參數(shù)無(wú)實(shí)際意義
TimeUnit = TimeUnit.MILLISECONDS --> 4.因?yàn)闊o(wú)界隊(duì)列锚赤，此參數(shù)無(wú)實(shí)際意義
workQueue = new LinkedBlockingQueue<Runnable>()) --> 5.無(wú)界隊(duì)列，如果無(wú)可用核心線程,則新任務(wù)在此等待褐鸥，不會(huì)再創(chuàng)建線程
實(shí)例代碼：

System.out.println("===================== newSingleThreadExecutor - 單任務(wù)線程池");
//定義一個(gè)單任務(wù)線程池
ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();
//循環(huán)執(zhí)行5個(gè)任務(wù)
for (int i = 0; i < 5; i++) {
    //永遠(yuǎn)都是thread-1
    singleThreadExecutor.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
Thread.sleep(1000);
singleThreadExecutor.shutdown();
System.out.println("===================== newSingleThreadExecutor - 單任務(wù)線程池");

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

===================== newSingleThreadExecutor - 單任務(wù)線程池
pool-1-thread-1
pool-1-thread-1
pool-1-thread-1
pool-1-thread-1
pool-1-thread-1
===================== newSingleThreadExecutor - 單任務(wù)線程池

結(jié)果說(shuō)明：
從運(yùn)行結(jié)果可知线脚，無(wú)論向線程池中提交多少任務(wù)，其內(nèi)只是pool-1-thread-1這個(gè)線程在執(zhí)行叫榕。

newCachedThreadPool - 緩存線程池

創(chuàng)建一個(gè)線程池浑侥，這個(gè)線程池能夠按需創(chuàng)建新線程，并且能夠重用之前創(chuàng)建的可用線程晰绎。
這個(gè)線程池會(huì)典型的提高處理多個(gè)短期異步任務(wù)的程序的性能寓落。
如果有可用的線程，執(zhí)行任務(wù)會(huì)盡量重用以前構(gòu)建的線程荞下。
如果沒(méi)有可用的線程伶选，將會(huì)創(chuàng)建一個(gè)新的線程，并將此線程添加到線程池中尖昏。
空閑超過(guò)60秒的線程將會(huì)被終止仰税，并且從緩存中移除。
因此会宪，即使這個(gè)線程池空閑再長(zhǎng)時(shí)間肖卧，也不會(huì)消耗任何資源。
注意掸鹅，可以通過(guò)ThreadPoolExecutor的構(gòu)造函數(shù)塞帐，構(gòu)造具有相似屬性不同細(xì)節(jié)(例如：超時(shí)參數(shù))的緩存線程池實(shí)現(xiàn)。

方法定義：

public static ExecutorService newCachedThreadPool() {
    return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
                                  60L, TimeUnit.SECONDS,
                                  new SynchronousQueue<Runnable>());
}

從方法定義可知：

其實(shí)際是通過(guò)ThreadPoolExecutor構(gòu)造的巍沙。
參數(shù)說(shuō)明：
corePoolSize = 0 --> 1.不會(huì)存在長(zhǎng)期存在的線程
maximumPoolSize = Integer.MAX_VALUE --> 2.最多創(chuàng)建2,147,483,647個(gè)線程
keepAliveTime = 60L --> 3.線程執(zhí)行完任務(wù)后葵姥，最多空閑60秒，就會(huì)關(guān)閉
TimeUnit = TimeUnit.SECONDS --> 4.線程執(zhí)行完任務(wù)后句携，最多空閑60秒榔幸，就會(huì)關(guān)閉
workQueue = new SynchronousQueue<Runnable>() --> 5.直傳隊(duì)列，新線程到達(dá)，不會(huì)等待削咆，會(huì)直接創(chuàng)建新線程
實(shí)例代碼：

System.out.println("===================== newCachedThreadPool - 緩存線程池");
//定義一個(gè)緩沖線程池
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
//創(chuàng)建5個(gè)線程
for (int i = 0; i < 5; i++) {
    //如果無(wú)可用線程牍疏，則創(chuàng)建新線程
    cachedThreadPool.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
//等待1秒
Thread.sleep(1000);
System.out.println();
//再次重新創(chuàng)建5個(gè)線程
for (int i = 0; i < 5; i++) {
    //如果有可用線程，則重用之前創(chuàng)建的線程
    cachedThreadPool.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
//等待1秒
Thread.sleep(70000);
System.out.println();
//再次重新創(chuàng)建5個(gè)線程
for (int i = 0; i < 5; i++) {
    //如果有可用線程拨齐，則重用之前創(chuàng)建的線程
    cachedThreadPool.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
Thread.sleep(1000);
cachedThreadPool.shutdown();
System.out.println("===================== newCachedThreadPool - 緩存線程池")

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

===================== newCachedThreadPool - 緩存線程池
pool-2-thread-1
pool-2-thread-3
pool-2-thread-4
pool-2-thread-5
pool-2-thread-2

pool-2-thread-3
pool-2-thread-4
pool-2-thread-1
pool-2-thread-2
pool-2-thread-5

pool-2-thread-6
pool-2-thread-7
pool-2-thread-8
pool-2-thread-9
pool-2-thread-10
===================== newCachedThreadPool - 緩存線程池

結(jié)果說(shuō)明：

當(dāng)無(wú)可用的空閑線程時(shí)鳞陨，線程池會(huì)創(chuàng)建新的線程來(lái)執(zhí)行新的任務(wù)。
當(dāng)有可用的空閑線程時(shí)瞻惋，線程池會(huì)優(yōu)先使用之前創(chuàng)建的線程來(lái)執(zhí)行新的任務(wù)厦滤。
線程的空閑時(shí)間超過(guò)60秒，就會(huì)關(guān)閉歼狼；這時(shí)再進(jìn)來(lái)新的任務(wù)掏导，線程池又會(huì)創(chuàng)建新線程來(lái)執(zhí)行任務(wù)。

newFixedThreadPool - 固定大小線程池

創(chuàng)建一個(gè)線程池羽峰，這個(gè)線程池重復(fù)使用固定數(shù)量的線程池趟咆，以及一個(gè)共享的無(wú)界隊(duì)列。
在任何時(shí)候梅屉，最多有nThreads個(gè)活動(dòng)的線程忍啸。
如果所有的nThreads個(gè)線程都處于活動(dòng)狀態(tài)，則新提交的任務(wù)將會(huì)在隊(duì)列中等待履植。
如果一個(gè)工作線程在關(guān)閉之前因?yàn)閳?zhí)行失敗而終止，則如果需要去執(zhí)行后續(xù)任務(wù)悄晃，可以新建一個(gè)線程代替它玫霎。
線程池中的線程會(huì)一直存在，直到顯式的調(diào)用關(guān)閉方法shutdown或shutdownNow妈橄。
方法定義：

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

從方法定義可知：

其實(shí)際是通過(guò)ThreadPoolExecutor構(gòu)造的庶近。
參數(shù)說(shuō)明：
corePoolSize = nThreads --> 1.至多有nThreads個(gè)活動(dòng)線程會(huì)長(zhǎng)期存在
maximumPoolSize = nThreads --> 2.因?yàn)闊o(wú)界隊(duì)列，此參數(shù)無(wú)實(shí)際意義
keepAliveTime = 0L --> 3.因?yàn)闊o(wú)界隊(duì)列眷蚓，此參數(shù)無(wú)實(shí)際意義
TimeUnit = TimeUnit.MILLISECOND --> 4.因?yàn)闊o(wú)界隊(duì)列鼻种，此參數(shù)無(wú)實(shí)際意義
workQueue = new LinkedBlockedQueue<Runnable>()> --> 5.無(wú)界隊(duì)列，如果無(wú)可用核心線程沙热，則新任務(wù)在此等待叉钥，不會(huì)再創(chuàng)建線程
實(shí)例代碼：

System.out.println("===================== newFixedThreadPool - 固定大小線程池");
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(2);
for (int i = 0; i < 5; i++) {
    //在thread-1 和 Thread-2 之間切換
    fixedThreadPool.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
Thread.sleep(1000);
fixedThreadPool.shutdown();
System.out.println("===================== newFixedThreadPool - 固定大小線程池");

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

從運(yùn)行結(jié)果可知，無(wú)論向線程池中提交多少任務(wù)篙贸，其內(nèi)只有2個(gè)線程在執(zhí)行投队。

newWorkStealingPool - 并行工作者線程池

創(chuàng)建一個(gè)工作竊取線程池，以JVM運(yùn)行時(shí)可以CPU核數(shù)作為線程池的并行度爵川。
此線程池通過(guò)ForkJoinPool實(shí)現(xiàn)敷鸦。
方法定義：

public static ExecutorService newWorkStealingPool() {
    return new ForkJoinPool
        (Runtime.getRuntime().availableProcessors(),
         ForkJoinPool.defaultForkJoinWorkerThreadFactory,
         null, true);
}

參數(shù)說(shuō)明：

parallelism = Runtime.getRuntime().availableProcessors() --> 1.并行級(jí)別為運(yùn)行期可用的CPU處理器數(shù)量
factory = ForkJoinPool.defaultForkJoinWorkerThreadFactory --> 2.使用ForkJoinPool默認(rèn)的工作線程隊(duì)列
handler = null --> 3.不設(shè)置異常捕捉處理器
asyncMode = true --> 4.采取異步模式
實(shí)例代碼：

System.out.println("===================== newWorkStealingPool - 并行任務(wù)線程池");
//定義一個(gè)并行工作者線程池
ExecutorService workStealingPool = Executors.newWorkStealingPool();
//循環(huán)創(chuàng)建線程池
for (int i = 0; i < 20; i++) {
    //因?yàn)楸緳C(jī)CPU為4核，所以并行級(jí)別為4，即最多平行四個(gè)工作者扒披。
    workStealingPool.submit(() -> {
        System.out.println(Thread.currentThread().getName());
    });
}
//
Thread.sleep(1000);
workStealingPool.shutdown();
System.out.println("===================== newWorkStealingPool - 并行任務(wù)線程池");

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

===================== newWorkStealingPool - 并行任務(wù)線程池
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-2
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-2
ForkJoinPool-1-worker-2
ForkJoinPool-1-worker-2
ForkJoinPool-1-worker-2
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-3
ForkJoinPool-1-worker-0
ForkJoinPool-1-worker-1
ForkJoinPool-1-worker-2
===================== newWorkStealingPool - 并行任務(wù)線程池

結(jié)果說(shuō)明：

因?yàn)楸緳C(jī)CPU為4核值依，所以并行級(jí)別為4，即最多平行四個(gè)工作者碟案。

第5類靜態(tài)方法：幾類預(yù)先配置的常用可調(diào)度線程池

newScheduledThreadPool - 固定大小調(diào)度線程池

創(chuàng)建一個(gè)線程池愿险，這個(gè)線程池可以延時(shí)執(zhí)行任務(wù)，或者周期性的執(zhí)行任務(wù)蟆淀。
方法定義：

//Executors
public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize) {
    return new ScheduledThreadPoolExecutor(corePoolSize);
}
//ScheduledThreadPoolExecutor
public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}
//ThreadPoolExecutor
public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue) {
    this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
         Executors.defaultThreadFactory(), defaultHandler);
}

從方法定義可知：

其實(shí)際是通過(guò)ScheduledThreadPoolExecutor構(gòu)造的.
而ScheduledThreadPoolExecutor是通過(guò)ThreadPoolExecutor構(gòu)造的拯啦。
參數(shù)說(shuō)明：
corePoolSize = 指定大小 --> 1.至多有指定數(shù)量的活動(dòng)線程會(huì)長(zhǎng)期存在
maximumPoolSize = Integer.MAX_VALUE --> 2.因?yàn)闊o(wú)界隊(duì)里，此參數(shù)無(wú)實(shí)際意義
keepAliveTime = 0L --> 3.因?yàn)闊o(wú)界隊(duì)列熔任，此參數(shù)無(wú)實(shí)際意義
TimeUnit = TimeUnit.NANOSECONDS --> 4.因?yàn)闊o(wú)界隊(duì)列褒链，此參數(shù)無(wú)實(shí)際意義
workQueue = new DelayedWorkQueue() --> 5.一種無(wú)界隊(duì)列，如果無(wú)可用核心線程疑苔，則新任務(wù)在此等待甫匹，不會(huì)再創(chuàng)建線程
實(shí)例代碼：

System.out.println("===================== newScheduledThreadPool - 調(diào)度線程池");
//定義一個(gè)固定大小的調(diào)度線程池
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(2);
//循環(huán)提交任務(wù)
for (int i = 0; i < 5; i++) {
    //在thread-1 和 Thread-2 之間切換
    //如果不能計(jì)算好線程池的核心線程數(shù)量和任務(wù)延時(shí)之間的關(guān)系，很可能造成指定的延時(shí)任務(wù)并未按照計(jì)劃執(zhí)行
    scheduledThreadPool.schedule(() -> {
        System.out.println(Thread.currentThread().getName() + " begin... ");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + " end. ");
    }, 2, TimeUnit.SECONDS);
}
Thread.sleep(7000);
System.out.println("===================== newScheduledThreadPool - 調(diào)度線程池");
scheduledThreadPool.shutdown();

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

===================== newScheduledThreadPool - 調(diào)度線程池
pool-4-thread-2 begin... 
pool-4-thread-1 begin... 
pool-4-thread-2 end. 
pool-4-thread-2 begin... 
pool-4-thread-1 end. 
pool-4-thread-1 begin... 
pool-4-thread-2 end. 
pool-4-thread-2 begin... 
pool-4-thread-1 end. 
pool-4-thread-2 end. 
===================== newScheduledThreadPool - 調(diào)度線程池

結(jié)果說(shuō)明：

這些任務(wù)都在2秒之后才開始執(zhí)行惦费。
這些任務(wù)只會(huì)通過(guò)pool-4-thread-1和pool-4-thread-2這兩個(gè)工作線程執(zhí)行兵迅。

newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池

創(chuàng)建一個(gè)單線程線程池，這個(gè)線程池可以延時(shí)執(zhí)行任務(wù)薪贫，或者周期性的執(zhí)行任務(wù)恍箭。
但是請(qǐng)注意，如果這個(gè)工作線程在關(guān)閉之前因?yàn)閳?zhí)行失敗而終止瞧省，則如果需要去執(zhí)行后續(xù)任務(wù)扯夭，可以新建一個(gè)線程代替它。
任務(wù)是按順序執(zhí)行的鞍匾，任意時(shí)刻交洗，都不會(huì)有超過(guò)一個(gè)以上的活動(dòng)線程。
不同于等效的newScheduledThreadPool(1)橡淑，newSingleThreadScheduledExecutor不能通過(guò)配置而達(dá)到使用額外線程的目的构拳。
方法定義：

//Executors
public static ScheduledExecutorService newSingleThreadScheduledExecutor() {
    return new DelegatedScheduledExecutorService
        (new ScheduledThreadPoolExecutor(1));
}
//Executors
DelegatedScheduledExecutorService(ScheduledExecutorService executor) {
    super(executor);
    e = executor;
}
//Executors
DelegatedExecutorService(ExecutorService executor) { e = executor; }
//ScheduledThreadPoolExecutor
public ScheduledThreadPoolExecutor(int corePoolSize) {
    super(corePoolSize, Integer.MAX_VALUE, 0, NANOSECONDS,
          new DelayedWorkQueue());
}
//ThreadPoolExecutor
public ThreadPoolExecutor(int corePoolSize,
                          int maximumPoolSize,
                          long keepAliveTime,
                          TimeUnit unit,
                          BlockingQueue<Runnable> workQueue) {
    this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
         Executors.defaultThreadFactory(), defaultHandler);
}

從方法定義可知：

使用了代理類DelegatedScheduledExecutorService，使之無(wú)法修改配置梁棠。
其實(shí)際是通過(guò)ScheduledThreadPoolExecutor構(gòu)造的.
而ScheduledThreadPoolExecutor是通過(guò)ThreadPoolExecutor構(gòu)造的置森。
參數(shù)說(shuō)明：
corePoolSize = 1 --> 1.至多只有1個(gè)的活動(dòng)線程會(huì)長(zhǎng)期存在
maximumPoolSize = Integer.MAX_VALUE --> 2.因?yàn)闊o(wú)界隊(duì)里，此參數(shù)無(wú)實(shí)際意義
keepAliveTime = 0L --> 3.因?yàn)闊o(wú)界隊(duì)列掰茶，此參數(shù)無(wú)實(shí)際意義
TimeUnit = TimeUnit.NANOSECONDS --> 4.因?yàn)闊o(wú)界隊(duì)列暇藏，此參數(shù)無(wú)實(shí)際意義
workQueue = new DelayedWorkQueue() --> 5.一種無(wú)界隊(duì)列，如果無(wú)可用核心線程濒蒋，則新任務(wù)在此等待盐碱，不會(huì)再創(chuàng)建線程
實(shí)例代碼：

System.out.println("===================== newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池");
//定義一個(gè)單線程的調(diào)度線程池
ScheduledExecutorService singleThreadScheduledExecutor = Executors.newSingleThreadScheduledExecutor();
for (int i = 0; i < 5; i++) {
    singleThreadScheduledExecutor.schedule(() -> {
        System.out.println(Thread.currentThread().getName() + " begin... ");
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + " end. ");
    }, 2, TimeUnit.SECONDS);
}
Thread.sleep(10000);
System.out.println("===================== newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池");
singleThreadScheduledExecutor.shutdown();

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

===================== newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池
pool-5-thread-1 begin... 
pool-5-thread-1 end. 
pool-5-thread-1 begin... 
pool-5-thread-1 end. 
pool-5-thread-1 begin... 
pool-5-thread-1 end. 
pool-5-thread-1 begin... 
pool-5-thread-1 end. 
pool-5-thread-1 begin... 
pool-5-thread-1 end. 
===================== newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池

結(jié)果說(shuō)明：

這些任務(wù)都在2秒之后才開始執(zhí)行把兔。
這些任務(wù)只會(huì)通過(guò)pool-4-thread-1這1個(gè)工作線程執(zhí)行。

最后編輯于：2022.08.26 18:08:29

?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者

人面猴
序言：七十年代末瓮顽，一起剝皮案震驚了整個(gè)濱河市县好，隨后出現(xiàn)的幾起案子，更是在濱河造成了極大的恐慌暖混，老刑警劉巖缕贡，帶你破解...
沈念sama閱讀 211,561評(píng)論 6贊 492
死咒
序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現(xiàn)場(chǎng)離奇詭異拣播，居然都是意外死亡晾咪，警方通過(guò)查閱死者的電腦和手機(jī)，發(fā)現(xiàn)死者居然都...
沈念sama閱讀 90,218評(píng)論 3贊 385
救了他兩次的神仙讓他今天三更去死
文/潘曉璐我一進(jìn)店門贮配，熙熙樓的掌柜王于貴愁眉苦臉地迎上來(lái)谍倦，“玉大人，你說(shuō)我怎么就攤上這事泪勒≈缰” “怎么了？”我有些...
開封第一講書人閱讀 157,162評(píng)論 0贊 348
道士緝兇錄：失蹤的賣姜人
文/不壞的土叔我叫張陵圆存，是天一觀的道長(zhǎng)叼旋。經(jīng)常有香客問(wèn)我，道長(zhǎng)沦辙，這世上最難降的妖魔是什么夫植？我笑而不...
開封第一講書人閱讀 56,470評(píng)論 1贊 283
?港島之戀（遺憾婚禮）
正文為了忘掉前任，我火速辦了婚禮油讯，結(jié)果婚禮上偷崩，老公的妹妹穿的比我還像新娘。我一直安慰自己撞羽，他們只是感情好，可當(dāng)我...
茶點(diǎn)故事閱讀 65,550評(píng)論 6贊 385
惡毒庶女頂嫁案：這布局不是一般人想出來(lái)的
文/花漫我一把揭開白布衫冻。她就那樣靜靜地躺著诀紊，像睡著了一般。火紅的嫁衣襯著肌膚如雪隅俘。梳的紋絲不亂的頭發(fā)上邻奠，一...
開封第一講書人閱讀 49,806評(píng)論 1贊 290
城市分裂傳說(shuō)
那天，我揣著相機(jī)與錄音为居，去河邊找鬼碌宴。笑死，一個(gè)胖子當(dāng)著我的面吹牛蒙畴，可吹牛的內(nèi)容都是我干的贰镣。我是一名探鬼主播呜象，決...
沈念sama閱讀 38,951評(píng)論 3贊 407
雙鴛鴦連環(huán)套：你想象不到人心有多黑
文/蒼蘭香墨我猛地睜開眼，長(zhǎng)吁一口氣：“原來(lái)是場(chǎng)噩夢(mèng)啊……” “哼碑隆！你這毒婦竟也來(lái)了恭陡？” 一聲冷哼從身側(cè)響起，我...
開封第一講書人閱讀 37,712評(píng)論 0贊 266
萬(wàn)榮殺人案實(shí)錄
序言：老撾萬(wàn)榮一對(duì)情侶失蹤上煤，失蹤者是張志新（化名）和其女友劉穎休玩，沒(méi)想到半個(gè)月后，有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體劫狠，經(jīng)...
沈念sama閱讀 44,166評(píng)論 1贊 303
?護(hù)林員之死
正文獨(dú)居荒郊野嶺守林人離奇死亡拴疤，尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛以下內(nèi)容為張勛視角年9月15日...
茶點(diǎn)故事閱讀 36,510評(píng)論 2贊 327
?白月光啟示錄
正文我和宋清朗相戀三年，在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了独泞。大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片呐矾。...
茶點(diǎn)故事閱讀 38,643評(píng)論 1贊 340
活死人
序言：一個(gè)原本活蹦亂跳的男人離奇死亡，死狀恐怖阐肤，靈堂內(nèi)的尸體忽然破棺而出凫佛，到底是詐尸還是另有隱情，我是刑警寧澤孕惜，帶...
沈念sama閱讀 34,306評(píng)論 4贊 330
?日本核電站爆炸內(nèi)幕
正文年R本政府宣布愧薛，位于F島的核電站，受9級(jí)特大地震影響衫画，放射性物質(zhì)發(fā)生泄漏毫炉。R本人自食惡果不足惜，卻給世界環(huán)境...
茶點(diǎn)故事閱讀 39,930評(píng)論 3贊 313
男人毒藥：我在死后第九天來(lái)索命
文/蒙蒙一削罩、第九天我趴在偏房一處隱蔽的房頂上張望瞄勾。院中可真熱鬧，春花似錦弥激、人聲如沸进陡。這莊子的主人今日做“春日...
開封第一講書人閱讀 30,745評(píng)論 0贊 21
一樁弒父案微服，背后竟有這般陰謀
文/蒼蘭香墨我抬頭看了看天上的太陽(yáng)趾疚。三九已至，卻和暖如春以蕴，著一層夾襖步出監(jiān)牢的瞬間糙麦，已是汗流浹背。一陣腳步聲響...
開封第一講書人閱讀 31,983評(píng)論 1贊 266
情欲美人皮
我被黑心中介騙來(lái)泰國(guó)打工丛肮，沒(méi)想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留赡磅，地道東北人。一個(gè)月前我還...
沈念sama閱讀 46,351評(píng)論 2贊 360
代替公主和親
正文我出身青樓宝与，卻偏偏與公主長(zhǎng)得像焚廊，于是被迫代替她去往敵國(guó)和親冶匹。傳聞我的和親對(duì)象是個(gè)殘疾皇子，可洞房花燭夜當(dāng)晚...
茶點(diǎn)故事閱讀 43,509評(píng)論 2贊 348

Executors用法和@Async

@Async

Executors接口概述

第1類靜態(tài)方法：將Runnable轉(zhuǎn)換成Callable

第2類靜態(tài)方法：線程工廠(ThreadFactory)類

第3類靜態(tài)方法：不可配置的線程池

第4類靜態(tài)方法：幾類預(yù)先配置的常用線程池

newSingleThreadExecutor - 單任務(wù)線程池

newCachedThreadPool - 緩存線程池

newFixedThreadPool - 固定大小線程池

newWorkStealingPool - 并行工作者線程池

第5類靜態(tài)方法：幾類預(yù)先配置的常用可調(diào)度線程池

newScheduledThreadPool - 固定大小調(diào)度線程池

newSingleThreadScheduledExecutor - 單線程的調(diào)度線程池

推薦閱讀更多精彩內(nèi)容