最新国产好看的视频,伊人天堂AV在线,国产Aaaaaa视频,蜜臀视频在线观看一区,人妻av色图,密臀久久久精品影片,青青视频免费观看毛片,久草在线观看视,国产三级精品色情在线

Spring定時任務(wù)@scheduled多線程使用@Async注解示例

 更新時間：2023年11月24日 10:58:00   作者：怕翻船的忒修斯  
這篇文章主要為大家介紹了Spring定時任務(wù)@scheduled多線程使用@Async注解示例詳解,有需要的朋友可以借鑒參考下,希望能夠有所幫助,祝大家多多進(jìn)步,早日升職加薪

1.開篇

在Spring定時任務(wù)@Scheduled注解使用方式淺窺這篇文章里面提及過，spring的定時任務(wù)默認(rèn)是單線程的，他在某些場景下會造成堵塞，那么如果我們想讓每一個任務(wù)都起一條線程去執(zhí)行呢？

2.使用@Async

我們可以使用Spring的@Async注解十分容易的實現(xiàn)多線程的任務(wù)執(zhí)行。
測試代碼：

@Scheduled(cron = "0/2 * * * * ?")
    @Async
    public void doTask() throws InterruptedException {
        logger.info(Thread.currentThread().getName()+"===task run");
        Thread.sleep(6*1_000);
        logger.info(Thread.currentThread().getName()+"===task end");
    }

結(jié)果日志

2018-06-12 16:02:42.005 [taskExecutor-97] INFO  service.task.testTask -taskExecutor-97===task run
2018-06-12 16:02:42.007 [taskExecutor-94] INFO  service.task.testTask -taskExecutor-94===task end
2018-06-12 16:02:44.004 [taskExecutor-98] INFO  service.task.testTask -taskExecutor-98===task run
2018-06-12 16:02:44.015 [taskExecutor-95] INFO  service.task.testTask -taskExecutor-95===task end
2018-06-12 16:02:46.004 [taskExecutor-99] INFO  service.task.testTask -taskExecutor-99===task run
2018-06-12 16:02:46.014 [taskExecutor-96] INFO  service.task.testTask -taskExecutor-96===task end
2018-06-12 16:02:48.004 [taskExecutor-100] INFO  service.task.testTask -taskExecutor-100===task run
2018-06-12 16:02:48.010 [taskExecutor-97] INFO  service.task.testTask -taskExecutor-97===task end
2018-06-12 16:02:50.005 [taskExecutor-1] INFO  service.task.testTask -taskExecutor-1===task run
2018-06-12 16:02:50.008 [taskExecutor-98] INFO  service.task.testTask -taskExecutor-98===task end
2018-06-12 16:02:52.006 [taskExecutor-2] INFO  service.task.testTask -taskExecutor-2===task run

截取部分結(jié)果日志我們可以看到，在上一個任務(wù)6s的執(zhí)行時間內(nèi)，下一個任務(wù)并沒有等待上一個任務(wù)結(jié)束，而是在任務(wù)開始時間直接開啟了一條新的線程進(jìn)行執(zhí)行。
仔細(xì)觀察結(jié)果我們還可以發(fā)現(xiàn)，每條結(jié)果都是一條新的線程，直到100時，才又從第一條線程開始。這是因為在默認(rèn)不做配置的情況下，@Async所使用的線程池容量為100，每次需要的時候都會從中拿出一條，直到用完，才會等待之前的線程釋放，不會再自己擴(kuò)容。
下面我們稍稍改下代碼來證實一下:

@Scheduled(cron = "0/2 * * * * ?")
    @Async
    public void doTask() throws InterruptedException {
        logger.info(Thread.currentThread().getName()+"===task run");
        Thread.sleep(300*1_000);
        logger.info(Thread.currentThread().getName()+"===task end");
    }

這次我讓任務(wù)執(zhí)行的時間等于300s，大于100條線程總間隔時間來耗盡線程池中的線程。

結(jié)果日志

