java – 如何保证ThreadPoolExecutor中的FIFO执行顺序

前端之家收集整理的这篇文章主要介绍了java – 如何保证ThreadPoolExecutor中的FIFO执行顺序前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
我用这行代码创建一个ThreadPoolExecutor:
private ExecutorService executor = new ThreadPoolExecutor(5,10,120,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(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;
}

谢谢

解决方法

我会使核心大小等于最大值.这就是大多数池的使用方式,我不确定在你的情况下何时会出现缺点,但你会按顺序执行任务.

猜你在找的Java相关文章