动态线程池

Question

我有一个运行时间很长的过程，可以监听事件并进行一些激烈的处理。

目前，我通常Executors.newFixedThreadPool(x)用于限制并发运行的作业数量，但是根据一天中的时间以及其他各种因素，我希望能够动态地增加或减少并发线程的数量。

如果我减少了并发线程的数量，那么我希望当前正在运行的作业能够很好地完成。

是否有Java库可以让我控制并动态增加或减少线程池中运行的并发线程数？（该类必须实现ExecutorService）。

我必须自己实施吗？

Answer 1

看看下面的ThreadPoolExecutor中的API

public void setCorePoolSize(int corePoolSize)

设置核心线程数。这将覆盖构造函数中设置的任何值。

如果新值小于当前值，则多余的现有线程将在下次空闲时终止。

如果更大，将在需要时启动新线程以执行任何排队的任务。

初始化：

ExecutorService service = Executors.newFixedThreadPool(5);

根据需要，使用以下API 调整线程池 的 大小

((ThreadPoolExecutor)service).setCorePoolSize(newLimit);//newLimit is new size of the pool

重要的提示：

如果队列已满，并且线程数的新值大于或等于之前定义的maxPoolSize，则Task将被拒绝。

因此，请设置maxPoolSize和的值corePoolSize。