是否有两个ExecutorServices可以共享一个线程池？
在云计算领域，ExecutorService 是一个用于管理和执行异步任务的接口。线程池是一个具有固定大小的线程集合，可以在其中执行多个任务。
是的，可以有两个 ExecutorService 共享一个线程池。在 Java 中，可以使用 Executors 类中的静态方法创建线程池，并将其作为参数传递给 ExecutorService 的实现类。例如，可以使用以下代码创建一个固定大小的线程池：
ExecutorService executorService1 = Executors.newFixedThreadPool(4);
ExecutorService executorService2 = Executors.newFixedThreadPool(4);然后，可以将这两个 ExecutorService 实例共享一个线程池，如下所示：
ExecutorService executorService1 = new ThreadPoolExecutor(2, 4, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());
ExecutorService executorService2 = new ThreadPoolExecutor(2, 4, 60L, TimeUnit.SECONDS, new LinkedBlockingQueue<Runnable>());在这个例子中，两个 ExecutorService 实例都使用相同的线程池。这意味着，当一个 ExecutorService 提交任务时，另一个 ExecutorService 也可以使用相同的线程池执行任务。
需要注意的是，当两个 ExecutorService 共享一个线程池时，它们共享线程池中的资源，包括线程和任务队列。因此，需要确保在共享线程池时，不会出现死锁或资源争用的情况。
总之，可以有两个 ExecutorService 共享一个线程池，这可以提高资源利用率和执行效率。但是，需要注意线程池的管理和资源分配，以避免出现问题。
相关·内容
14回答
无法创建有大小限制的缓存线程池？
java、multithreading、concurrency、executorservice、threadpoolexecutor
似乎不可能创建一个有线程数量限制的缓存线程池。
下面是如何在标准Executors.newCachedThreadPool库中实现静态Java：
public static ExecutorService newCachedThreadPool() {
return new ThreadPoolExecutor(0, Integer.MAX_VALUE,
60L, TimeUnit.SECONDS,
new SynchronousQueue<R
浏览 18提问于2009-11-26得票数 136
回答已采纳
2回答
ThreadPoolExecutor类似于Executors.cachedThreadPool，但具有最大线程和队列
java、multithreading、asynchronous、concurrency、java.util.concurrent
这是缓存的线程池：
new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>());
这是固定的ThreadPoolExecutor：
new ThreadPoolExecutor( 0, 20, 60L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());
第一个可以创建INTEGER.MAX_VALUE线程数，这在我的情况下是不理想的。
第二个，是不正确的。对
浏览 6提问于2015-01-16得票数 1
回答已采纳
2回答
线程数量有限的执行器按需执行
java、java.util.concurrent、threadpoolexecutor
我正在寻找一个ExecutorService，它根据需要创建线程，最多可达到预定义的限制，并在保持活动时间之后销毁空闲线程。
以下构造函数创建一个具有固定线程计数的ThreadPoolExecutor：
// taken from Executors.newFixedThreadPool()
new ThreadPoolExecutor(nThreads, nThreads,
0L, TimeUnit.MILLISECONDS,
new LinkedBlock
浏览 3提问于2013-07-30得票数 2
回答已采纳
3回答
我需要关于java中ExecutorService的建议。
java、concurrency、executorservice
嘿，我为ExecutorService的java文档选择了这个例子。我想确认一下这段代码的流程，Executors.newFixedThreadPool会创建一个线程池(我猜)。所以serversocket将等待一个连接，一旦它获得一个连接，它就会启动一个线程，所以现在poolsize减少了1。一旦线程完成执行，poolsize将再次增加1，不是吗？线程会放弃它使用的资源吗？
class NetworkService implements Runnable {
private final ServerSocket serverSocket;
private final ExecutorSe
浏览 12提问于2012-08-30得票数 1
1回答
使用maxPoolSize扩展ThreadPoolExecutor；为什么池不动态增加其大小？
java、multithreading、performance、parallel-processing、threadpool
作为初学者，我正在学习java中的线程和并发包，我已经阅读了有关ThreadPoolExecutor的文档，以了解getPoolSize()、getCorePoolSize()、getMaxPoolSize()之间的区别，并尝试在代码中实现相同的内容。
位背景
据我理解，Executors.newFixedThreadPool(3)使用corePoolSize=3创建了一个池，当我们继续通过池执行任务时，线程将被创建到3，然后当底层队列大小达到100并且新任务仍然被提交时，maxPoolSize就出现在图片中，线程现在被缩放到从corePoolSize到达maxPoolSize。
public
浏览 3提问于2020-12-30得票数 3
回答已采纳
1回答
RXJava线程优先级
android、multithreading、threadpool、rx-java
我使用以下方法获取订阅的ExecutorService：
public static ExecutorService getThreadPoolExecutorService(int threads)
{
int NUMBER_OF_CORES = Runtime.getRuntime().availableProcessors();
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
NUMBER_OF_CORES * 2,
NUMBER_OF_CORE
浏览 3提问于2016-02-22得票数 3
3回答
Executor不按预期处理任务。
java、concurrency、executor
如果运行持久任务，如果第一个任务未完成，执行器将不会启动新线程。有谁能帮我理解一下为什么，以及如何解决这个问题？
import java.util.concurrent.ExecutorService;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import org.junit.Test;
public class TestExecutor {
@Test
浏览 5提问于2013-07-27得票数 10
回答已采纳
3回答
ExecutorService有一个最大的大小
java、multithreading
有没有办法通过一个庞大的数据库，并并行地应用一些作业作为条目的工作台？我试过使用ExecutorService，但是我们必须关闭()才能知道池的大小.
所以我最好的解决办法是：
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class TestCode
{
private static L
浏览 5提问于2017-06-29得票数 3
回答已采纳
3回答
如何使用线程池为生产者-消费者解决方案创建动态使用者任务？
java、multithreading
我正在尝试实施一个生产者-消费者解决方案。
但我不想使用固定数量的消费线程。相反，我想创建一个新的消费线程，如果我的eventQueue是满的。
我已经创建了一个ExecutorService，但是由于我只有一个EventConsumerTask实例，所以它只为这个任务创建了一个线程。
LinkedBlockingQueue<String> eventQueue = new LinkedBlockingQueue<>(50);
ExecutorService es = new ThreadPoolExecutor(5, 20, 60L, TimeUnit.SECOND
浏览 0提问于2019-10-17得票数 0
回答已采纳
5回答
当tomcat关闭时，如何关闭spring bean中的ThreadPoolExecutor？
java、spring、javabeans、shutdown
我在一个spring bean中创建了一个threadpoolexecutor，所以我需要在tomcat关闭时关闭这个executor。
public class PersistBO implements InitializingBean {
private ThreadPoolExecutor executer;
public void shutdownExecutor() {
executer.shutdown();
}
@Override
public void afterPropertiesSet() throws Exception {
taskQue
浏览 0提问于2012-01-31得票数 2
回答已采纳
1回答
为什么我不能在Java中第二次将任务添加到线程池中？
java、multithreading、threadpool、threadpoolexecutor
我创建了一个线程池来处理任务，在处理完任务后，我发现我无法添加和启动其他任务？怎么修呢？如果我通过executor = new ThreadPoolExecutor(3, 3, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(), new NamedThreadFactory("timeOutThread"));更改执行程序，如果任务由于超时而取消，它将运行OK.But，这会导致内存泄漏吗？
ExecutorService executor = new ThreadPoolExecut
浏览 5提问于2022-06-21得票数 3
回答已采纳
2回答
当线程池大小小于执行的任务数时，使用newFixedThreadPool的多线程程序不例外地运行
java、multithreading、concurrency、executorservice
package com.playground.concurrency;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.LinkedBlockingQueue;
public class MyRunnable implements Runnable {
private String taskName;
public String getTaskName() {
return taskName;
浏览 1提问于2020-01-04得票数 0
回答已采纳
2回答
如何使用ExecutorService执行具体顺序的线程？
java、multithreading、concurrency
在我的程序中，我有几个命令，这些命令由命令执行器类执行。我需要使用ExecutorService逐一执行4条命令(在创建新命令之前不要向用户显示)。
执行环境：
public class ConcurrentCommandExecutionEnvironment {
private static final int POOL_SIZE = 4;
private static final Logger log = Logger.getLogger(ConcurrentCommandExecutionEnvironment.class);
public void rea
浏览 1提问于2021-05-06得票数 0
回答已采纳
1回答
SynchronousQueue in ThreadPoolExecutor
java、multithreading、threadpool、threadpoolexecutor、blockingqueue
我正在尝试理解ThreadPoolExecutor中队列的行为。在下面的程序中，当我使用LinkedBlockingQueue时，每次只能向线程池提交一个任务。但是，如果我用LinkedBlockingQueue替换SynchronousQueue，我可以立即将所有5个任务提交到池中。在这种情况下，SynchronousQueue与LinkedBlockingQueue有什么不同？
Java程序:
import java.util.concurrent.Executors;
import java.util.concurrent.LinkedBlockingQueue;
import java
浏览 0提问于2017-12-05得票数 8
回答已采纳
2回答
在这种情况下，我的Java线程真的会死吗？
java、multithreading、tomcat
首先，我想告诉大家，在发布这篇文章之前，我已经检查了和。
这一切都是关于Java中的线程的。我怀疑我的代码(服务器端)中新插入的线程是导致"java.lang.OutOfMemoryError: Java heap space“错误的原因，大约每隔2天我就会收到一次错误(似乎这是谷歌的机器人来我的应用程序进行SEO的时候)……
在使用线程之前，我曾经让我的tomcat服务器在128MB上运行，没有问题。插入线程后，我的tomcat服务器在350MB上运行，需要每两天重新启动一次。
一般来说，下面是我的线程模式：
public Boolean sendEmailInThread(Stri
浏览 1提问于2014-07-23得票数 1
2回答
对于ThreadPoolExecutor，allowCoreThreadTimeOut和零核心线程之间有什么区别？
java、multithreading、threadpoolexecutor
阅读了的文档之后，我搞不懂下面的示例用法之间有什么区别：
零核心线程和十个最大线程，其中后一个线程在2秒后超时：
ThreadPoolExecutor executor = new ThreadPoolExecutor(
0, // core threads
10, // max threads
2000, TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>(),
Executors.defaultThreadFactory()
);
10个
浏览 1提问于2019-04-27得票数 4
回答已采纳
1回答
使用ThreadPoolExecutor()只运行一个线程
java、multithreading、threadpoolexecutor
我使用ThreadPoolExecutor()为我的应用程序运行多个线程。我希望使用单线程进行测试，因此在本例中设置了nb_threads =1。但是我不确定它是否正确，所以你能帮我只取一条线吗？
这是我的部分代码：
private ThreadPoolExecutor executor = null;
public static int NB_THREADS_MAX = 8;
public void submit(Runnable inRunnable) {
if (executor == null) {
/*Choice exactly the numb
浏览 2提问于2015-05-13得票数 2
回答已采纳
2回答
workQueue的大小能比maximumPoolSize大吗？
java、threadpoolexecutor
我们有ThreadPoolExecutor，它的初始化看起来如下：
LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>();
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(maxThreads, maxThreads, 50000L, TimeUnit.MILLISECONDS, queue);
maxThreads值为200，但总有一段时间queue.size() > 200。为什么会这样？
浏览 8提问于2016-02-22得票数 0
回答已采纳
3回答
Executor和scheduleWithFixedDelay()
java、multithreading、executorservice
这是我的任务。我有一个类中的静态作业队列和一个将作业添加到队列中的静态方法。有n个线程从队列中轮询并执行拉出的作业。我需要在一个间隔内同时进行n个线程轮询。也就是说，所有三个人都应该每5秒进行一次投票，然后找工作。
我有这个：
public class Handler {
private static final Queue<Job> queue = new LinkedList<>();
public static void initialize(int maxThreads) { // maxThreads == 3
Sched
浏览 3提问于2013-11-26得票数 1
回答已采纳
3回答
如何“杀死”执行器中的线程？
java、multithreading、memory-leaks
我有一个tomcat webapp，其中我使用java执行程序来执行一些可运行的程序。
首先，我从我的executor实例分配executor服务，如下所示：
executorService = Executors.newFixedThreadPool(nThreads, new MyThreadFactory(threadFactoryName))
然后，我使用executor服务启动任务：
executorService.execute(new MyRunnable);
然后，它似乎起作用了。但我的问题是，我正在追踪某种泄漏，在运行服务器一段时间后，我得到了这个错误：
Caused by:
浏览 1提问于2012-12-14得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储活动推荐
腾讯云开发者