2018-06-12 16:26:44.411 [taskExecutor-93] INFO  service.task.testTask -taskExecutor-93===task run
2018-06-12 16:26:46.853 [taskExecutor-94] INFO  service.task.testTask -taskExecutor-94===task run
2018-06-12 16:26:48.008 [taskExecutor-95] INFO  service.task.testTask -taskExecutor-95===task run
2018-06-12 16:26:50.008 [taskExecutor-96] INFO  service.task.testTask -taskExecutor-96===task run
2018-06-12 16:26:52.006 [taskExecutor-97] INFO  service.task.testTask -taskExecutor-97===task run
2018-06-12 16:26:54.008 [taskExecutor-98] INFO  service.task.testTask -taskExecutor-98===task run
2018-06-12 16:26:56.006 [taskExecutor-99] INFO  service.task.testTask -taskExecutor-99===task run
2018-06-12 16:26:58.005 [taskExecutor-100] INFO  service.task.testTask -taskExecutor-100===task run

2018-06-12 16:28:40.142 [taskExecutor-1] INFO  service.task.testTask -taskExecutor-1===task end
2018-06-12 16:28:40.149 [taskExecutor-1] INFO  service.task.testTask -taskExecutor-1===task run
2018-06-12 16:28:42.117 [taskExecutor-2] INFO  service.task.testTask -taskExecutor-2===task end
2018-06-12 16:28:42.121 [taskExecutor-2] INFO  service.task.testTask -taskExecutor-2===task run
2018-06-12 16:28:44.253 [taskExecutor-3] INFO  service.task.testTask -taskExecutor-3===task end
2018-06-12 16:28:44.257 [taskExecutor-3] INFO  service.task.testTask -taskExecutor-3===task run
2018-06-12 16:28:46.027 [taskExecutor-4] INFO  service.task.testTask -taskExecutor-4===task end
2018-06-12 16:28:46.031 [taskExecutor-4] INFO  service.task.testTask -taskExecutor-4===task run

通過日志我們可以看到，再第100條線程也開始執(zhí)行任務(wù)后，沒有新的線程再被創(chuàng)建，而是等待有線程執(zhí)行完后，再開始執(zhí)行本次任務(wù)。

3.配置線程池大小

雖然上面的方式已經(jīng)解決了我們的問題，但是總覺得不太好，有時候我們需要異步執(zhí)行任務(wù)，但是又不需要這么多的線程的時候，我們可以使用下面的配置來設(shè)置線程池的大小
配置文件：

<task:annotation-driven scheduler="testScheduler" />
    <!-- 配置任務(wù)線程池和線程池大小 -->
    <task:scheduler id="testScheduler" pool-size="6" />

測試代碼：

@Scheduled(cron = "0/2 * * * * ?")
    @Async
    public void doTask() throws InterruptedException {
        logger.info(Thread.currentThread().getName()+"===task run");
        Thread.sleep(6*1_000);
        logger.info(Thread.currentThread().getName()+"===task end");
    }

結(jié)果日志：

2018-06-12 18:32:56.032 [taskExecutor-1] INFO  service.task.testTask -taskExecutor-1===task run
2018-06-12 18:32:58.007 [taskExecutor-2] INFO  service.task.testTask -taskExecutor-2===task run
2018-06-12 18:33:00.005 [taskExecutor-3] INFO  service.task.testTask -taskExecutor-3===task run
2018-06-12 18:33:02.008 [taskExecutor-4] INFO  service.task.testTask -taskExecutor-4===task run
2018-06-12 18:33:02.036 [taskExecutor-1] INFO  service.task.testTask -taskExecutor-1===task end
2018-06-12 18:33:04.327 [taskExecutor-2] INFO  service.task.testTask -taskExecutor-2===task end
2018-06-12 18:33:04.328 [taskExecutor-5] INFO  service.task.testTask -taskExecutor-5===task run
2018-06-12 18:33:06.007 [taskExecutor-6] INFO  service.task.testTask -taskExecutor-6===task run
2018-06-12 18:33:06.010 [taskExecutor-3] INFO  service.task.testTask -taskExecutor-3===task end
2018-06-12 18:33:08.459 [taskExecutor-4] INFO  service.task.testTask -taskExecutor-4===task end
2018-06-12 18:33:08.460 [taskExecutor-7] INFO  service.task.testTask -taskExecutor-7===task run
2018-06-12 18:33:10.011 [taskExecutor-8] INFO  service.task.testTask -taskExecutor-8===task run
2018-06-12 18:33:10.332 [taskExecutor-5] INFO  service.task.testTask -taskExecutor-5===task end
2018-06-12 18:33:12.005 [taskExecutor-9] INFO  service.task.testTask -taskExecutor-9===task run
2018-06-12 18:33:12.012 [taskExecutor-6] INFO  service.task.testTask -taskExecutor-6===task end
2018-06-12 18:33:14.904 [taskExecutor-10] INFO  service.task.testTask -taskExecutor-10===task run
2018-06-12 18:33:14.904 [taskExecutor-7] INFO  service.task.testTask -taskExecutor-7===task end

