2. 程式人生 > >springBoot執行緒池

springBoot執行緒池

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

1：定義執行緒池

1

2

3

4

5

6

7

8

9

10

11

12

13

@EnableAsync

@Configuration

class TaskPoolConfig {

@Bean("taskExecutor")

public Executor taskExecutor() {

ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();

executor.setCorePoolSize(

10);

executor.setMaxPoolSize(20);

executor.setQueueCapacity(200);

executor.setKeepAliveSeconds(60);

executor.setThreadNamePrefix("taskExecutor-");

executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

         executor.setWaitForTasksToCompleteOnShutdown(

true);

executor.setAwaitTerminationSeconds(60);

1

2

3

return executor;

}

}

上面我們通過使用ThreadPoolTaskExecutor建立了一個執行緒池，同時設定了以下這些引數：

  • 核心執行緒數10：執行緒池建立時候初始化的執行緒數
  • 最大執行緒數20：執行緒池最大的執行緒數，只有在緩衝佇列滿了之後才會申請超過核心執行緒數的執行緒
  • 緩衝佇列200：用來緩衝執行任務的佇列
  • 允許執行緒的空閒時間60秒：當超過了核心執行緒出之外的執行緒在空閒時間到達之後會被銷燬
  • 執行緒池名的字首：設定好了之後可以方便我們定位處理任務所在的執行緒池
  • 執行緒池對拒絕任務的處理策略：這裡採用了CallerRunsPolicy策略，當執行緒池沒有處理能力的時候，該策略會直接在 execute 方法的呼叫執行緒中執行被拒絕的任務；如果執行程式已關閉，則會丟棄該任務

說明：setWaitForTasksToCompleteOnShutdown（true）該方法就是這裡的關鍵，用來設定執行緒池關閉的時候等待所有任務都完成再繼續銷燬其他的Bean，這樣這些非同步任務的銷燬就會先於Redis執行緒池的銷燬。同時，這裡還設定了setAwaitTerminationSeconds(60)，該方法用來設定執行緒池中任務的等待時間，如果超過這個時候還沒有銷燬就強制銷燬，以確保應用最後能夠被關閉，而不是阻塞住。

2：如何使用該執行緒池呢？

1

2

3

4

5

@Slf4j

@Component

public class Task {

public static Random random = new Random();

    @Autowired

private StringRedisTemplate stringRedisTemplate;

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

@Async("taskExecutor")

public void doTaskOne() throws Exception {

log.info("開始做任務一");

long start = System.currentTimeMillis();

Thread.sleep(random.nextInt(10000));

long end = System.currentTimeMillis();        log.info(stringRedisTemplate.randomKey());

log.info("完成任務一，耗時：" + (end - start) + "毫秒");

}

@Async("taskExecutor")

public void doTaskTwo() throws Exception {

log.info("開始做任務二");

long start = System.currentTimeMillis();

Thread.sleep(random.nextInt(10000));

long end = System.currentTimeMillis();

log.info("完成任務二，耗時：" + (end - start) + "毫秒");

}

@Async("taskExecutor")

public void doTaskThree() throws Exception {

log.info("開始做任務三");

long start = System.currentTimeMillis();

Thread.sleep(random.nextInt(10000));

long end = System.currentTimeMillis();

log.info("完成任務三，耗時：" + (end - start) + "毫秒");

}

}

3 執行非同步任務

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

@RunWith(SpringJUnit4ClassRunner.class)

@SpringBootTest

public class ApplicationTests {

@Autowired

private Task task;

@Test

public void test() throws Exception {

task.doTaskOne();

task.doTaskTwo();

task.doTaskThree();

Thread.currentThread().join();

}

}

1

2

3

4

5

6

2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-1] com.didispace.async.Task                 : 開始做任務一

2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-2] com.didispace.async.Task                 : 開始做任務二

2018-03-27 22:01:15.620  INFO 73703 --- [ taskExecutor-3] com.didispace.async.Task                 : 開始做任務三

2018-03-27 22:01:18.165  INFO 73703 --- [ taskExecutor-2] com.didispace.async.Task                 : 完成任務二，耗時：2545毫秒

2018-03-27 22:01:22.149  INFO 73703 --- [ taskExecutor-3] com.didispace.async.Task                 : 完成任務三，耗時：6529毫秒

2018-03-27 22:01:23.912  INFO 73703 --- [ taskExecutor-1] com.didispace.async.Task                 : 完成任務一，耗時：8292毫秒

4 注意事項

注： @Async所修飾的函式不要定義為static型別，這樣非同步呼叫不會生效

從異常信息JedisConnectionException: Could not get a resource from the pool來看，我們很容易的可以想到，在應用關閉的時候非同步任務還在執行，由於Redis連線池先銷燬了，導致非同步任務中要訪問Redis的操作就報了上面的錯。所以，我們得出結論，上面的實現方式在應用關閉的時候是不優雅的，那麼我們要怎麼做呢？如下設定：

executor.setWaitForTasksToCompleteOnShutdown(true);

executor.setAwaitTerminationSeconds(60);

相關推薦

springBoot執行緒池使用

在我們現實開發中肯定會遇到需要延時請求並且高併發的業務場景,所以結合這個我自己寫了一個模擬延時+高併發的小案例供大家參考. 1. 執行緒池相關配置(當然你也可以寫在配置檔案中方便改動,我就先寫死了): import org.springframework.context.annotati

