回答情况：
提问时间：
问题标签：
3回答
ThreadPoolExecutor threadPoolExecutor = (ThreadPoolExecutor)实际上，这很奇怪，因为ThreadPoolExecutor implements ExecutorService和我要把ExecutorService投给ThreadPoolExecutor。
浏览 3修改于2013-07-26得票数 1
回答已采纳
}; final ThreadPoolExecutorservice = new ThreadPoolExecutor(coreSize, maxSize, idleThreadLiveInSecond,
TimeUnit.SECONDS, queue, factory, new ThreadPoolExecutor<
浏览 4修改于2018-01-21得票数 0
我得到了以下代码，它使用concurrent.futures.ThreadPoolExecutor以一种有节制的方式启动另一个程序的进程(一次不超过30个)。subprocess.Popen(args) process.wait()
with concurrent.futures.ThreadPoolExecutor
浏览 56提问于2021-01-22得票数 1
鉴于此，我正在尝试确定ThreadPoolExecutor的正确设置。
我的第一个想法是使用直接切换和调用者运行故障策略的固定线程池。
浏览 1提问于2011-12-01得票数 3
回答已采纳
Count: 3 Queue Size: 0Active Count: 2 Pool Size : 5 Idle Count: 3 Queue Size: 0ThreadPoolExecutorThreadPoolExecutor:- System.out.println("Active Count: "
浏览 5修改于2017-05-23得票数 2
当脚本中断时，如何立即停止concurrent.futures.ThreadPoolExecutor并丢弃所有挂起的操作，如下例所示： import requests
try:with ThreadPoolExecutor(max_workers=25) as executor:
futur
浏览 48修改于2021-10-23得票数 0
回答已采纳
我试图使用ThreadPoolExecutor来调度任务，但是它的策略遇到了一些问题。我现在想的是在一个ThreadPoolExecutor上运行SynchronousQueue，而不是直接将任务提供给它，而是将它们提供给一个单独的、无界的LinkedBlockingQueue。
浏览 4修改于2010-08-05得票数 13
回答已采纳
这是我得到的最后一个异常日志
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolE
浏览 0修改于2021-01-06得票数 0
我已经实现了一个ThreadPoolExecutor，它只对尚未使用的元素运行Consumer<T>。此代码使用Java 8。public class SingleExecutionThreadPoolExecutor<E> extends ThreadPoolExecutor {
private final Consumer
浏览 0提问于2014-04-03得票数 11
回答已采纳
我正在编写一个定制的ThreadPoolExecutor，其附加功能如下：
如果线程数大于核心池大小，但小于最大池大小和队列不满，并且没有理想的线程，则为任务创建一个新线程。
浏览 1修改于2013-10-23得票数 0
static final BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<Runnable>(); instance = new ThreadPoolExecutor(defaultCorePoolSize, defaultMaximumPoolSize, defaultKeepAliveTime, defaultTi
浏览 2提问于2011-11-23得票数 2
回答已采纳
Timer();在run方法中，我声明一个ThreadExecutorPool： new ThreadPoolExecutor(4, f.
浏览 15修改于2012-09-18得票数 0
这个管理器不断地轮询资源，当它相信资源被更新时，它就使用ThreadPoolExecutor来完成这项工作。这个线程池执行器有一个合理大小的阻塞队列，但是最大线程数量相当少。
浏览 1修改于2013-11-23得票数 0
我惊讶地发现： results = list(executor.map(f, iterable))with concurrent.futures.ThreadPoolExecutor(max_workers=4) as executor:
results =我根本不清楚concurrent.futures.ThreadPoolExecutor对象是如何工作的--天真地说，我更喜欢
浏览 409修改于2014-07-24得票数 84
回答已采纳
我正在尝试理解ThreadPoolExecutor中队列的行为。在下面的程序中，当我使用LinkedBlockingQueue时，每次只能向线程池提交一个任务。java.util.concurrent.SynchronousQueue;import java.util.concurrent.ThreadPoolExecutorSynchronousQueue<>();
ThreadFactory threadFactory = Executor
浏览 0修改于2018-09-28得票数 8
回答已采纳
我想为我的ThreadPoolExecutor设置一个超时。LinkedBlockingQueue(2);
private ThreadPoolExecutorexecutor = new ThreadPoolExecutor(CORE_POOL_SIZE, MAXIMUM_POOL_SIZE, QUEUE_KEEP_ALIVE_TIME_SECONDS,
浏览 1修改于2015-06-18得票数 0
我正尝试在Python语言中使用futures backport包中的ThreadPoolExecutor。然而，问题是所有线程都是同时执行的，因此不会发生实际的池化。with ThreadPoolExecutor(max_workers=5) as executor:
futures = [executor.submit(f, X, y) for t in
浏览 1修改于2014-07-24得票数 3
我创建了两个ThreadPoolExecutor，给他们两个任务列表，并在这两个任务中调用invokeAll方法。我看到，在第一个ThreadPoolExecutor的所有任务都完成之后，第二个ThreadPoolExecutor的任务就开始了。有没有办法并行启动它们？Object>>(); Thre
浏览 2提问于2021-05-16得票数 0
回答已采纳
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@56624074 rejected from java.util.concurrent.ThreadPoolExecutoractive threads = 300, queued tasks = 2000, completed tasks = 7979]
at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.reje
浏览 1提问于2015-02-12得票数 1
回答已采纳
腾讯云开发者
Copyright © 2013 - 2026 Tencent Cloud. All Rights Reserved. 腾讯云 版权所有
深圳市腾讯计算机系统有限公司 ICP备案/许可证号：粤B2-20090059 
粤公网安备44030502008569号
腾讯云计算（北京）有限责任公司 京ICP证150476号 | 京ICP备11018762号