2. 程式人生 > >Spring 執行緒池應用

Spring 執行緒池應用

阿新 • • 發佈：2019-02-12
源自:http://zjriso.iteye.com/blog/771706 
1.瞭解 TaskExecutor介面 

    Spring的TaskExecutor介面等同於java.util.concurrent.Executor介面。 實際上，它存在的主要原因是為了在使用執行緒池的時候，將對Java 5的依賴抽象出來。 這個介面只有一個方法execute(Runnable task)，它根據執行緒池的語義和配置，來接受一個執行任務。最初建立TaskExecutor是為了在需要時給其他Spring元件提供一個執行緒池的抽象。 例如ApplicationEventMulticaster元件、JMS的 AbstractMessageListenerContainer和對Quartz的整合都使用了TaskExecutor抽象來提供執行緒池。 當然，如果你的bean需要執行緒池行為，你也可以使用這個抽象層。 




2. TaskExecutor介面的實現類 

    (1)SimpleAsyncTaskExecutor 類 

這個實現不重用任何執行緒，或者說它每次呼叫都啟動一個新執行緒。但是，它還是支援對併發總數設限，當超過執行緒併發總數限制時，阻塞新的呼叫，直到有位置被釋放。如果你需要真正的池，請繼續往下看。 



    (2)SyncTaskExecutor類 

這個實現不會非同步執行。相反，每次呼叫都在發起呼叫的執行緒中執行。它的主要用處是在不需要多執行緒的時候，比如簡單的test case。 



    (3)ConcurrentTaskExecutor 類 

這個實現是對Java 5 java.util.concurrent.Executor類的包裝。有另一個備選, ThreadPoolTaskExecutor類，它暴露了Executor的配置引數作為bean屬性。很少需要使用ConcurrentTaskExecutor, 但是如果ThreadPoolTaskExecutor不敷所需，ConcurrentTaskExecutor是另外一個備選。 


    (4)SimpleThreadPoolTaskExecutor 類 

這個實現實際上是Quartz的SimpleThreadPool類的子類，它會監聽Spring的生命週期回撥。當你有執行緒池，需要在Quartz和非Quartz元件中共用時，這是它的典型用處。 

    (5)ThreadPoolTaskExecutor 類 

它不支援任何對java.util.concurrent包的替換或者下行移植。Doug Lea和Dawid Kurzyniec對java.util.concurrent的實現都採用了不同的包結構，導致它們無法正確執行。 這個實現只能在Java 5環境中使用，但是卻是這個環境中最常用的。它暴露的bean properties可以用來配置一個java.util.concurrent.ThreadPoolExecutor，把它包裝到一個TaskExecutor中。如果你需要更加先進的類，比如ScheduledThreadPoolExecutor,我們建議你使用ConcurrentTaskExecutor來替代。 


    (6)TimerTaskExecutor類 

這個實現使用一個TimerTask作為其背後的實現。它和SyncTaskExecutor的不同在於，方法呼叫是在一個獨立的執行緒中進行的，雖然在那個執行緒中是同步的。 

    (7)WorkManagerTaskExecutor類 

這個實現使用了CommonJ WorkManager作為其底層實現，是在Spring context中配置CommonJ WorkManager應用的最重要的類。和SimpleThreadPoolTaskExecutor類似，這個類實現了WorkManager介面，因此可以直接作為WorkManager使用。 

3.執行緒池Demo之  ThreadPoolTaskExecutor 

    (1)編寫測試類 