結(jié)果和我們預(yù)料的并不一樣啊，線程數(shù)超過了6，這是什么原因呢？

其實如果我們在使用@Async時想使用配置好的線程池，需要為@Async注解添加value屬性來制定所用的線程池。
修改后的代碼

@Scheduled(cron = "0/2 * * * * ?")
    @Async("testScheduler")
    public void doTask() throws InterruptedException {
        logger.info(Thread.currentThread().getName()+"===task run");
        Thread.sleep(30*1_000);
        logger.info(Thread.currentThread().getName()+"===task end");
    }

結(jié)果日志：

2018-06-12 18:54:42.035 [testScheduler-3] INFO  service.task.testTask -testScheduler-3===task run
2018-06-12 18:54:44.010 [testScheduler-2] INFO  service.task.testTask -testScheduler-2===task run
2018-06-12 18:54:46.007 [testScheduler-1] INFO  service.task.testTask -testScheduler-1===task run
2018-06-12 18:54:48.007 [testScheduler-5] INFO  service.task.testTask -testScheduler-5===task run
2018-06-12 18:54:50.005 [testScheduler-4] INFO  service.task.testTask -testScheduler-4===task run
2018-06-12 18:54:52.021 [testScheduler-6] INFO  service.task.testTask -testScheduler-6===task run

2018-06-12 18:55:12.039 [testScheduler-3] INFO  service.task.testTask -testScheduler-3===task end
2018-06-12 18:55:12.044 [testScheduler-3] INFO  service.task.testTask -testScheduler-3===task run
2018-06-12 18:55:14.016 [testScheduler-2] INFO  service.task.testTask -testScheduler-2===task end
2018-06-12 18:55:14.022 [testScheduler-2] INFO  service.task.testTask -testScheduler-2===task run
2018-06-12 18:55:16.289 [testScheduler-1] INFO  service.task.testTask -testScheduler-1===task end
2018-06-12 18:55:16.297 [testScheduler-1] INFO  service.task.testTask -testScheduler-1===task run
2018-06-12 18:55:18.289 [testScheduler-5] INFO  service.task.testTask -testScheduler-5===task end
2018-06-12 18:55:18.293 [testScheduler-5] INFO  service.task.testTask -testScheduler-5===task run
2018-06-12 18:55:20.009 [testScheduler-4] INFO  service.task.testTask -testScheduler-4===task end
2018-06-12 18:55:20.014 [testScheduler-4] INFO  service.task.testTask -testScheduler-4===task run
2018-06-12 18:55:22.165 [testScheduler-6] INFO  service.task.testTask -testScheduler-6===task end
2018-06-12 18:55:22.172 [testScheduler-6] INFO  service.task.testTask -testScheduler-6===task run

這次結(jié)果和我們的預(yù)計是一樣的了，在初始的6條線程使用完畢以后就會等待之前的線程釋放啦，同時也可以看到線程池名是我們設(shè)置的線程池。

以上就是Spring定時任務(wù)@scheduled多線程使用@Async注解示例的詳細(xì)內(nèi)容，更多關(guān)于Spring @scheduled使用@Async的資料請關(guān)注腳本之家其它相關(guān)文章！

