Переглянути джерело

Merge branch 'develop' of gitadmin/tuoheng_freeway into release

tags/v1.0.0^2
wanjing 1 рік тому
джерело
коміт
eba6bb88c6
1 змінених файлів з 36 додано та 0 видалено
  1. +36
    -0
      tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/config/ExecutorConfig.java

+ 36
- 0
tuoheng-service/tuoheng-admin/src/main/java/com/tuoheng/admin/config/ExecutorConfig.java Переглянути файл

@@ -0,0 +1,36 @@
package com.tuoheng.admin.config;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableAsync;
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;

import java.util.concurrent.Executor;
import java.util.concurrent.ThreadPoolExecutor;

/**
* 线程池配置
*/
@Configuration
@EnableAsync
public class ExecutorConfig {

@Bean
public Executor asyncServiceExecutor() {
ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
//配置核心线程数
executor.setCorePoolSize(5);
//配置最大线程数
executor.setMaxPoolSize(10);
//配置队列大小
executor.setQueueCapacity(400);
//配置线程池中的线程的名称前缀
executor.setThreadNamePrefix("thread-");
// rejection-policy:当pool已经达到max size的时候,如何处理新任务
// CALLER_RUNS:不在新线程中执行任务,而是有调用者所在的线程来执行
executor.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());
//执行初始化
executor.initialize();
return executor;
}
}

Завантаження…
Відмінити
Зберегти