代码之家 › 专栏 › 技术社区 › Epcylon

消费池的自动缩放

producer-consumer multithreading java

Epcylon · 技术社区 · 15 年前

我们有一个Web应用程序,允许用户触发对外部资源的请求。外部资源花费不确定的时间来收集结果,因此我们必须对其进行轮询以获取更新,并在完成后收集最终结果。

我们希望这样做,当用户触发请求时,它将被添加到队列中,然后许多工作线程将拾取每个请求并进行轮询,而用户则执行其他操作。

由于请求的数量在一天中变化很大,我们认为当速度较慢时,让许多工人什么也不做是浪费资源,但同时我们需要有足够的工人来处理系统的峰值负载。

我们想要一些可以在有很多请求等待时添加更多工人的东西,但是在没有什么事情可做的时候就杀死工人。

使用EJB可以/曾经可以这样做,但我们不想使用它。我们也不想使用JMS或其他大型框架来处理这个问题,除非它是我们已经在使用的框架(Spring、Quartz、许多Apache工具)。

因为EJB支持这一点,而且它是其中一个更有用的特性,所以我们认为已经有人为我们解决了这个问题。建议?

2 回复 | 直到 13 年前

RivieraKid 13 年前

使用A ThreadPoolExecutor 具有适当的核心和最大池大小值。

但是请记住,拥有数百个空闲线程并没有很大的成本,因此您可以考虑只使用 Executors.newFixedThreadPool() .

Dirk 15 年前

从 java.util.concurrent.ThreadPoolExecutor documentation :

如果池当前具有比CopePoLosithType多的线程,则多余的线程将被终止,如果它们已经闲置超过KePayLaveTimE(参见GETKEPIPALVETIME(Java.UTI.Orth.TimeUnt))。这提供了一种在池未被积极使用时减少资源消耗的方法。如果池稍后变得更活跃,将构造新线程。

所以,我建议你先试试Java标准库。您需要稍微调整参数,但是线程池是高度可配置的。

推荐文章

Zdanovskiy Mihail · Numba使用parallel=True标志集使Python崩溃

1 年前

Ma Joonyoung · 粗粒度和细粒度链表的时间比较

1 年前

Community wiki · SqlConnections,Parallel.For,一个旧的C#应用程序,初始化SqlConnections时随机挂起

1 年前

user1700890 · 了解交互式代理Python API中的线程

2 年前

AntonBoarf · 为什么要将实例变量指定给局部变量?

2 年前

rhymes · 如何让线程操作相同的java列表

2 年前

Ben · 错误:缺少类型说明符-假定为int。注意C++不支持默认初始化

2 年前

SRK7Kyros · 在Python中启动线程时是否使用整个处理器线程?

2 年前

MatiiFine · 在c++[duplicate]中的主源文件外使用std::thread

2 年前

Youssof. K. · 线程1:vector insert上的EXC_BAD_访问(代码=1,地址=0x0)

2 年前