自定义线程池执行器

Question

我正在编写一个定制的ThreadPoolExecutor，具有以下额外功能：-

>

如果有理想的线程，并且随着任务的到来，将该任务分配到队列中，而不是将其添加到队列中。

如果所有线程（最大池大小）都忙，则在新任务到来时，使用RejectionHandler的reject方法将它们添加到队列中

我已经重写了线程池执行程序的java 1.5版本的执行方法。

新守则如下：-

 public void execute(Runnable command) {
        System.out.println(" Active Count: "+getActiveCount()+" PoolSize: "+getPoolSize()+" Idle Count: "+(getPoolSize()-getActiveCount())+" Queue Size: "+getQueue().size()); 
         if (command == null)
             throw new NullPointerException();
         for (;;) {
             if (runState != RUNNING) {
                 reject(command);
                 return;
             }
             if (poolSize < corePoolSize && addIfUnderCorePoolSize(command)) {
                 return;
             }
            if (runState == RUNNING && (getPoolSize()-getActiveCount() != 0) && workQueue.offer(command)) {
                 return;
             }
             int status = addIfUnderMaximumPoolSize(command);
             if (status > 0)      // created new thread
                 return;
             if (status == 0) {   // failed to create thread
                 reject(command);
                 return;
             }

             if (workQueue.offer(command))
                 return;
             // Retry if created a new thread but it is busy with another task
         }
     }

遗留代码如下所示：-

 public void execute(Runnable command) {
          if (command == null)
              throw new NullPointerException();
          for (;;) {
             if (runState != RUNNING) {
                  reject(command);
                  return;
              }
              if (poolSize < corePoolSize && addIfUnderCorePoolSize(command))
                  return;
              if (workQueue.offer(command))
                  return;
              int status = addIfUnderMaximumPoolSize(command);
              if (status > 0)      // created new thread
                  return;
             if (status == 0) {   // failed to create thread
                 reject(command);
                  return;
             }
            // Retry if created a new thread but it is busy with another task
          }
      }

现在正在生成的问题是，当线程空闲时，它不会创建新的线程，但它甚至不会将任务分配给这些线程，否则它会将它们添加到队列中，这是不希望的，因为我们不想让任务等待，而是处理它ASAP，即使它需要新线程创建，但不允许等待任务。

请帮我解决这个问题。谢谢

Answer 1

就我对您所描述的三个功能的了解而言，我认为使用ExecutorService将比您目前尝试的做得更多：一个Executor，它提供了管理终止的方法，以及可以产生未来跟踪一个或多个异步任务进度的方法，特别是：

1.catched thread pool：允许创建在Parralel中执行任务所需的任意多个线程。旧的可用线程将被重新用于新任务和固定线程池。

2.固定线程池：提供具有固定线程数的池。如果某个线程不可用于该任务，则该任务将被放入队列中，等待其他任务结束。

看看这篇文章的详细解释和很好的例子。

Answer 2

如果我理解了这个问题，我相信我已经找到了ThreadPoolExecutor默认行为的解决方案，我在这里的回答中显示了：

如何让线程池执行器在排队前将线程增加到最大？

基本上，你LinkedBlockingQueue总是返回false的queue.offer（...），这将在必要时向池中添加一个额外的线程。如果池已经处于最大线程，并且它们都很忙，则将调用Reject tedExektionHandler。然后是处理程序将（...）放入队列。

看到我的代码在那里。