java - 在Netty NIO中动态添加线程到ExecutorService

Question

我想创建一个类似 ExecutorService 的东西，其中最初是单线程，并且基于给予 ExecutorService 的工作负载，线程数必须逐渐增加到一定数量，例如 50。我找不到任何方法来做到这一点。

有办法在 NETTY NIO 中实现这一点吗？

感谢您的帮助。谢谢。

Answer 1

您可以使用 ThreadPoolExecutor 。您实际上并不自己添加线程，而是池会根据负载的需要实例化新线程，因此您从核心线程开始，新线程将根据需要自动添加，最多>最大线程数。超过核心计数的线程一旦在超时期限内空闲，就会继续存在。

import java.util.concurrent.*;
....
ThreadPoolExecutor tpe = new ThreadPoolExecutor(core, maxThreads,
                                      timeout, TimeUnit.SECONDS,
                                      new SynchronousQueue<Runnable>(),
                                      threadFactory);