0
我们在生产中有一个弹簧应用程序，看起来它正在泄漏线程。Spring集成：应用程序泄漏SimpleAsyncTaskExecutor线程？
当我做一个线程转储时，我看到以下线程似乎在等待。下面是下面的例子，但也有成千上万的
"SimpleAsyncTaskExecutor-1801" prio=10 tid=0x00007fa668413800 nid=0x376c waiting on condition [0x00007fa4fbaff000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <0x00000007777e2ba8> (a java.util.concurrent.CountDownLatch$Sync)
at java.util.concurrent.locks.LockSupport.park(LockSupport.java:186)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.parkAndCheckInterrupt(AbstractQueuedSynchronizer.java:834)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.doAcquireSharedInterruptibly(AbstractQueuedSynchronizer.java:994)
at java.util.concurrent.locks.AbstractQueuedSynchronizer.acquireSharedInterruptibly(AbstractQueuedSynchronizer.java:1303)
at java.util.concurrent.CountDownLatch.await(CountDownLatch.java:236)
at org.springframework.integration.core.MessagingTemplate$TemporaryReplyChannel.receive(MessagingTemplate.java:415)
at org.springframework.integration.core.MessagingTemplate$TemporaryReplyChannel.receive(MessagingTemplate.java:409)
at org.springframework.integration.core.MessagingTemplate.doReceive(MessagingTemplate.java:317)
at org.springframework.integration.core.MessagingTemplate.doSendAndReceive(MessagingTemplate.java:341)
at org.springframework.integration.core.MessagingTemplate.sendAndReceive(MessagingTemplate.java:255)
at org.springframework.integration.core.MessagingTemplate.convertSendAndReceive(MessagingTemplate.java:290)
at org.springframework.integration.gateway.MessagingGatewaySupport.doSendAndReceive(MessagingGatewaySupport.java:224)
at org.springframework.integration.gateway.MessagingGatewaySupport.sendAndReceive(MessagingGatewaySupport.java:203)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.invokeGatewayMethod(GatewayProxyFactoryBean.java:306)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.doInvoke(GatewayProxyFactoryBean.java:269)
at org.springframework.integration.gateway.GatewayProxyFactoryBean.access$200(GatewayProxyFactoryBean.java:71)
at org.springframework.integration.gateway.GatewayProxyFactoryBean$AsyncInvocationTask.call(GatewayProxyFactoryBean.java:499)
at java.util.concurrent.FutureTask.run(FutureTask.java:262)
at java.lang.Thread.run(Thread.java:745)
最终达到一个地步，这将导致服务器无法响应，只有重启会拿回来。
这似乎涉及到一个Spring集成网关，它发送一条消息，正在等待一些永不会得到的答案。在我们的应用程序，使用这个唯一的地方是发送（发布）这些消息到RabbitMQ的交换，使用服务接口
这是服务接口代码的通知通道：
@Component
public interface INotificationSender {
Future<Void> sendNotification(@Payload Object notification,
@Header("routingKey") String routingKey,
@Header("notificationType") String type);
}
这是相关的Spring配置：
<!-- Spring Integration RabbitMQ adapter -->
<rabbit:template
id="amqpTemplate"
connection-factory="notificationConnectionFactory" />
<rabbit:connection-factory
id="notificationConnectionFactory"
addresses="${notificationChannel.rabbitHost1}:${notificationChannel.rabbitPort}, ${notificationChannel.rabbitHost2}:${notificationChannel.rabbitPort}"
username="${notificationChannel.rabbitUsername}"
password="${notificationChannel.rabbitPassword}"
virtual-host="${notificationChannel.rabbitVirtualHost}"/>
<rabbit:topic-exchange
name="notificationExchange"/>
<!-- Spring Integration AMQP -->
<int-amqp:outbound-channel-adapter
id="notificationChannelAdapter"
channel="notificationChannelEnc"
exchange-name="notificationExchange"
routing-key-expression="headers['routingKey']"
mapped-request-headers="STANDARD_REQUEST_HEADERS, notificationType"/>
<!-- Spring Integration Core -->
<int:channel
id="notificationChannelEnc">
<int:interceptors>
<int:wire-tap channel="loggingChannel" />
</int:interceptors>
</int:channel>
<int:channel id="notificationChannel"/>
<int:object-to-json-transformer
id="NotificationEncoder"
content-type="text/x-json"
input-channel="notificationChannel"
output-channel="notificationChannelEnc"/>
<int:gateway
id="notificationGateway"
default-request-channel="notificationChannel"
service-interface="com.ericsson.ericloud.commander.notification.sender.INotificationSender"/>
我们使用Spring版本3.2.3.RELEASE和Spring集成版本3.0.0.M2
任何人有任何想法如何处理这个问题，让这些线程正确终止？
谢谢， /塞巴斯蒂安