java – 如何保证ThreadPoolExecutor中的FIFO执行顺序
发布时间:2020-12-15 03:04:35 所属栏目:Java 来源:网络整理
导读:我用这行代码创建一个ThreadPoolExecutor: private ExecutorService executor = new ThreadPoolExecutor(5,10,120,TimeUnit.SECONDS,new ArrayBlockingQueueRunnable(20,true)); 然后,我运行25个任务(T01到T25),所以情况是: 目前正在运行的5个任务(T01到T0
我用这行代码创建一个ThreadPoolExecutor:
private ExecutorService executor = new ThreadPoolExecutor(5,10,120,TimeUnit.SECONDS,new ArrayBlockingQueue<Runnable>(20,true)); 然后,我运行25个任务(T01到T25),所以情况是: >目前正在运行的5个任务(T01到T05) 当我再添加1个任务(T26)时,当队列已满时,我预计将删除旧任务(T06)以启动(因为未达到MaxPoolSize)并且新任务(T26)被放置在末尾队列. 但在现实生活中,如果Queue已满并且未达到MaxPoolSize,则启动最新任务. 所以我有 … >目前正在运行的6个任务(T01到T05和T26) … 代替 … >目前正在运行的6个任务(T01到T06) 我可以配置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; } 谢谢 解决方法
我会使核心大小等于最大值.这就是大多数池的使用方式,我不确定在你的情况下何时会出现缺点,但你会按顺序执行任务.
(编辑:李大同) 【声明】本站内容均来自网络,其相关言论仅代表作者个人观点,不代表本站立场。若无意侵犯到您的权利,请及时与联系站长删除相关内容! |