Java程式碼  收藏程式碼
  1. import org.springframework.core.task.TaskExecutor;  
  2. public class TaskExecutorExample {  
  3.     private TaskExecutor taskExecutor;  
  4.     public TaskExecutorExample(TaskExecutor taskExecutor) {      
  5.         this.taskExecutor = taskExecutor;    
  6.     }  
  7.     public void printMessages() {      
  8.         for(int i = 0; i < 25; i++) {        
  9.             taskExecutor.execute(new MessagePrinterTask("Message" + i));      
  10.         }    
  11.     }  
  12.     private class MessagePrinterTask implements Runnable {      
  13.         private String message;      
  14.         public MessagePrinterTask(String message) {        
  15.             this.message = message;      
  16.         }      
  17.         public void run() {        
  18.             System.out.println(message);      
  19.         }  
  20.     }  
  21. }  


  (2)spring的配置 
Xml程式碼  收藏程式碼
  1. <bean id="taskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">                 
  2.                   <!-- 執行緒池活躍的執行緒數 -->     
  3.     <property name="corePoolSize" value="5" />   
  4.                    <!-- 執行緒池最大活躍的執行緒數 -->    
  5.     <property name="maxPoolSize" value="10" />   
  6.                    <!-- 佇列的最大容量 -->    
  7.     <property name="queueCapacity" value="25" />  
  8. </bean>  
  9. <bean id="taskExecutorExample" class="powercn.TaskExecutorExample">   
  10.     <constructor-arg ref="taskExecutor" />  
  11. </bean>  


(3)呼叫 
Java程式碼  收藏程式碼
  1. ApplicationContext appContext = new ClassPathXmlApplicationContext("applicationContext.xml");  
  2. TaskExecutorExample te = (TaskExecutorExample)appContext.getBean("taskExecutorExample");  
  3. te.printMessages();  
  4. System.out.println("11111111111111111111111");  

相關推薦

Spring 執行緒池應用

源自:http://zjriso.iteye.com/blog/771706 1.瞭解 TaskExecutor介面     Spring的TaskExecutor介面等同於java.util.concurrent.Executor介面。 實際上，它存在的主要原因是為了在使

1.1 Spring 執行緒池 --- ThreadPoolTaskExecutor

Spring 擅長對元件的封裝和整合， Spring-context對JDK的併發包做了功能增強。  step 1 ：Spring-context.xml 中增加如下程式碼 <bean id="poolTaskExecutor" class="org.springframe

Junit單元測試+aop+spring+執行緒池，在進行Junit測試時切面中執行緒池內呼叫的方法不執行

一、問題背景： 寫了一個切面，指向某service包下的所有類及方法，當該service包下方法被呼叫時切面執行，切面中用了執行緒池ExecutorService pool = Executors.newFixedThreadPool(5);執行緒池內呼叫了dao層的方法。 二、問題描述：單

Spring 執行緒池使用

Spring 中預設自帶執行緒池org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor，一般有可以直接使用，這是時候使用的是預設的配置，直接使用@Autowired注入使用     @Autowire

jdk8新特性（Lambda表示式）結合spring 執行緒池，一行程式碼實現多執行緒

