中文字幕av专区_日韩电影在线播放_精品国产精品久久一区免费式_av在线免费观看网站

溫馨提示×

溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務條款》

Spring boot如何通過@Scheduled實現定時任務及多線程配置

發布時間:2020-10-24 10:44:05 來源:腳本之家 閱讀:177 作者:慕塵 欄目:編程語言

這篇文章主要介紹了Spring boot如何通過@Scheduled實現定時任務及多線程配置,文中通過示例代碼介紹的非常詳細,對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下

使用@Scheduled 可以很容易實現定時任務

spring boot的版本 2.1.6.RELEASE

package com.abc.demo.common;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
public class ScheduleSetting {
  private final Logger logger = LoggerFactory.getLogger(Tasks.class);
  @Scheduled(fixedRate = 10000, initialDelay = 2000)
  public void scheduleRead() {
    try {
      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron1任務開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      long endStamp = System.currentTimeMillis();
      try {
        TimeUnit.SECONDS.sleep(20);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("cron1任務正在運行的線程名稱:" + thread.getName() + " 結束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("++++++++++++++++++++++++");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }

  @Scheduled(fixedRate = 5000, initialDelay = 1000)
  public void scheduleConvert() {
    try {

      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron2任務開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      try {
        TimeUnit.SECONDS.sleep(10);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      long endStamp = System.currentTimeMillis();
      System.out.println("cron2任務正在運行的線程名稱:" + thread.getName() + " 結束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("====================");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }
}

運行輸出內容為

cron2任務開始,start=2019-10-11 17:31:52, threadId=34, threadName=scheduling-1
cron2任務正在運行的線程名稱:scheduling-1 結束,start=2019-10-11 17:31:52,end=2019-10-11 17:32:02
====================
cron1任務開始,start=2019-10-11 17:32:02, threadId=34, threadName=scheduling-1
cron1任務正在運行的線程名稱:scheduling-1 結束,start=2019-10-11 17:32:02,end=2019-10-11 17:32:02
++++++++++++++++++++++++
cron2任務開始,start=2019-10-11 17:32:22, threadId=34, threadName=scheduling-1
cron2任務正在運行的線程名稱:scheduling-1 結束,start=2019-10-11 17:32:22,end=2019-10-11 17:32:32

……

注:

  cron2執行完后才會執行cron1

原因:

  spring默認是以單線程執行任務調度

  spring的定時任務默認最大運行線程數為1,多個任務執行起來時間會有問題

1.配置線程池

在配置文件application.properties中添加

# 線程池大小
spring.task.scheduling.pool.size=5
# 線程名前綴
spring.task.scheduling.thread-name-prefix=myScheduling-

輸出內容變為

cron2任務開始,start=2019-10-11 17:34:48, threadId=34, threadName=myScheduling-1
cron1任務開始,start=2019-10-11 17:34:49, threadId=35, threadName=myScheduling-2
cron2任務正在運行的線程名稱:myScheduling-1 結束,start=2019-10-11 17:34:48,end=2019-10-11 17:34:58
====================
cron2任務開始,start=2019-10-11 17:34:58, threadId=34, threadName=myScheduling-1
cron2任務正在運行的線程名稱:myScheduling-1 結束,start=2019-10-11 17:34:58,end=2019-10-11 17:35:08
====================
cron2任務開始,start=2019-10-11 17:35:08, threadId=57, threadName=myScheduling-3
cron1任務正在運行的線程名稱:myScheduling-2 結束,start=2019-10-11 17:34:49,end=2019-10-11 17:34:49

……

注:

多線程下,cron1和cron2不用互相等待了,但是同一個任務還是需要等待的

2.并發

修改代碼

package com.abc.demo.common;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.SimpleDateFormat;
import java.util.concurrent.TimeUnit;
@EnableScheduling
@Component
@EnableAsync
public class ScheduleSetting {
  private final Logger logger = LoggerFactory.getLogger(Tasks.class);
  @Async
  @Scheduled(fixedRate = 10000, initialDelay = 2000)
  public void scheduleRead() {
    try {
      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron1任務開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      long endStamp = System.currentTimeMillis();
      try {
        TimeUnit.SECONDS.sleep(20);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      System.out.println("cron1任務正在運行的線程名稱:" + thread.getName() + " 結束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("++++++++++++++++++++++++");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }

  @Async
  @Scheduled(fixedRate = 5000, initialDelay = 1000)
  public void scheduleConvert() {
    try {

      long timeStamp = System.currentTimeMillis();
      SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
      Thread thread = Thread.currentThread();
      System.out.println("cron2任務開始,start=" + simpleDateFormat.format(timeStamp) + ", threadId=" + thread.getId() + ", threadName=" + thread.getName());
      try {
        TimeUnit.SECONDS.sleep(10);
      } catch (InterruptedException e) {
        e.printStackTrace();
      }
      long endStamp = System.currentTimeMillis();
      System.out.println("cron2任務正在運行的線程名稱:" + thread.getName() + " 結束,start=" + simpleDateFormat.format(timeStamp) + ",end=" + simpleDateFormat.format(endStamp));
      System.out.println("====================");
    } catch (Exception e) {
      logger.error(e.getMessage());
    }
  }
}

輸出的內容

cron2任務開始,start=2019-10-11 17:39:53, threadId=57, threadName=task-1
cron1任務開始,start=2019-10-11 17:39:54, threadId=59, threadName=task-2
cron2任務開始,start=2019-10-11 17:39:58, threadId=61, threadName=task-3
cron2任務開始,start=2019-10-11 17:40:03, threadId=63, threadName=task-4
cron2任務正在運行的線程名稱:task-1 結束,start=2019-10-11 17:39:53,end=2019-10-11 17:40:03
====================
cron1任務開始,start=2019-10-11 17:40:04, threadId=64, threadName=task-5
cron2任務開始,start=2019-10-11 17:40:08, threadId=65, threadName=task-6
cron2任務正在運行的線程名稱:task-3 結束,start=2019-10-11 17:39:58,end=2019-10-11 17:40:08
====================
cron2任務開始,start=2019-10-11 17:40:13, threadId=66, threadName=task-7
cron2任務正在運行的線程名稱:task-4 結束,start=2019-10-11 17:40:03,end=2019-10-11 17:40:13
====================
cron1任務正在運行的線程名稱:task-2 結束,start=2019-10-11 17:39:54,end=2019-10-11 17:39:54

說明: 

  •   @EnableAsync開啟多線程
  •   @Async標記其為一個異步任務
  •   每個定時任務都是在通過不同的線程來處理,線程名的前綴成了task-
  •   線程默認為10個

修改配置

spring.task.execution.thread-name-prefix=mytask-
spring.task.execution.pool.core-size=5

重新運行的輸出

cron2任務開始,start=2019-10-11 17:44:00, threadId=56, threadName=mytask-1
cron1任務開始,start=2019-10-11 17:44:01, threadId=57, threadName=mytask-2
cron2任務開始,start=2019-10-11 17:44:05, threadId=58, threadName=mytask-3
cron2任務開始,start=2019-10-11 17:44:10, threadId=59, threadName=mytask-4
cron2任務正在運行的線程名稱:mytask-1 結束,start=2019-10-11 17:44:00,end=2019-10-11 17:44:10
====================
cron1任務開始,start=2019-10-11 17:44:11, threadId=60, threadName=mytask-5
cron2任務正在運行的線程名稱:mytask-3 結束,start=2019-10-11 17:44:05,end=2019-10-11 17:44:15
====================
cron2任務開始,start=2019-10-11 17:44:15, threadId=58, threadName=mytask-3
cron2任務開始,start=2019-10-11 17:44:20, threadId=56, threadName=mytask-1
cron2任務正在運行的線程名稱:mytask-4 結束,start=2019-10-11 17:44:10,end=2019-10-11 17:44:20
====================
cron1任務正在運行的線程名稱:mytask-2 結束,start=2019-10-11 17:44:01,end=2019-10-11 17:44:01

以上就是本文的全部內容,希望對大家的學習有所幫助,也希望大家多多支持億速云。

向AI問一下細節

免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。

AI

昌邑市| 辽宁省| 保德县| 象州县| 五莲县| 津市市| 永修县| 观塘区| 抚松县| 绵竹市| 射阳县| 都安| 金湖县| 金堂县| 房产| 肇东市| 伊金霍洛旗| 鄢陵县| 雷山县| 杭锦旗| 阿克| 罗甸县| 崇义县| 黄石市| 峨边| 麻江县| 长沙市| 柯坪县| 汉中市| 吉木萨尔县| 颍上县| 南阳市| 荆州市| 航空| 绩溪县| 邢台县| 长顺县| 略阳县| 曲周县| 台州市| 犍为县|