- iOS/Objective-C 元类和类别
- objective-c - -1001 错误,当 NSURLSession 通过 httpproxy 和/etc/hosts
- java - 使用网络类获取 url 地址
- ios - 推送通知中不播放声音
请帮助我理解 newFixedThreadPool(或缓存)的内部流程
当我们写下面的语句时,ExecutorService e=Executors.newFixedThreadPool(3);
直到第3个execute方法,会创建3个线程,当调用第4个execute方法时,不会创建新线程,工作会等待一个线程空闲。
我不明白这一点“不会创建新线程,但工作将等待线程空闲”。我认为当runnable1将被赋予第一个创建的线程时,一旦runnable1的run方法完成,Thread1的run也将完成,thread1将无法调用runnable4的run方法。那么,java 如何设法仅用 3 个线程执行 5 个 Runnable。
最佳答案
仅供引用:这是一个非常简单的线程池实现。
class MyThreadPool implements java.util.concurrent.Executor
{
private final java.util.concurrent.BlockingQueue<Runnable> queue;
public MyThreadPool(int numThreads) {
queue = new java.util.concurrent.LinkedBlockingQueue<>();
for (int i=0 ; i<numThreads ; i++) {
new Thread(new Runnable(){
@Override
public void run() {
while(true) {
queue.take().run();
}
}
}).start();
}
}
@Override
public void execute(Runnable command) {
queue.put(command);
}
}
这不会编译,因为我没有处理 InterruptedException,并且在 真实 线程池中,您还需要处理给定 命令可能抛出的异常
,但它应该让您大致了解线程池的作用。
它创建一个队列和任意数量的工作线程。工作线程相互竞争以使用队列中的命令。该队列是一个 BlockingQueue
,因此只要队列为空,所有工作人员都会 hibernate 。
其他线程可能会产生新命令(即Runnable
对象),并调用execute(command)
方法将新命令放入队列。命令将由工作线程执行(即,将调用它们的运行方法),其顺序与它们入队的顺序大致*相同。
.run()
方法之前失去它的时间片。然后其他工作人员可以从队列中选择其他命令并在调度程序允许工作人员 A 再次运行之前执行它们。关于java - newFixedThreadPool 的内部工作,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/31123457/
我有创建 N 个线程(例如 50 个线程)的方法。这些创建的线程使用 Executors.newFixedThreadPool(20) 创建新线程。因此,50 * 20 = 1000 或更多可能会在应
我正在尝试诊断使用 WSO2 身份管理时遇到的问题。 package org.wso2.carbon.identity.mgt; import java.util.concurrent.Executo
这可能是一个有点老的问题。我对 Jboss 环境中的 ExecutorService 工作感到困惑。我使用了一些示例代码,其中我使用 ExecutorService 提交任务,一切完成后我关闭执行程序
请帮助我理解 newFixedThreadPool(或缓存)的内部流程 当我们写下面的语句时,ExecutorService e=Executors.newFixedThreadPool(3); e.
我正在努力弄清楚如何集中资源,我开始怀疑我的线程可能是问题所在(不是 100%,但一直在试验)。我想要做的事情的要点是创建一个服务器 channel 池,然后查看线程是否正在使用它们。我已经成功地获得
我要火了 Executors.newFixedThreadPool(100); 在一个主程序中,生产者提供工作的速度比消费者跟上的速度快。有没有办法查看 newFixedThreadPool 使用的底
我使用了 CopyOnWriteArrayList 集合对象,它包含 1000 个 URL。每个 URL 表示一个文件。 我想使用多线程池机制并行下载这些 URL 文件。 尝试使用以下代码:
对于特定操作,应用程序创建两个线程(执行不同的任务),主线程不会等待它。同样,对于某些情况,它也只能是一个线程。 如果我将其移至 Executors.newFixedThreadPool(),会有什么
我有一个服务方法,它需要并行调用三个方法,如下所示,以使 ServiceMethod() 运行得更快。 public void ServiceMethod() { ExecutorServic
我的英语不好。但我需要了解 newfixedthreadpool 的 . enter code here ExecutorService executorService = new FixedThre
我有一个要求,我需要处理一些当前现场表演的任务。这是一个计划任务,每分钟运行一次。 在任何给定的时刻,可以有任意数量的现场表演(尽管数量不能那么大,大约最多 10)。 所有的直播节目需要完成20多个功
我正在创建用户线程并将它们放入大小=5 的固定池中。我希望我的线程在 5 分钟内执行。这些线程在远程服务器上完成了一些数据库操作。但由于网络延迟,某些线程只是停止并等待远程服务器的响应,因此它会导致我
我对生产者-消费者模式的理解是,它可以使用生产者和消费者之间共享的队列来实现。生产者将工作提交到共享队列,消费者检索并处理它。也可以通过生产者直接提交给消费者来实现(Producer线程直接提交给Co
这个问题在这里已经有了答案: What does a "Cannot find symbol" or "Cannot resolve symbol" error mean? (18 个答案) 关闭
我正在使用 ConcurrentLinkedQueue 来存储计算步骤,并使用 Executors.newFixedThreadPool 创建的 ExecutorService 来执行它们。我的问题是
这个问题在这里已经有了答案: Executors.newCachedThreadPool() versus Executors.newFixedThreadPool() (8 个答案) 关闭 7 年
我正在尝试更改报告的执行并以并发方式完成。在“连续模式”下,执行测试需要 30 秒,而在使用并发模式时,我需要 27 秒(考虑到必须连续执行几个步骤,我对结果没意见)。 我仍然不明白的是这一行: Ex
正如它在 javadoc 中所说的那样 The threads in the pool will exist until it is explicitly shutdowned by Executor
我的程序应该在多线程下运行很长时间。我需要能够为线程设置超时,一旦线程终止,我想再次启动它。这是我的代码: @Test public void testB() throws Inter
我想启动很多任务来在 +-42Mio 记录的数据库上运行。我想以 5000 条记录/时间的批处理运行此程序(结果为 850 个任务)。我还想限制 java 开始为我执行此操作的线程数(最多 16 个)
我是一名优秀的程序员,十分优秀!