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);
	}
}