1.配置spring 執行緒池 @Configuration @EnableAsync @ConfigurationProperties(prefix="threadpool") public class ExecutePoolConfiguration { @V

Tornado 執行緒池應用

Tornado是一個非同步框架，在非同步操作的時候能提升程式的處理效能。但是如果在程式中碰到同步的邏輯，由於GIL的關係，會直接卡死，導致效能急劇下降。 目前對於mongodb以及redis都有比較不錯的非同步框架，但是對於Mysql，目前的非同步框架都不是很成熟。 在實際應用中，由於一開始不是特別瞭解，

spring執行緒池在新的執行緒中獲取不到注入的例項

spring執行緒池獲取注入的例項問題 1、問題描述： 配置spring的執行緒池，在呼叫執行緒池時，建立的新執行緒中獲取不到已注入的例項，所以在呼叫方法時會報空指標異常。 2、程式描述： 呼叫執行緒

Tomcat原始碼分析-執行緒池應用

         t.start()方法實則會開啟一個執行緒呼叫了Worker中的run方法，檢視這段程式碼不難發現，如當前處理的任務不為空或者能從任務佇列中取到任務時，則在直接呼叫任務中的run方法進行真正業務處理，否則佇列就會阻塞，程式碼如下： (adsbygoogle = w

spring執行緒池ThreadPoolTaskExecutor與阻塞佇列BlockingQueue

一：　　ThreadPoolTaskExecutor是一個spring的執行緒池技術，檢視程式碼可以看到這樣一個欄位： private ThreadPoolExecutor threadPoolExecutor; 　　可以發現，spring的  ThreadPoolTaskExecutor是

spring執行緒池ThreadPoolExecutor配置並且得到任務執行的結果

用ThreadPoolExecutor的時候，又想知道被執行的任務的執行情況，這時就可以用FutureTask。 ThreadPoolTask 01 package com.zuidaima.threadpoo

Spring執行緒池的使用demo

為了提高執行效率，專案使用了Spring的執行緒池，實行多執行緒並行執行。 Spring註冊執行緒池。 <bean id ="taskExecutor" class ="org.springf

Spring執行緒池配置模板設計（基於Springboot）

目錄 執行緒池配置模板 springboot給我們提供了一個執行緒池的實現，它的底層是由我們傳統執行緒池ThreadPoolTaskExecutor來實現的。並對它進行了一些功能的增強，比如對執行緒狀態的監聽，在我們在使用的時候更加的方便。在這裡給各位同學一個配置模板，簡單的講解下Spring執行緒池的底

spring執行緒池配置

<!-- 配置執行緒池 非同步執行緒池 --> <bean id="taskExecutor" class="org.springframework.scheduling.

Quartz應用——Spring和Quartz加執行緒池實際應用

公司最近開發需要用到定時任務，引用了微服務的概念，但是開發還是spring相關的專案，沒有用到SpringCloud相關的微服務框架。定時任務我就沒選擇xxx-job，Elastic-Job。選擇了Quartz，簡單方便而且拓展行也高。 Spring是一個很優秀的框架，它無縫的集成了Quartz

Java高階應用：執行緒池全面解析

  什麼是執行緒池？   很簡單，簡單看名字就知道是裝有執行緒的池子，我們可以把要執行的多執行緒交給執行緒池來處理，和連線池的概念一樣，通過維護一定數量的執行緒池來達到多個執行緒的複用。   執行緒池的好處 &n

踩坑 Spring Cloud Hystrix 執行緒池佇列配置

背景： 有一次在生產環境，突然出現了很多筆還款單被掛起，後來排查原因，發現是內部系統呼叫時出現了Hystrix呼叫異常。在開發過程中，因為核心執行緒數設定的比較大，沒有出現這種異常。放到了測試環境，偶爾有出現這種情況，後來在網上查詢解決方案，網上的方案是調整maxQueueSize屬性就好了，當時調整了一下

執行緒池的實際應用

最近要將公司專案的JS程式碼改造成Java程式碼，需要用到多執行緒。需求大概是這樣的：有一大批客戶，需要對這一大批客戶進行風險測評，測評涉及到對錶的update操作，這邊採用多執行緒分批對資料庫進行操作。 下面是主要程式碼結構 //建立執行緒池，設定為static if (exec == n

spring mvc tomcat 執行緒池的坑

1 配置tomcat  執行緒池設定為20個執行緒處理請求 2 後臺框架是springmvc   3 模擬10個請求 4  發現tomcat執行緒池沒一個幹活的 5 幹活的是spring自己建立的執行緒 為什麼springmvc

2.1 Spring boot/cloud 執行緒池

Step 1：ExecutePool配置，開啟@EnableAsync支援非同步任務 package com.springboot.begin.threadPool; import org.springframework.context.annotation.Bean; import org.

Spring中的執行緒池

前言：   Java SE 5.0引入了ThreadPoolExecutor、ScheduledThreadPoolExecutor。Spring 2.x藉助ConcurrentTaskExecutor和ThreadPoolTaskExecutor能夠通過IoC配置形式自定義它