文章/答案/技术大牛

发布

社区首页 >问答首页 >Poller任务执行器内存泄漏

问Poller任务执行器内存泄漏
EN

Stack Overflow用户

提问于 2019-09-06 09:17:40

回答 1查看 229关注 0票数 0

我正在构建一个企业应用程序，并使用active mq在应用程序之间进行内部通信。当我与poller一起使用任务执行器时，AbstractPollingEndpoint和ErrorHandlingTaskExecutor对象实例会导致内存泄漏。即使应用程序处于空闲模式，堆中的对象计数也会增加。当我关闭代码.taskExecutor(outTaskExecutor)的这一部分时，问题就不再发生了。但是我们正在为大量的通信做准备，我们不需要提供更多的线程来处理消息。我做错什么了？你能帮忙吗？谢谢

可视化VM堆比较

Executor Service outTaskExecutor = Executors.newFixedThreadPool(10);

IntegrationFlow jmsOutbound = IntegrationFlows.from(jmsInChannel)
                .handle(Jms.outboundAdapter(this.jmsTemplate.getConnectionFactory())
                                .destinationExpression("headers['responseQueueName']")
                        , s -> s.poller(p -> p.fixedDelay(pollerDelay).taskExecutor(outTaskExecutor)).get())
                .get();
        this.flowContext.registration(jmsOutbound).id("jmsOutbound").register();

poller

spring

spring-integration

dsl

回答 1

Stack Overflow用户

回答已采纳

发布于 2019-09-06 17:23:50

对于每一个动态流都有Executor Service outTaskExecutor = Executors.newFixedThreadPool(10);，这看上去并不正确。为什么不把它作为一个单独的实例并与所有动态流共享呢？

还要注意对docs中类似问题的这种描述：https://docs.spring.io/spring-integration/reference/html/#async-polling

加上这个问题：由于接收超时和任务执行器退出调优而导致内存泄漏

票数 0

页面原文内容由Stack Overflow提供。腾讯云小微IT领域专用引擎提供翻译支持

原文链接：

https://stackoverflow.com/questions/57819133

复制

相似问题

问Poller任务执行器内存泄漏
EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Poller任务执行器内存泄漏EN

回答 1

Stack Overflow用户

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

问Poller任务执行器内存泄漏
EN