相關(guān)文章

  • Java連接MySQL8.0 JDBC的詳細(xì)步驟(IDEA版本)

    Java連接MySQL8.0 JDBC的詳細(xì)步驟(IDEA版本)

    這篇文章主要介紹了Java連接MySQL8.0 JDBC的詳細(xì)步驟(IDEA版本)，本文給大家介紹的非常詳細(xì)，對大家的學(xué)習(xí)或工作具有一定的參考借鑒價值,需要的朋友可以參考下
    2021-04-04
  • Java通過百度地圖API獲取定位(普通IP定位)的方法教程

    Java通過百度地圖API獲取定位(普通IP定位)的方法教程

    這篇文章主要介紹了Java通過百度地圖API獲取定位的方法教程,首先說明了實現(xiàn)這個功能的需求和初衷,然后詳細(xì)描述了利用百度地圖API實現(xiàn)這個功能的步驟,包括在百度地圖開放平臺的準(zhǔn)備工作、學(xué)習(xí)官網(wǎng)API文檔、修改API的AK配置、Java代碼獲取定位等,需要的朋友可以參考下
    2024-11-11
  • SpringBoot攔截器實現(xiàn)登錄攔截的示例代碼

    SpringBoot攔截器實現(xiàn)登錄攔截的示例代碼

    本文主要介紹了SpringBoot攔截器實現(xiàn)登錄攔截，文中根據(jù)實例編碼詳細(xì)介紹的十分詳盡，具有一定的參考價值，感興趣的小伙伴們可以參考一下
    2022-03-03
  • SpringBoot如何指定某些類優(yōu)先啟動

    SpringBoot如何指定某些類優(yōu)先啟動

    這篇文章主要介紹了SpringBoot如何指定某些類優(yōu)先啟動,文中通過示例代碼介紹的非常詳細(xì)，對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友可以參考下
    2019-09-09
  • K8S(Docker)如何優(yōu)雅的關(guān)閉SpringBoot微服務(wù)

    K8S(Docker)如何優(yōu)雅的關(guān)閉SpringBoot微服務(wù)

    這篇文章主要介紹了K8S(Docker)如何優(yōu)雅的關(guān)閉SpringBoot微服務(wù)問題,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
    2025-01-01
  • idea中如何去掉不想commit的文件

    idea中如何去掉不想commit的文件

    這篇文章主要介紹了idea中如何去掉不想commit的文件，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
    2023-02-02
  • 詳解java中的6種單例寫法及優(yōu)缺點

    詳解java中的6種單例寫法及優(yōu)缺點

    在java中，單例有很多種寫法，面試時，手寫代碼環(huán)節(jié)，除了寫算法題，有時候也會讓手寫單例模式，這里記錄一下單例的幾種寫法和優(yōu)缺點。需要的朋友可以參考下
    2018-11-11
  • IDEA使用Lombok簡化POJO代碼的示例

    IDEA使用Lombok簡化POJO代碼的示例

    今天小編就為大家分享一篇關(guān)于IDEA使用Lombok簡化POJO代碼的示例，小編覺得內(nèi)容挺不錯的，現(xiàn)在分享給大家，具有很好的參考價值，需要的朋友一起跟隨小編來看看吧
    2019-01-01
  • JUC系列學(xué)習(xí)工具類CountDownLatch詳解

    JUC系列學(xué)習(xí)工具類CountDownLatch詳解

    這篇文章主要介紹了JUC系列學(xué)習(xí)工具類CountDownLatch詳解，文章圍繞主題展開詳細(xì)的內(nèi)容介紹，具有一定的參考價值，需要的小伙伴可任意參考一下
    2022-08-08
  • java實現(xiàn)的小時鐘示例分享

    java實現(xiàn)的小時鐘示例分享

    這篇文章主要介紹了java實現(xiàn)的小時鐘示例,需要的朋友可以參考下
    2014-02-02

最新評論

准格尔旗| 乌兰浩特市| 安塞县| 长葛市| 晋州市| 铁力市| 思南县| 文安县| 偏关县| 闸北区| 南乐县| 高阳县| 安庆市| 麻城市| 泽普县| 邵武市| 广水市| 北海市| 焦作市| 松原市| 平凉市| 盘锦市| 宁武县| 星子县| 铁岭县| 庆阳市| 额敏县| 威宁| 临漳县| 涟水县| 右玉县| 兴安县| 沅陵县| 溧水县| 峨山| 阿克苏市| 金乡县| 东阳市| 甘德县| 鄄城县| 铁岭市|