Spring定時任務多線程

阿新 • • 發佈：2018-11-27

-c sta sys getname print ram encoding 配置 size

單線程

1)在Spring.xml中開啟定時器的功能

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns="http://www.springframework.org/schema/beans"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:task="http://www.springframework.org/schema/task"

xsi:schemaLocation 
="  

http://www.springframework.org/schema/beans  

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  

http://www.springframework.org/schema/context  

http://www.springframework.org/schema/context/spring-context-3.0.xsd  

http://www.springframework.org/schema/task  

http://www.springframework.org/schema/task/spring-task-3.0.xsd  " 
>

<!-- 讓Spring找到被@Component註解的類 -->

<context:component-scan base-package="cn.ltian.base" />

<!--定時器開關 -->

<task:annotation-driven  />

2)編寫定時器類

package cn.ltian.base;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
 
import org.springframework.stereotype.Component;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class MyScheduler {

    //每10秒執行一次
    @Scheduled(cron = "0/2 * * * * ?")
    public void aTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 開始");
       try{
           Thread.sleep(5000);
       }catch(Exception e){
       }
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 結束");
    }

    //每5秒執行一次
    @Scheduled(cron = "0/5 * * * * ?")
    public void bTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"b任務執行一次,5m");
    }
}

3)運行結果

2018-11-13 20:27:20 :pool-1-thread-1a任務執行一次,2m 開始

2018-11-13 20:27:25 :pool-1-thread-1a任務執行一次,2m 結束

2018-11-13 20:27:25 :pool-1-thread-1b任務執行一次,5m

2018-11-13 20:27:26 :pool-1-thread-1a任務執行一次,2m 開始

2018-11-13 20:27:31 :pool-1-thread-1a任務執行一次,2m 結束

2018-11-13 20:27:31 :pool-1-thread-1b任務執行一次,5m

2018-11-13 20:27:32 :pool-1-thread-1a任務執行一次,2m 開始

2018-11-13 20:27:37 :pool-1-thread-1a任務執行一次,2m 結束

2018-11-13 20:27:37 :pool-1-thread-1b任務執行一次,5m

2018-11-13 20:27:38 :pool-1-thread-1a任務執行一次,2m 開始

2018-11-13 20:27:43 :pool-1-thread-1a任務執行一次,2m 結束

2018-11-13 20:27:43 :pool-1-thread-1b任務執行一次,5m

2018-11-13 20:27:44 :pool-1-thread-1a任務執行一次,2m 開始

多線程（同步單任務）

1)在Spring.xml中開啟定時器的功能

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns="http://www.springframework.org/schema/beans"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:task="http://www.springframework.org/schema/task"

xsi:schemaLocation="  

http://www.springframework.org/schema/beans  

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  

http://www.springframework.org/schema/context  

http://www.springframework.org/schema/context/spring-context-3.0.xsd  

http://www.springframework.org/schema/task  

http://www.springframework.org/schema/task/spring-task-3.0.xsd  ">

<!-- 讓Spring找到被@Component註解的類 -->
<context:component-scan base-package="cn.ltian.base" />
<!--定時器開關 -->
<task:annotation-driven scheduler="MyScheduler"/>
<!-- 配置任務線程池 -->
<task:scheduler id="MyScheduler" pool-size="4" />

2)編寫定時器類

package cn.ltian.base;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class MyScheduler {

    //每10秒執行一次
    @Scheduled(cron = "0/2 * * * * ?")
    public void aTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 開始");
       try{
           Thread.sleep(5000);
       }catch(Exception e){
       }
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 結束");
    }

    //每5秒執行一次
    @Scheduled(cron = "0/5 * * * * ?")
    public void bTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"b任務執行一次,5m");
    }
}

3)運行結果

2018-11-13 20:29:18 :MyScheduler-1a任務執行一次,2m 開始

2018-11-13 20:29:20 :MyScheduler-2b任務執行一次,5m

2018-11-13 20:29:23 :MyScheduler-1a任務執行一次,2m 結束

2018-11-13 20:29:24 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:25 :MyScheduler-3b任務執行一次,5m

2018-11-13 20:29:29 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:29:30 :MyScheduler-3b任務執行一次,5m

2018-11-13 20:29:30 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:35 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:29:35 :MyScheduler-3b任務執行一次,5m

2018-11-13 20:29:36 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:40 :MyScheduler-4b任務執行一次,5m

2018-11-13 20:29:41 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:29:42 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:45 :MyScheduler-4b任務執行一次,5m