springboot執行緒池的使用和擴充套件

我們常用ThreadPoolExecutor提供的執行緒池服務，springboot框架提供了@Async註解，幫助我們更方便的將業務邏輯提交到執行緒池中非同步執行，今天我們就來實戰體驗這個執行緒池服務； 實戰環境 windowns10； jdk1.8； spring

springBoot執行緒池

1：定義執行緒池 1 2 3 4 5 6 7 8 9 10 11 12 13 @EnableAsync @Configuration

springboot執行緒池配置（程式碼）

1.配置類   package cn.com.bonc.util; import java.util.concurrent.Executor; import java.util.concurrent.ThreadPoolExecutor; import org.springfr

SpringBoot 執行緒池使用

1. 認識java執行緒池 1.1 在什麼情況下使用執行緒池？     1.單個任務處理的時間比較短     2.需處理的任務的數量大 1.2 使用執行緒池的好處:     1.減少在建立和銷燬執行緒上所花的時間以及系統資源的開銷     2.如不使用執行緒池，有可能造

springboot 執行緒池配置

@Configuration @EnableAsync public class ExecutorConfig { private static final Logger logger = LoggerFactory.getLogger(Executo

SpringBoot 進階系列二 @EnableAsync和@Async 執行緒池定義和使用

在spring傳統自定義執行緒池，是在xml配置檔案中進行配置如： <?xml version="1.0" encoding="UTF-8"?> <beans xmlns="http://www.springframework.org/schema/beans" xmlns:

SpringBoot使用非同步執行緒池使程式無法關閉

又是一個困擾我在整整一天的難題,到了快23點,終於結束了,雖然很想睡覺,但還是得把它記錄下來.                             

springboot @Async 執行緒池使用

一、配置類 AsyncConfig import org.springframework.aop.interceptor.AsyncUncaughtExceptionHandler; import org.springframework.context.annotation.

在Springboot中使用執行緒池ThreadPoolTaskExecutor

package com.markor.template.config; import org.springframework.context.annotation.Bean; import org.springframework.context.annotat

《SpringBoot從入門到放棄》之第（十三）篇——使用@Async非同步呼叫，ThreadPoolTaskScheduler執行緒池，使用Future以及定義超時

建立 TaskPoolConfig 類，配置執行緒池： package com.test.util; import org.springframework.context.annotation.Bean; import org.springframework.cont

springboot之多工並行+執行緒池處理

最近專案中做到一個關於批量發簡訊的業務，如果使用者量特別大的話，不能使用單執行緒去發簡訊，只能嘗試著使用多工來完成！我們的專案使用到了方式二，即Future的方案 Java 執行緒池 Java通過Executors提供四種執行緒池，分別為

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

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

springboot中如何使用執行緒池及非同步執行緒

有一些業務需求，需要是非同步進行的，不能影響當前執行緒的執行，在spring boot中則能通過註解和配置快速實現這個。 首先寫個非同步執行緒池配置類，如下： @Configuration @EnableAsync public class AsyncC

【玩轉SpringBoot】非同步任務執行與其執行緒池配置

同步程式碼寫起來簡單，但就是怕遇到耗時操作，會影響效率和吞吐量。此時非同步程式碼才是王者，但涉及多執行緒和執行緒池，以及非同步結果的獲取，寫起來頗為麻煩。不過在遇到SpringBoot非同步任務時，這個問題就不存在了。因為Spring家族是最替使用者考慮的。結果就是，像同步一樣簡單，像非同步一樣強大。眾所熟悉

執行緒池Executors.newFixedThreadPool驗證以及總結

1、Executors在於java.util.comcurrent.包下，Executors.newFixedThreadPool(n)建立容器大小為n的執行緒池，表示正在執行中的執行緒只有n個， 實踐程式碼如下： public class TestExecute { public

一文帶你吃透執行緒池

微信公眾號：[Amos部落格] 內容目錄 TreadPoolexecutor原始碼解析 類關係圖 Executor介面 ExecutorService介面 AbstractExecutorService 成員變數

Java之執行緒池原始碼深入理解

在前面的文章中，我們使用執行緒的時候就去建立一個執行緒，這樣實現起來非常簡便，但是就會有一個問題： 如果併發的執行緒數量很多，並且每個執行緒都是執行一個時間很短的任務就結束了，這樣頻繁建立執行緒就會大大降低系統的效率，因為頻繁建立執行緒和銷燬執行

Golang 執行緒池

經常會用到協程，但是不能一下開那麼多協調，只需要 poolSize 個即可，多了不行。這些個協程在執行完後必須等其完成之後才能進行下一步動作。假定工作方法為 work 。   package main import ( "fmt" "runtime" "

java：記憶體池、程序池、執行緒池

記憶體池： 自定義記憶體池的思想通過這個"池"字表露無疑，應用程式可以通過系統的記憶體分配呼叫預先一次性申請適當大小的記憶體作為一個記憶體池，之後應用程式自己對記憶體的分配和釋放則可以通過這個記憶體池來完成。 只有當記憶體池大小需要動態擴充套件時，才需要再呼叫系統的記憶體分配函式，其他時間對