寻求关于分享烦躁老板/员工资源的建议

Question

上下文： Netty 3.6.3。最终，Java1.7，Scala 2.9. x

为了最大限度地减少（可能空闲的）线程数量，我想与不同的NIO套接字通道工厂（TCP）和一个NioDatagramChannelFactory共享NIO客户端/服务器和工作池。我使用至少两个（或三个与Finagle堆栈）服务器/客户端引导集，每个都有自己的NIO套接字通道工厂。为每个老板和工作池使用新的缓存线程池会导致线程负载，而这些线程大部分时间都不会使用。粗略的目标是将所有引导/通道工厂的工人数量限制在2*CPU核心数量和CPU核心数量的老板数量。

我正在尝试切换到NioServer/ClientBossPool和niowerpool，以获得我自己的一套引导。但是，根据底层ThreadPoolExecutor的配置，关闭引导会导致主线程在AbstractNioSelector关闭闩锁上永远等待。

class NioClientBossPoolTest {

  @Test def shutdown() {
    val corePoolSize = 1
    val maxPoolSize = Integer.MAX_VALUE
    val keepAliveSeconds = 60
    val keepAliveUnit = TimeUnit.SECONDS

    val blocking = true
    val queue: BlockingQueue[Runnable] =
      if(blocking) new LinkedBlockingQueue[Runnable](Integer.MAX_VALUE)
      else new SynchronousQueue[Runnable]()

    val executor = new ThreadPoolExecutor(corePoolSize,
        maxPoolSize,
        keepAliveSeconds,
        keepAliveUnit,
        queue)

    val clientBossPool = new NioClientBossPool(executor, 1) // B
    new NioServerBossPool(executor, 1) // C
    val workerPool = new NioWorkerPool(executor, 1) // A

    val channelFactory = new NioClientSocketChannelFactory(clientBossPool, workerPool)
    val bootstrap = new ClientBootstrap(channelFactory)

    // hangs waiting for shutdown latch in AbstractNioSelector (NioWorker or NioClientBoss
    // depending on the order of statement A, B, C) for
    // LinkedBlockingQueue, corePoolSize = 1 and sequence of statements A, B and C other than [B, A, C]
    // LinkedBlockingQueue, corePoolSize = 2 and sequence of statements A, B and C other than
    // [A, B, C], [B, C, A] and [C, B, A]
    bootstrap.shutdown()
  }
}

我很确定executor服务配置必须满足一些特定的要求，但具体要求是什么（核心池大小、队列类型）？独自创立shutdown（）将永远阻塞，除非语句A、B和C的执行顺序正好是[B、A、C]。对于三条语句的六个组合中的三个，将核心池大小增加到2个块。具有核心池大小

Answer 1

实际上，这似乎是一个错误。我认为，如果xou为boss和workerpool使用不同的执行器，那么它是有效的。你能打开一个错误报告吗？