spring ThreadPoolTaskExecutor在每次方法调用时创建新线程

Question

我有以下ThreadPoolTaskExecator2配置

 <bean id="threadPoolTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <property name="corePoolSize" value="10" />
    <property name="maxPoolSize" value="25" />
    <property name="queueCapacity" value="30" />
</bean>

在我的公共类AdminService中，我有两个方法。

1. void triggerJob（）
2. 布尔执行sql（字符串sql）

如何将ThreadPoolTaskExecutor插入triggerJob方法，以便在第一个方法中调用executeSql时创建新线程。

在triggerjob中，我有一个基于条件调用executeSql的循环。

我是否需要创建一个私有类，实现runnable，以便ThreadPoolTaskExector可以执行此类，或者是否有可能创建没有runnable的线程？

我的想法是这样的

@Autowired    
ThreadPoolTaskExecutor threadPoolTaskExecutor;

     void triggerJob(){
           for( Object k:Objects){
               if(k.equals(something){
                //here new thread to be created somehow 
                threadPoolTaskExecutor.execute(executeSql(k.getSql())
               }
           }
        }

Answer 1

如果你必须这样做，你可以使用org.springframework.core.task.SimpleAsyncTaskExecator：

<bean id="simpleTaskExecutor" class="org.springframework.core.task.SimpleAsyncTaskExecutor">
   <property name="concurrencyLimit" value="25" />
</bean>

但是创建一个Java线程是昂贵的。通常建议重用线程，即使SimpleAsyncTaskExecutor文档也会说：

注意：此实现不重用线程！请考虑使用线程池TaskExecitor实现，特别是在执行大量短期任务时。