package org.sxkj.resource.download.comfig;
|
|
import jodd.util.concurrent.ThreadFactoryBuilder;
|
import org.springframework.context.annotation.Bean;
|
import org.springframework.context.annotation.Configuration;
|
|
import java.util.concurrent.ExecutorService;
|
import java.util.concurrent.LinkedBlockingQueue;
|
import java.util.concurrent.ThreadPoolExecutor;
|
import java.util.concurrent.TimeUnit;
|
|
/**
|
* @Description TODO 下载任务线程池配置
|
* @Author AIX
|
* @Date 2025/8/5 13:48
|
* @Version 1.0
|
*/
|
@Configuration
|
public class ThreadPoolConfig {
|
|
@Bean("downloadTaskExecutor")
|
public ExecutorService downloadTaskExecutor() {
|
return new ThreadPoolExecutor(
|
// 核心线程数
|
8,
|
// 最大线程数
|
32,
|
60L, TimeUnit.SECONDS,
|
// 队列大小
|
new LinkedBlockingQueue<>(100),
|
new ThreadFactoryBuilder().setNameFormat("download-task-%d").get(),
|
// 拒绝策略
|
new ThreadPoolExecutor.CallerRunsPolicy()
|
);
|
}
|
|
}
|
