用于多个相同任务的Java ThreadPool

2 回答

• 2

  当您使用 ExecutorService 时，您将 Runnable 作业提交给线程池，这些线程池依次由池中的线程运行 . 您可以执行以下操作之一：

  • 让每个 Runnable 坐在循环中，从循环中的 BlockingQueue 出发来处理每个数据包 . 这可能比他们在缓冲区对象周围进行同步更容易 . 就像是：

  public void run() {
     while (!shutdown) {
        packet = packetQueue.take();
        processPacket(packet);
     }
  }
  

  • 或者，您可以将每个数据包作为作业本身提交给线程池，尽管这可能会增加您的对象负载 . 您可以处理每个数据包，提取有效负载，并使用处理有效负载的 run() 方法在有效负载周围创建一个 Runnable 包装器 . Runnable 类的内容类似于：

  Payload payload;
  public void run() {
     // process packet here
     processPayload(payload);
  }
  

  使用这两种机制，我会选择一个最符合您的处理器数量和处理任务性质的固定线程数 . 下面的示例使用了处理器的数量，但您可能需要为GC或其他任务关闭一些 . 您可能希望在其他IO上的处理块上添加更多内容 . 只有性能测试才能告诉您最佳值 .

  // start a pool that uses the number of threads that there are processors
  ExecutorService threadPool = Executors.newFixedThreadPool(
      Runtime.getRuntime().availableProcessors());
  

  回复于 2024-04-20T15:11:53+08:00
• 1

  由Executors.newFixedThreadPool创建的固定线程池将正常工作 .

  实现的内部语义是这样的，线程池将优先创建一个新线程，直到它达到其首选大小（核心池大小），这似乎是你想要的 .

  回复于 2024-04-20T15:11:53+08:00