spring-integration-aws:调用stop()时等待彼此的SqsMessageDrivenChannelAdapter线程

Question

当调用SqsMessageDrivenChannelAdapter时，我试图停止stop() --我收到了以下错误：

java.util.concurrent.TimeoutException: null
at java.util.concurrent.FutureTask.get(FutureTask.java:205)
at org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer.stop(SimpleMessageListenerContainer.java:197)
at org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer.doStop(SimpleMessageListenerContainer.java:133)
at org.springframework.cloud.aws.messaging.listener.AbstractMessageListenerContainer.stop(AbstractMessageListenerContainer.java:329)
at org.springframework.cloud.aws.messaging.listener.SimpleMessageListenerContainer.stop(SimpleMessageListenerContainer.java:1)
at org.springframework.integration.aws.inbound.SqsMessageDrivenChannelAdapter.doStop(SqsMessageDrivenChannelAdapter.java:140)
at org.springframework.integration.endpoint.AbstractEndpoint.stop(AbstractEndpoint.java:111)

最初的迹象我认为超时还不够长，在研究了这个问题之后，我发现停止线程和正在运行的线程正在等待，TimeoutException总是会发生的。我通过下面的代码来修正这个问题：

new Thread() {
     public void run()
     {
        sqsMessageRawDataChannelAdapter.stop();
        LockSupport.parkNanos(TimeUnit.SECONDS.toNanos(5));
     }
  }.start();

我现在不再得到TimeoutException，因为线程能够停止。我做错什么了吗，还是这是个问题？

Answer 1

嗯-嗯。看起来像是代码中的死锁。

您试图从侦听器持有的线程中停止适配器(因此也是侦听器)。

用你的话说，stopping thread == running thread。

为了避免这样的问题，您肯定应该将stop操作转移到不同的线程。