2018-11-13 20:29:47 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:29:48 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:50 :MyScheduler-4b任務執行一次,5m

2018-11-13 20:29:53 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:29:54 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:29:55 :MyScheduler-4b任務執行一次,5m

2018-11-13 20:29:59 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:30:00 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:30:00 :MyScheduler-4b任務執行一次,5m

多線程（異步單任務）

1)在Spring.xml中開啟定時器的功能

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xmlns="http://www.springframework.org/schema/beans"

xmlns:context="http://www.springframework.org/schema/context"

xmlns:task="http://www.springframework.org/schema/task"

xsi:schemaLocation="  

http://www.springframework.org/schema/beans  

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd  

http://www.springframework.org/schema/context  

http://www.springframework.org/schema/context/spring-context-3.0.xsd  

http://www.springframework.org/schema/task  

http://www.springframework.org/schema/task/spring-task-3.0.xsd  ">

<!-- 讓Spring找到被@Component註解的類 -->

<context:component-scan base-package="cn.ltian.base" />

<!--定時器開關 -->

<task:annotation-driven scheduler=" myScheduler"/>

<!-- 配置任務線程池 -->

<task:scheduler id="myScheduler" pool-size="4" />

2)編寫定時器類

package cn.ltian.base;

import org.springframework.scheduling.annotation.Async;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import java.text.DateFormat;
import java.text.SimpleDateFormat;
import java.util.Date;

@Component
public class MyScheduler {

    //每10秒執行一次
    @Scheduled(cron = "0/2 * * * * ?")
    @Async(value="MyScheduler")
    public void aTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 開始");
       try{
           Thread.sleep(5000);
       }catch(Exception e){
       }
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"a任務執行一次,2m 結束");
    }

    //每5秒執行一次
    @Scheduled(cron = "0/5 * * * * ?")
    public void bTask() {
        DateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println(sdf.format(new Date())+"     :"+Thread.currentThread().getName()+"b任務執行一次,5m");
    }
}

3)運行結果

2018-11-13 20:32:24 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:32:25 :MyScheduler-3b任務執行一次,5m

2018-11-13 20:32:26 :MyScheduler-3a任務執行一次,2m 開始

2018-11-13 20:32:28 :MyScheduler-4a任務執行一次,2m 開始

2018-11-13 20:32:29 :MyScheduler-2a任務執行一次,2m 結束

2018-11-13 20:32:30 :MyScheduler-2b任務執行一次,5m

2018-11-13 20:32:30 :MyScheduler-1a任務執行一次,2m 開始

2018-11-13 20:32:31 :MyScheduler-3a任務執行一次,2m 結束

2018-11-13 20:32:32 :MyScheduler-3a任務執行一次,2m 開始

2018-11-13 20:32:33 :MyScheduler-4a任務執行一次,2m 結束

2018-11-13 20:32:34 :MyScheduler-4a任務執行一次,2m 開始

2018-11-13 20:32:35 :MyScheduler-1a任務執行一次,2m 結束

2018-11-13 20:32:35 :MyScheduler-2b任務執行一次,5m

2018-11-13 20:32:36 :MyScheduler-2a任務執行一次,2m 開始

2018-11-13 20:32:37 :MyScheduler-3a任務執行一次,2m 結束

2018-11-13 20:32:38 :MyScheduler-3a任務執行一次,2m 開始

Spring定時任務多線程

-c sta sys getname print ram encoding 配置 size 單線程 1)在Spring.xml中開啟定時器的功能 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns

定時任務-C#線程類 windows服務

system 由於 star pri code windows 方法的參數方法 html 原理最常用的就是C#中 timer類寫一個定時方法，然後在把他宿主到windows服務裏面。 C#中Timer分類關於C# Timer類在C#裏關於定時器類就有3個

Spring定時任務多執行緒

單執行緒 1)在Spring.xml中開啟定時器的功能 <?xml version="1.0" encoding="UTF-8"?> <beans xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xml

一個C# (隊列多任務+多線程處理)對象的winform demo

blog exception nerd row 部分主體如何 windows prot 閱讀本文前，先閱讀：https://www.cnblogs.com/zetee/p/3487084.html 該文中構建多線程任務的思路，與delphi下構建多任務線程池的方式類似

Spring Boot 中配置定時任務，實現多線程操作

pre log pri http code china 部分多線程操作 .net 參考的代碼部分 https://git.oschina.net/jokerForTao/spring_boot_schedule 一目了然！Spring Boot 中配置定時任務，實現

使用spring-boot創建定時任務。同時創建多線程執行定時任務。

