Только один поток используется в ThreadPoolTaskExecutor и JMS - PullRequest
Новая
       24

Только один поток используется в ThreadPoolTaskExecutor и JMS

2 голосов
/ 16 марта 2011

У меня есть прослушиватель сообщений JMS под JBoss 5.1, настроенный Spring. Хотя ThreadPoolTaskExecutor настроен на размер пула ядер 15, я вижу, что только один поток обслуживает запросы, а остальные ожидают. В соответствии с ThreadPoolExecutor API мне нужна ограниченная очередь, но я не вижу, как Spring позволяет мне это делать.

Вот конфигурация: 

<bean id="connectionFactory" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="java:/ConnectionFactory" />
    <property name="jndiTemplate" ref="jndiTemplate" />
</bean>

<bean id="destination" class="org.springframework.jndi.JndiObjectFactoryBean">
    <property name="jndiName" value="queue/someQueue" />
    <property name="jndiTemplate" ref="jndiTemplate" />
</bean>

<bean id="jmsReceiveDestinationResolver"
    class="org.springframework.jms.support.destination.JndiDestinationResolver">
    <property name="jndiTemplate" ref="jndiTemplate" />
</bean>

<bean id="someListener" class="com.company.SomeListener">
    <property name="..." ref="..." />
</bean>

<jms:listener-container connection-factory="connectionFactory"
    destination-type="queue" destination-resolver="jmsReceiveDestinationResolver" 
    task-executor="jmsTaskExecutor">
    <jms:listener destination="queue/someQueue" ref="messageListener" />
</jms:listener-container>

<bean name="jmsTaskExecutor" class="org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor">
    <property name="corePoolSize" value="15"/>
    <property name="maxPoolSize" value="50"/>       
    <property name="threadNamePrefix" value="some-queue-thread"/>
</bean>

Вот трассировка стека 14 ожидающих потоков: 

"some-queue-thread7" prio=10 tid=0x000000004dcfc800 nid=0x1d90 waiting on condition [0x00000000435f7000]
   java.lang.Thread.State: WAITING (parking)
    at sun.misc.Unsafe.park(Native Method)
    - parking to wait for  <0x000000070f5abad8> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
    at java.util.concurrent.locks.LockSupport.park(LockSupport.java:158)
    at java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject.await(AbstractQueuedSynchronizer.java:1987)
    at java.util.concurrent.LinkedBlockingQueue.take(LinkedBlockingQueue.java:399)
    at java.util.concurrent.ThreadPoolExecutor.getTask(ThreadPoolExecutor.java:947)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
    at java.lang.Thread.run(Thread.java:662)

Обратите внимание, что это может быть похоже на Spring ThreadPoolTaskExecutor только с одним потоком , но в моем случае размер пула ядра больше 1.

1 Ответ

2 голосов
/ 16 марта 2011

Spring Reference говорит, что вам нужно указать максимальное количество одновременных потребителей с <jms:listener-container concurrency = "15" ...>, в противном случае это будет 1.

...