package org.sxkj.odm.service;
|
|
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;
|
|
/**
|
* odm 任务线程池服务
|
*/
|
@Component
|
public class OdmTaskThreadService {
|
|
@Qualifier("odmTaskThreadPool")
|
@Autowired
|
private ThreadPoolTaskExecutor 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);
|
}
|
}
|
