当前位置: 首页 > 知识库问答 >
问题:

不同ConcurrentMessageListenerContainer实例上的共享线程池

邢凌
2023-03-14

我有很多消费者组(每个消费者组一个主题)的用例,因此我必须为一个主题/消费者组创建许多ConcurrentMessageListenerContainer实例。但我希望他们共享一个公共线程池,以控制KafkanConsumer的调用。轮询以及记录的处理方式。您认为这与SpringKafka相关吗,还是我必须实现自己的版本来实例化自己的KafakConsumers?

共有1个答案

锺离锦
2023-03-14

使用池不会有帮助——容器目前为每个消费者使用专用线程。不支持跨容器共享线程。

 类似资料:
  • 问题内容: 我想像这样在多个线程之间共享一个变量: 我想在主线程和帮助线程之间共享,这是我创建的两个不同的Java类。有什么办法吗?谢谢! 问题答案: 二者并可以参照包含该变量的类。 然后,可以使该变量为 volatile ,这意味着 对该变量的更改在两个线程中立即可见。 有关更多信息,请参见本文。 易变变量 共享已同步的可见性功能,但不共享原子性功能。这意味着线程将自动 查看volatile变量

  • 问题内容: 假设我有一个与field共享的对象。多个线程将共享对该对象的引用以访问该字段。但是,线程永远不会同时访问对象。我需要声明为volatile吗? 这样的情况如下: 一个类定义一个唯一字段和一个方法。 一个线程使计数器递增,然后生成另一个使计数器递增的线程,依此类推。 鉴于程序的逻辑,因此无法并发访问计数器。但是,计数器是在多个线程之间共享的。计数器必须波动吗? 的情况的另一个变体是当多个

  • 我一直在努力理解春豆。根据我的理解,默认情况下所有bean都是singleton,并且在第一次请求时创建具有lazy-init属性设置为true的singleton bean,在创建应用程序上下文时创建具有lazy-init属性设置为false的singleton bean。 因此,在应用程序中,当一个用户请求进来时(每个请求都是一个单独的线程),当在程序/类中被请求时,所有这些线程是否共享相同的

  • 本文向大家介绍C++进程间共享数据实例,包括了C++进程间共享数据实例的使用技巧和注意事项,需要的朋友参考一下 本文实例讲述了C++进程间共享数据的实现方法,分享给大家供大家参考。具体实现方法如下: 希望本文所述对大家的C++程序设计有所帮助。

  • 你会如何用swift写下以下内容?

  • 我注意到一些web框架(如Play Framework)允许您配置多个不同大小的线程池(线程池中的线程数)。假设我们在单核的单机中运行这个游戏。拥有多个线程池不会有很大的开销吗?