JDKネイティブスレッドプールのバグを修正するTomcatの実装原理

// カスタマイズされたタスク キュー taskqueue = new TaskQueue(maxQueueSize);

// カスタマイズされたスレッドファクトリー TaskThreadFactory tf = new TaskThreadFactory(namePrefix,
							                 デーモン、
							                 スレッド優先度を取得します。
);

// カスタム スレッド プール executor = new ThreadPoolExecutor(getMinSpareThreads(),
								  getMaxThreads()、
				 			      最大アイドル時間、 
				 			      時間単位.ミリ秒、
				 			      タスクキュー、
				 			      tf);

public void execute(実行可能なコマンド、長いタイムアウト、TimeUnit 単位) {
    送信されたCountを増加して取得します。
    試す {
        //タスクを実行するには、JDK ネイティブ スレッド プールの execute 関数を呼び出します。super.execute(command);
    } キャッチ (RejectedExecutionException rx) {
       // スレッドの総数がmaximumPoolSizeに達すると、JDKネイティブスレッドプールはデフォルトの拒否ポリシーを実行します。if (super.getQueue() instanceof TaskQueue) {
            最終的な TaskQueue キュー = (TaskQueue)super.getQueue();
            試す {
                // タスクをタスクキューに追加し続ける if (!queue.force(command, timeout, unit)) {
                    送信されたCountを減分して取得します。
                    // バッファ キューがまだいっぱいの場合、挿入は失敗し、拒否戦略が実行されます。
                    新しい RejectedExecutionException("...") をスローします。
                }
            } 
        }
    }
}

送信されたCountを増加して取得します。

送信されたCountを減分して取得します。

パブリッククラスTaskQueueはLinkedBlockingQueue<Runnable>を拡張します。

  パブリックタスクキュー(int 容量) {
      スーパー(容量);
  }
  ...
}

パブリッククラスTaskQueueはLinkedBlockingQueue<Runnable>を拡張します。

  ...
   @オーバーライド
  // スレッドプールがタスクキューメソッドを呼び出すと、現在のスレッド数 > コアスレッド数 public boolean offer(Runnable o) {

      // スレッド数が最大に達した場合、新しいスレッドは作成できず、(parent.getPoolSize() == parent.getMaximumPoolSize()) の場合にのみタスク キューに追加できます。 
          super.offer(o) を返します。
          
      // これまでのところ、最大スレッド数 > 現在のスレッド数 > コアスレッド数であることを示しています // 新しいスレッドを作成できることを示しています:
      
      // 1. 送信されたタスクの数 < 現在のスレッド数の場合 // アイドル状態のスレッドがまだ存在し、新しいスレッドを作成する必要がないことを意味します if (parent.getSubmittedCount()<=(parent.getPoolSize())) 
          super.offer(o) を返します。
          
      // 2. 送信されたタスクの数 > 現在のスレッド数の場合 // スレッドが足りない場合は、false を返して新しいスレッドを作成します if (parent.getPoolSize()<parent.getMaximumPoolSize()) 
          false を返します。
          
      // デフォルトでは、タスクは常にタスクキューに入れられます。 return super.offer(o);
  }
  
}