我用這行代碼創建一個ThreadPoolExecutor：

private ExecutorService executor = new ThreadPoolExecutor(5, 10, 120, TimeUnit.SECONDS, new ArrayBlockingQueue(20, true));

然后,我運行25個任務(T01到T25),所以情況是：

>目前正在運行的5個任務(T01到T05)

在隊列中等待的20個任務(T06到T25)

當我再添加1個任務(T26)時,當隊列已滿時,我預計將刪除舊任務(T06)以啟動(因為未達到MaxPoolSize)并且新任務(T26)被放置在末尾隊列.

但在現實生活中,如果Queue已滿并且未達到MaxPoolSize,則啟動最新任務.

所以我有 …

>目前正在運行的6個任務(T01到T05和T26)

在隊列中等待的20個任務(T06到T25)

… 代替 …

>目前正在運行的6個任務(T01到T06)

> 20個任務在隊列中等待(T07到T26)

我可以配置ThreadPoolExecutor來獲得預期的結果嗎？

我應該使用其他課嗎？

有關信息,部分ThreadPoolExecutor源代碼

public void execute(Runnable command) {

if (command == null)

throw new NullPointerException();

if (poolSize >= corePoolSize || !addIfUnderCorePoolSize(command)) {

if (runState == RUNNING && workQueue.offer(command)) {

if (runState != RUNNING || poolSize == 0)

ensureQueuedTaskHandled(command);

}

else if (!addIfUnderMaximumPoolSize(command))

reject(command); // is shutdown or saturated

}

}

private boolean addIfUnderMaximumPoolSize(Runnable firstTask) {

Thread t = null;

final ReentrantLock mainLock = this.mainLock;

mainLock.lock();

try {

if (poolSize < maximumPoolSize && runState == RUNNING)

t = addThread(firstTask);

} finally {

mainLock.unlock();

}

if (t == null)

return false;

t.start();

return true;

}

謝謝

總結

以上是生活随笔為你收集整理的fifo java_java – 如何保证ThreadPoolExecutor中的FIFO执行顺序的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。