executor の execute メソッドをオーバーライドする必要があります。ここで、キューがいっぱいの場合にのみコア プール サイズを超えるスレッドが作成されるように動作を変更する必要があります。
ただし、リアルタイム アプリケーションでは、キューに存在するタスクの無限の待機につながる可能性があるため、この動作は望ましくありません。
以下のように実行方法を変更しました。
public void execute(Runnable command)
{
System.out.println("ActiveCount : " + getActiveCount() + " PoolSize : " + getPoolSize()
+ " QueueSize : " + getQueue().size() +" Idle Threads : " +(getPoolSize()-getActiveCount()));
int c = ctl.get();
if (workerCountOf(c) < corePoolSize) {
if (addWorker(command, true))
return;
c = ctl.get();
}
else if (isRunning(c) && workQueue.offer(command))
{
int recheck = ctl.get();
if (getActiveCount() < workerCountOf(recheck) && isRunning(recheck) && workQueue.offer(command)) {
return;
}
if (addWorker(command, false)) {
return;
}
else if (! isRunning(recheck) && remove(command))
{
reject(command);
}
else if (workerCountOf(recheck) == 0)
{
addWorker(null, false);
}
}
else
{
reject(command); // add task to the queue
}
}
達成しようとしています: CoreThreads -> Non-CoreThreads -> CoreThreads の代わりに Queue -> Queue -> Non-CoreThreads。