Spring ThreadPoolTask​​Executor仅运行一个线程

Question

我们在JMS使用者中使用ThreadPoolExecutor，并将其注入DefaultMessageListenerContainer中。我希望这会在许多消息上运行并发线程，但是我们的日志显示线程ID不会改变，而我们的日志显示对于不同的消息处理，线程ID始终为24。

在这种情况下，这是spring配置：

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"       
         p:connectionFactory-ref="cachedConnectionFactory"
         p:destination-ref="formsCRRDestination"
         p:messageListener-ref="formServicePojo"
         p:concurrentConsumers="5"
         p:idleTaskExecutionLimit="1"
         p:maxConcurrentConsumers="25"
         p:taskExecutor-ref="threadPoolExecutor"         
         destroy-method="doShutdown"     
    >


 <bean id="threadPoolExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor" >
        <property name="corePoolSize" value="1"/>
        <property name="maxPoolSize" value="15"/>
        <property name="keepAliveSeconds" value="30"/>
    </bean>

在不将threadPoolExectuor Bean注入DefaultMessageListenerContainer中之后，现在正在不同的线程中执行消息。

这是结果配置：

<bean class="org.springframework.jms.listener.DefaultMessageListenerContainer"       
             p:connectionFactory-ref="cachedConnectionFactory"
             p:destination-ref="formsCRRDestination"
             p:messageListener-ref="formServicePojo"
             p:concurrentConsumers="5"
             p:idleTaskExecutionLimit="1"
             p:maxConcurrentConsumers="25"       
             destroy-method="doShutdown"     
        >

我尝试阅读文档，但我不明白为什么会这样。有什么解释吗？

Answer 1

在Spring中查看了ThreadPoolTask​​Executor代码并阅读了ThreadPoolTask​​Executor的Java文档之后，我认为这是答案：

无限队列。在所有corePoolSize线程都繁忙的情况下，使用无界队列（例如，没有预定义容量的LinkedBlockingQueue）将使新任务排队。因此，将仅创建corePoolSize线程。（因此，maximumPoolSize的值没有任何作用。）

在上面的配置中，默认情况下使用的是LinkedBlockingQueue，而corePoolSize为1。这就是为什么maximumPoolSize不起作用的原因。