from vnr thread make oca 工程遷移 prefix gist 1，下載spring-boot的maven工程：http://start.spring.io/ 直接自定義工程名稱。 2 ，啟動類增加註解：@EnableScheduling 具體的業

spring定時任務.線程池,自定義多線程配置

sys wire eight void port itl edm 代碼 .org 定時任務及多線程配置xml <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springfr

多線程-傳統定時任務

sta alt rup () color test pac exception lee package com.thread.timer; import java.util.Date; import java.util.Timer; import java.u

python 多線程並發threading & 任務隊列Queue

不同 htm doc threading 阻塞子線程 per 出現 bag https://docs.python.org/3.7/library/concurrency.htmlpython程序默認是單線程的，也就是說在前一句語句執行完之前後面的語句不能繼續執行先感受一

[深入學習C#]C#實現多線程的方式：Task——任務

ren avr 利用 run 如何創建其中 continue rep 簡介　　.NET 4包含新名稱空間System.Threading.Tasks，它包含的類抽象出了線程功能。在後臺使用ThreadPool。任務表示應完成的某個單元的工作。這個單元的工作可以

談談多線程開發中的線程和任務的理念

計算機制需求 spa 是把發的多少代碼編程技術前段時間寫了一個iOS端的數據統計SDK，數據統計有些復雜的計算和數據上報操作。由於有些操作比較耗時。所以不得不在後臺線程進行操作，由此引發了我對多線程的思考，在iOS開發中，一般非常難再見到直接使用NST

[django] 利用多線程添加異步任務

1.5 size lan sel ins post target span class 看到django異步大家的反應應該是celery這樣的消息隊列組件。如今用的最多的最推薦的也是這樣的方式。然而我這需求就是請求來了，運行一個小程序。可是又不能確定這個小程序啥時候

多線程中sleep和wait的區別，以及多線程的實現方式及原因，定時器--Timer

守護驗證取消技術方法代碼安全接口 art 1. Java中sleep和wait的區別 ① 這兩個方法來自不同的類分別是，sleep來自Thread類，和wait來自Object類。 sleep是Thread的靜態類方法，誰調用的誰去睡覺，即使在a線程裏調用b

C#多線程の遇見長耗時操作以及多任務

reat obj let zed when local ade counter args 4.0用 Task.Factory.StartNew(()=>{});4.0以下用 ThreadPool.QueueUserWorkItem(()=>{}

spring boot 集成kafka (多線程,消費者使用kafka的原生api實現,因為@KakfkaListener修改groupId無效)

初始化接收 .bat truct singleton test ops cati xtend application-test.properties 1 #kafka 2 kafka.consumer.zookeeper.connect=*:2181 3 kafk

並發實戰：多線程處理任務，結束後，執行後續操作

batch add 批次 for return countdown executors 操作 current 場景：分批從大列表 blist 讀取數據，執行驗證過濾，符合條件的加入到列表中。然後執行批量入庫操作。思路：多任務從 blist 取數據執行，采用Excuet

Spring單例模式多線程安全問題-有狀態的Bean

原型 ttr servlet resp 共享實現 tails div htm Spring單例與線程安全小結一、Spring單例模式與線程安全 Spring框架裏的bean，或者說組件，獲取實例的時候都是默認的單例模式，這是在多線程開發的時候要尤其註意的地方。單例

C#多線程學習(五) 多線程的自動管理(定時器)

class 時間 change chan 表示 () 圖片管理 rda Timer類：設置一個定時器，定時執行用戶指定的函數。定時器啟動後，系統將自動建立一個新的線程，執行用戶指定的函數。初始化一個Timer對象： Timer timer

多線程與計劃任務

線程 normal 實例啟動程序指定 scheduler target web 執行通常，程序在文件中最後一行代碼執行後終止（或調用sys.exit()）。在程序的所有線程終止之前，python程序不會終止。多線程也可能會導致所謂的並發問題。如果這些線程同時讀寫變量，

附1：多線程並發方案的不足——響應式Spring的道法術器

響應式編程本系列文章索引《響應式Spring的道法術器》本篇內容是響應式流的附錄。（以下接響應式流的1.2.1.1節，關於“CPU眼中的時間”的內容。請不要單獨看這一篇內容，否則有些內容可能讓你摸不著頭腦 0..0）多線程的方式有其不完美之處，而且有些難以駕馭—— 一、耗時的上下文切換 CPU先生不太樂

Spring定時任務多線程

單線程

多線程（同步單任務）

多線程（異步單任務）

相關推薦