package org.springblade.common.utils;
|
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.beans.factory.annotation.Qualifier;
|
import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
|
import org.springframework.stereotype.Component;
|
|
import java.util.concurrent.Callable;
|
import java.util.concurrent.Future;
|
|
@Component
|
public class ThreadPoolUtil {
|
|
// 指定Ben名称注入
|
@Qualifier("customThreadPool")
|
@Autowired
|
private ThreadPoolTaskExecutor executor;
|
|
// @Autowired
|
// public ThreadPoolUtil(ThreadPoolTaskExecutor executor) {
|
// this.executor = executor;
|
// }
|
|
/**
|
* 提交一个Runnable任务到线程池执行
|
* @param task 要执行的任务
|
*/
|
public void execute(Runnable task) {
|
executor.execute(task);
|
}
|
|
/**
|
* 提交一个Callable任务到线程池执行，并返回Future对象用于获取结果
|
* @param task 要执行的任务
|
* @return Future对象
|
*/
|
public <T> Future<T> submit(Callable<T> task) {
|
return executor.submit(task);
|
}
|
}
|
