spring boot 2X中@Scheduled實現定時任務及多線程配置

時間  2019-11-06
標籤 spring boot 2x scheduled 實現 定時 任務 多線程 配置 欄目 Spring 简体版
原文   原文鏈接

使用@Scheduled 能夠很容易實現定時任務java

spring boot的版本 2.1.6.RELEASEspring

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併發

……app

注：異步

　　cron2執行完後纔會執行cron1spa

緣由：線程

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

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

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

 

曾經在幽幽暗暗，反反覆覆中追問，才知道平平淡淡從從容容纔是真

再回首恍然如夢，再回首我心依舊，只有那無盡的長路陪伴我

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程