这是一个简单的线程练习。假设我有一个静态锁、一个web请求和一个线程队列线程。以下情况是否会导致问题(忽略代码本身的质量)：
static object locker = new object();
static MyObject obj = new MyObject();
public static void Update(){
lock(locker){
obj.Foo = "biz";
DoStuff();
}
}
public static void DoStuff(){
ThreadPool.QueueUserWorkIt
浏览 3提问于2013-10-10得票数 0
回答已采纳
许多应用程序都使用连接池来实现HTTP和JDBC的弹性调用。但是使用和配置这两种类型的池是非常不同的。这重复了实现两种常见的弹性模式的复杂性--例如超时、重试、缓存/警报回退、电路中断和监视。
在我看来，为HTTP和JDBC调用提供了配置和实现这些相同弹性模式的通用方法。
我的问题是：
理论上，Hystrix能否完全取代现有的HTTP和JDBC连接池？
如果是的话，这样做的利弊是什么？
替换它们完全降低了围绕这些连接池的复杂性--以及它们的伴随超时和验证查询属性等。然而，我不清楚Hystrix如何“保持”JDBC / HTTP连接的活力--从而避免昂贵的连接设置成本--而不将它
浏览 0提问于2015-06-10得票数 2
我在我们的应用程序中有几个泄漏的ThreadPools。这些泄漏的threadPools没有任何特定的名称，并使用java的默认命名约定。我们的应用程序启动的所有ThreadPools都有特定于应用程序的名称。看起来有一些依赖库正在启动这些threadPools。我能够重现这段代码，但我需要帮助才能找到启动这些threadPools的代码。任何帮助都是非常感谢的。应用程序stackDump泄漏的ThreadPool的堆栈转储。所有线程都处于相同的状态。
"pool-11-thread-1" #23 prio=5 os_prio=0 tid=0x00007f9f0c179000
浏览 3提问于2017-03-08得票数 0
我有一个应用程序，它出了问题，它的一些线程仍然处于WAITING阶段，一些运行正常。所有这些线程基本上都有相同的逻辑，并运行多个实例。 一旦我重新启动应用程序，应用程序就会重新开始工作。下面是两个线程，一个在TIMED_WAITING中，另一个永远处于WAITING阶段，除非我重启应用程序。 "Worker-pool-app-c4738262-bfec-47fb-9741-cc8712084508-StreamThread-4-0_14" #62 daemon prio=5 os_prio=0 tid=0x00007f766d71f800 nid=0x11b waiting
浏览 22提问于2020-04-24得票数 2
实际上，我正在研究Java并发性，并在8.3.1节“线程创建和Teardown”下看到了一条语句。下面是语句--“实现尝试将池保持在此大小，即使没有要执行的任务，并且除非工作队列已满，否则不会创建更多的线程。”为了验证同样的情况，我编写了一个小代码
package com.executor;
import java.util.concurrent.BlockingQueue;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurre
浏览 1提问于2014-01-05得票数 2
回答已采纳
1回答
我有一个线程池大小为20的应用程序，每当池中的所有线程耗尽时，线程就会永远处于阻塞状态，本质上就是将应用程序浏览掉。当部分填充池时，应用程序可以正常工作。线程转储显示，线程在运行异步可调用时被阻塞，但是没有任何关于可调用对象所在位置的堆栈信息。当池被填满时，我应该看什么来弄清楚为什么线程会进入阻塞状态。
转储还说没有检测到死锁。我使用executor服务进行线程管理。
线程：
Thread 25903: (state = BLOCKED)
- sun.misc.Unsafe.park(boolean, long) @bci=0 (Compiled frame; information may
浏览 3提问于2014-10-19得票数 0
在使用应用程序时，我遇到了这个异常。这不是一种特定的情况。有时打开片段，有时将文本设置为textview。所以我不能正确地理解这个问题。
你能对此说点什么吗？
这是我得到的最后一个异常日志
Task android.os.AsyncTask$SerialExecutor$1@373f483 rejected from java.util.concurrent.ThreadPoolExecutor@b9965c7[Running, pool size = 9, active threads = 9, queued tasks = 128, completed tasks = 31]
java.
浏览 0提问于2021-01-06得票数 0
我试图运行卡夫卡生产者使用卡夫卡-客户api。我有多个生产者在运行不同的线程，每个线程都试图将数据写入kafka。问题是，当我增加并行运行的线程数时，得到了kafka的中断异常。例如，如果并行运行20个线程，它不会抛出任何异常，但当我并行运行100个线程时，会得到以下异常：
线程“池-910-线程-1”org.apache.kafka.common.errors.InterruptException: java.lang.InterruptedException中的异常
在org.apache.kafka.clients.producer.KafkaProducer.close(KafkaP
浏览 0提问于2018-12-26得票数 1
每当我们接到更多的电话时，我就会接到java.util.concurrent.RejectedExecutionException。
我们已经将coreSize定义为10，maximumSize定义为25，但是我们得到了10个线程本身的异常。我们应该在25个线程之后得到这个异常，对吗？我有遗漏什么吗？你能帮我修一下吗？
hystrix.threadpool.servicename.coreSize=10
hystrix.threadpool.servicename.maximumSize=25
异常跟踪：
java.util.concurrent.RejectedExecutionExcept
浏览 4提问于2020-09-02得票数 1
我的消费者不像我期望的那样工作。下面是我实际程序中发生的事情的。
预期：
打印In finally!
打印About to print stacktrace
打印NullPointerException堆栈跟踪。
Actual:
打印In finally!
Hang，in sun.misc.Unsafe
程序：
import java.lang.Thread.UncaughtExceptionHandler;
import java.util.concurrent.ExecutorService;
import java.ut
浏览 4提问于2013-09-27得票数 1
回答已采纳
1回答
我有一个基于Windows2012的服务器，运行Tomcat8和Java7实例，作为使用wrapper.exe的windows服务。
在我将我的服务迁移到64位JVM后，我的服务关闭时间比平时更长，之前的关闭时间大约是8-10秒，现在是1分钟。
以下是在我触发进程关闭的10秒后看起来仍然活着的线程。请让我知道是什么真正触发了这件事。
13-Dec-2015 17:12:37.404 INFO [Thread-15] org.apache.coyote.AbstractProtocol.pause Pausing ProtocolHandler ["http-nio-7000"]
浏览 19提问于2015-12-18得票数 1
1回答
我正在分析一个应用程序挂起，通过线程转储，我有90%的工作线程处于这种状态：
“池-3-线程-352”#13082 prio=5 os_prio=0 tid=0x00007ff6407fc800 nid=0x1e94等待条件为0x00007ff5a53b4000
java.util.concurrent.SynchronousQueue$TransferStack) java.util.concurrent.locks.LockSupport.parkNanos(LockSupport.java:215) at java.util.concurrent.SynchronousQueue$Tr
浏览 2提问于2017-12-15得票数 6
3回答
我有一个tomcat webapp，其中我使用java执行程序来执行一些可运行的程序。
首先，我从我的executor实例分配executor服务，如下所示：
executorService = Executors.newFixedThreadPool(nThreads, new MyThreadFactory(threadFactoryName))
然后，我使用executor服务启动任务：
executorService.execute(new MyRunnable);
然后，它似乎起作用了。但我的问题是，我正在追踪某种泄漏，在运行服务器一段时间后，我得到了这个错误：
Caused by:
浏览 1提问于2012-12-14得票数 0
回答已采纳
2回答
我们在CEP上看到内存错误。线程转储显示大约有32000个线程在监视器上休眠。此外，尽管CEP选项指定在外部内存上生成HeapDump，但我们没有看到任何生成的堆转储。请指点。(CEP -Xms256m -Xmx1536m )
1)卡桑德拉号在这一CEP上被禁用
2) CEP版本为2.1.0
3) CEP由WSO2 ESB (使用)负责。
4)除了向CEP发送实际有效负载数据外，ESB还向CEP发送周期性心跳(每15个ec)。
5)我们还在ESB上配置了JMX代理，它每15分钟监视一次CEP (cpu/内存线程)。
6)即使指定了-XX:HeapDumpPath=参数，也没有找到堆转储
在
浏览 3提问于2013-06-10得票数 4
回答已采纳
1回答
在我运行的一个jetty应用程序中，我有很多这样的线程。我想知道我怎么才能调试出问题所在。
2011-11-30 18:25:52
Full thread dump OpenJDK Client VM (19.0-b09 mixed mode, sharing):
"pool-34193-thread-1" prio=10 tid=0xac634800 nid=0x515 waiting on condition [0xaaf2c000]
java.lang.Thread.State: TIMED_WAITING (parking)
at sun.misc.Un
浏览 2提问于2011-12-01得票数 0
回答已采纳
2回答
我可以在java中创建一个新的线程池，并使用和方法在其上执行任务。
是否有一个‘默认’线程池，我可以重用在我的java程序中的所有执行器服务？还是我只需要创建一个包含默认线程池的单例？C#有一个默认线程池，在调用方法时运行任务。
浏览 6提问于2015-11-23得票数 12
回答已采纳
我的应用程序负载很重，我在下面的日志中
sudo -u tomcat jstack <java_process_id>
下面的线程正在消耗卡夫卡的信息，并且被卡夫卡卡住了。由于这个线程处于等待状态，因此不再消耗卡夫卡消息。
"StreamThread-3" #91 daemon prio=5 os_prio=0 tid=0x00007f9b5c606000 nid=0x1e4d waiting on condition [0x00007f9b506c5000]
java.lang.Thread.State: WAITING (parking)
at s
浏览 0提问于2018-03-18得票数 0
我们已经将基于Spring批处理的应用程序更新为Spring 4.x和Boot2.0.x的最新版本，并且HikariCP MySQL连接池出现了一些问题。
如果我使用10个连接的默认maxPoolSize，并且使用5个线程，每个线程都启动一个简单的虚拟作业，那么工作正常。(使用SimpleJobLauncher)。所有乔布斯都会立即启动，此后，HikariCP池已经使用了所有返回的连接。
当我做同样的事情时，这个问题就开始了，但是接下来我用了11个线程。然后，我看到应用程序挂起直到连接超时，然后作业被启动。我预计头10份工作将开始，第一份工作完成后，第11份工作.
在工作开始之前，我看到：
H
浏览 0提问于2019-01-21得票数 2
2回答
新的提交Java并发框架的方法。想知道当我调用submit还是调用get时线程是否被执行？研究了甲骨文的官方文件，但找不到太多的信息。谢谢。
我指的是下面的样本，
package de.vogella.concurrency.callables;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorS
浏览 1提问于2016-06-01得票数 2
回答已采纳
2回答
在利用Java的阻塞套接字(我打算独立读写)的同时，我看到我的两个选项要么为每个操作指定一个单独的线程，要么使用setSoTimeout()轮询超时。
在这两个实现之间做出选择似乎是内存(线程)与CPU时间(轮询)之间的权衡。
我看到在调度程序和许多线程的上下文切换方面可能出现的缩放问题，这些问题可能会超过CPU花费的轮询时间，以及在从单个线程读写之间可能出现的延迟，这取决于接收到的数据包的大小。或者，一个小线程池可以与几个套接字的轮询结合使用，如果适当的话。
除了将Java的NIO作为一个替代方案(这超出了这个问题的范围)之外，我是否正确地理解了可用于处理阻塞套接字的选项？
浏览 6提问于2017-03-11得票数 0
回答已采纳
1回答
我正在尝试使用异步java客户端进行异步读取。我指的是中提到的示例
我使用下面的get读取get(BatchPolicy策略、RecordArrayListener侦听器、Key[]密钥)
这在请求很少的情况下工作得很好，但是在发出大约50000个请求之后，线程会进入无限期等待状态。下面是其中一个线程的堆栈跟踪。
"pool-11-thread-1" - Thread t@56
java.lang.Thread.State: WAITING
at sun.misc.Unsafe.park(Native Method)
- parking to wait f
浏览 1提问于2016-12-15得票数 2
我的tomcat应用服务器中的线程计数是每天都在增长。
当我把线程转储做分析的时候。
我发现430个线程中有307个线程处于这种状态.
样本堆栈跟踪
"pool-283-thread-1" #2308674 prio=5 os_prio=0 tid=0x000000000a916800 nid=0x1101 waiting on condition [0x00002aec87f17000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
- p
浏览 5提问于2016-10-17得票数 16
回答已采纳
我在java中创建了一个内核池大小为40的线程池。
假设当前它只有10个线程。如果属于这个线程池的一个线程创建了一些新的线程，它们是只属于这个线程池的一部分，还是独立的？
浏览 0提问于2017-07-18得票数 0
1回答
我正在创建一个在线评委，为此我希望提交的java代码不应该使用CPU的并行处理。因此，我希望禁用Java应用程序的多线程。 发送到服务器的应用程序将只是一个单独的java文件，它将被编译成字节码，然后执行，假设应用程序正在使用线程，它正在创建线程，应用程序应该通过抛出一些异常来关闭应用程序，比如权限被拒绝，比如错误。
浏览 12提问于2019-06-07得票数 0
我开始使用部署在weblogic 10.3.4中的get服务出现问题。在这个webservice中，我创建了一个新的可调用类，用于处理命令：
public class CommandById implements Callable<DataBean> {
private String docId = null;
private String folder = null;
public CommandById(final String docId, final String folder) {
this.docId = docId;
thi
浏览 1提问于2013-12-03得票数 0
回答已采纳
在jboss服务器中遇到此错误：
由以下原因引起：
java.util.concurrent.RejectedExecutionException: Task java.util.concurrent.FutureTask@542f7a70 rejected from java.util.concurrent.ThreadPoolExecutor@42XXXXXX[Running, pool size = 10, active threads = 10, queued tasks = 0, completed tasks = 64491]
at java.util.concurrent
浏览 1提问于2020-06-30得票数 0
1回答
Java:线程保持锁而不需要它
、、、、
最近，我遇到了一个非常奇怪的多线程死锁。当线程实际上从未在其堆栈跟踪的任何方法中请求锁时，它似乎持有锁。下面是必要的堆栈跟踪：
Found one Java-level deadlock:
=============================
"pool-1-thread-2":
waiting to lock monitor 0x000000000751fc20 (object 0x00000000f55e2960, a de.ntcomputer.minecraft.elevators2.plugin.implementation.extension.CraftE
浏览 0提问于2013-10-20得票数 2
1回答
这是个简单的问题。您是否可以像在常规Java应用程序中一样，在play框架上有意地在单独的线程中运行进程？我似乎找不到这个答案。
我目前有一个Java桌面应用程序，它使用用C编写的CPU密集型机器学习工具来查找图像中的特性。使用桌面上的常规Java，我可以同时运行多个实用程序实例，每个实例都在自己的线程中，使图像处理速度更快。在一个有128个逻辑核心的服务器上，它只需要几秒钟，而不是几分钟。我想重新设计我的桌面系统，允许它访问大型服务器的资源。现在我正在努力找出最好的方法来做这件事，我正在研究的一个选择就是--基本上把这个系统放到一个网页上。
浏览 1提问于2015-10-22得票数 3
我有一个spring引导(1.5.2) web应用程序，运行在tomcat (8.5)作为一个唯一的web应用程序。JVM (openjdk 1.8.0_181)中的线程总数几乎(虽然不是完全的)以恒定的速度单调地增加，从开始时的几百个增加到每周大约300个。到那时，大多数线程堆栈跟踪看起来如下所示：
WAITING Thread[pool-917-thread-1,5,main]
sun.misc.Unsafe.park(Native Method)
java.util.concurrent.locks.LockSupport.park(LockSupport.java:175)
java.
浏览 0提问于2019-01-18得票数 2
我阅读了所有现存的话题，但我没有找到任何解决问题的办法。我用VisualVM监视我的玻璃鱼服务器，我注意到了一些奇怪的行为。这是截图：
java.lang.Thread.State: WAITING
at sun.misc.Unsafe.park(Native Method)
- parking to wait for <3cb9965d> (a java.util.concurrent.locks.AbstractQueuedSynchronizer$ConditionObject)
at java.util.concurrent.locks.L
浏览 3提问于2015-05-04得票数 3
1回答
我正在开发一个支持库，它通过注释声明并发聚合。
但我有一个很难解决的问题。
当项目中使用了大量的ThreadLocal时，并发聚合将无法工作，因为ThreadLocal的值在多线程中丢失。
例如
public class RequestContext {
private static ThreadLocal<Long> TENANT_ID = new ThreadLocal<>();
public static Long getTenantId() {
return TENANT_ID.get();
}
public
浏览 1提问于2019-07-23得票数 1
我发现JPA有一些奇怪的行为。在某些情况下，我们得到了一个错误
"Timed out waiting for a free available connection."
at com.jolbox.bonecp.DefaultConnectionStrategy.getConnectionInternal(DefaultConnectionStrategy.java:88) ~[bonecp.jar:na]
该行的源代码可在以下网站获得：
我做了一个简单的研究，发现：
Play2在akka中使用了演员模型。
Play2使用bonecp作为数据库连接池。
对于pr
浏览 0提问于2013-12-29得票数 1
我正在为Java语言编写一个编译器，我希望它能够并行编译多个文件。
我的类Compiler.java具有构造函数Compiler(String fileName)和方法compile()，所以要在我的主目录中编译一个文件，我所做的就是：
Compiler c1 = new Compiler("file1.c");
c1.compile();
我想要做的是对一个文件列表(比如"file1.c“、"file2.c”、"file3.c“)并行执行c1.ile()、c2.ile()、c3.ile() (c'i‘是文件’i‘的编译器)。
我仍然是Java.
浏览 5提问于2021-12-28得票数 -1
回答已采纳
1回答
有人建议我使用Executors.newCachedThreadPool()，它将能够解决过度产生线程时的问题。
但是，当线程的数量增长超过某个点时，仍然会出现错误。有没有办法让线程在等待系统资源可用时自己等待？
[WARN ] Thread table can't grow past 16383 threads.
[ERROR][thread ] Could not start thread pool-1-thread-16114. errorcode -1
Exception in thread "Main Thread" java.lang.Error: err
浏览 1提问于2011-07-31得票数 0
回答已采纳
1回答
Java并行流关闭线程
、、、
我编写了一个使用Java流的方法，它简单地遍历对象列表并返回true/false是满足一定条件的
Java方法：
boolean method(SampleObj sampleObj) {
List testList = invokeSomeMethod();
int result = testList
.parallelStream()
.filter(listObj -> (listObj.getAttr() = 1))
.count(listObj -> listObj.isAttr4()
浏览 3提问于2017-02-28得票数 7
回答已采纳
我最近在使用Java 11的http客户端，在这个客户端中，如果需要，我们可以传递一个执行器，否则它将使用默认的executor服务。
我试图搜索默认的执行器线程池大小。但找不到尺码。发送(.)方法内部调用sendAsync(.)然后使用可完成的未来的get()阻止调用线程。
我在寻找同步调用，但似乎它使用的是带阻塞的异步方法。
所以问题是
http客户端中使用的默认线程池大小是多少。
什么时候我应该传递我自己的线程池。
浏览 2提问于2021-12-16得票数 0
我有一个Springboot Kotlin应用程序运行在AWS ECS/EC2中，其中有些代码是由我的前任编写的。在服务器上运行一段时间之后，它将运行到OutOfMemoryError中。我不熟悉ReactiveX和线程，所以想在这方面寻求一些帮助。
我从错误日志中看到，它应该与Observable.blockingForEach方法相关吗？
listOfKeys是一个5到50项的有限来源，所以它不应该是由于背压？
当OutOfMemoryError发生时，我还粘贴了线程转储。
myMethod内部代码
Observable.fromIterable(listOfKeys)
浏览 4提问于2021-12-02得票数 0
回答已采纳
1回答
我正在使用java服务器应用程序中的jWebsocket库执行一些压力测试(每分钟有数千个连接)，一段时间后，这个过程完全被jWebsocket线程填满，如下所示：
"jWebSocket TCP-Engine NIO writer" prio=10 tid=0x0000000000bf6000 nid=0x2eb9 waiting on condition [0x00007f1533bd9000]
java.lang.Thread.State: WAITING (parking)
at sun.misc.Unsafe.park(Native Method)
浏览 3提问于2016-11-18得票数 0
2回答
在试图比较用Java和Scala实现的同一个简单问题的“执行特性”时，我发现Java版本中的线程类运行在名为 thread -x的线程上，而Scala参与者则运行在名为Thread-x的线程上。非线程Java类和非参与者Scala类始终运行在主线程上。
下面的日志片段将说明：
Java version: Scoord thread class running in Thread[Thread-0,5,main]
Semaphore class running in Thread[main,5,main]
Scala version: Scoord actor ru
浏览 0提问于2013-10-17得票数 5
我是个新手，所以这个问题可能太天真了。我找了一段时间，但没有找到解决方案。
基本上:在WAS控制台中定义一个线程池，将其命名为"ac.work.threadpool“
但是在java代码中，在获取上下文之后，如何查找它。
像这样？：
ctx.lookup("java:ac.work.threadpool")
但不能工作
浏览 2提问于2016-02-13得票数 1
4回答
Java8的线程似乎比系统属性java.util.concurrent.ForkJoinPool.common.parallelism.指定的线程更多。这些单元测试表明，我使用自己的ForkJoinPool使用所需的线程数处理任务，但在使用parallelStream时，线程数量高于预期。
import org.junit.Test;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.ForkJoinPool;
import java.util.concurrent.TimeUnit;
浏览 6提问于2017-02-28得票数 4
回答已采纳
在春季引导应用程序(2.1.4-发行版)中，使用以下TaskExecutor配置
@Primary
@Qualifier("threadPoolTaskExecutor")
@Bean
public TaskExecutor threadPoolTaskExecutor() {
final ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
executor.setCorePoolSize(10);
executor.setMaxPoolSize(100);
浏览 4提问于2019-05-02得票数 0
回答已采纳
3回答
在我的项目中，我有一个服务器应用程序和一个客户端应用程序，其中一个中介application.Client通过中介application.The中介应用程序与服务器通信，反过来又连接到服务器应用程序。
对于它需要连接到服务器应用程序的每个客户端。我知道，对于每个客户端请求，打开一个新的连接都是昂贵的。我想我可以利用连接池的概念。如何在java中实现此功能。感谢您的指点...
感谢并致以问候
阳光充足的。
浏览 0提问于2011-05-19得票数 1
回答已采纳
我创建了一个线程池，并赋予它50个任务来连接到服务器。因此，一旦完成连接，发送一些数据，然后断开连接。它还将读取超时设置为5秒(当然是5000长)。我甚至将线程池设置为1，然后在linux上启动线程池，并运行htop (一个更好的top版本)来检查CPU的使用情况。我始终在100%的时间内看到我的一个核心(2台核心机器)。我用hprof (-agentlib:hprof=cpu=samples,interval=20,depth=3)对此进行了分析，socket.connect()为99%。
下面是我发现的奇怪之处，难道阻止IO阻止(因此等待)的意义不是吗？我的JDK (来自java -ver
浏览 2提问于2010-06-05得票数 5
1回答
我有一个spring引导应用程序运行，默认嵌入式tomcat (使用tomcat连接池)。它的生产和运行良好。我使用mysql作为我的数据库。
现在，我正在测试环境中做一些压力测试，并试图看看如果我从embedded Tomcat切换到embedded Undertow，是否会得到任何明显的好处。由于请求处理的异步特性，人们声称通过这样做可以明显地提高吞吐量。
我知道如何排除tomcat和添加下面的引导应用程序。在这样做之后，我尝试运行我的压力测试脚本，大约每秒生成500个请求，在这个负载下运行5分钟，看看它是如何工作的。当我这样做时，在最初的几秒钟之后，我开始得到jdbc异常，如下所示。
浏览 1提问于2017-07-27得票数 1
我有一个执行器，它负责消费来自ArrayBlockingQueue的消息。
new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<>(1),
r -> {
return new Thread(r, "Request-Queue-Drainer");
});
请求-队列-链接线程处于等待状
浏览 2提问于2016-06-22得票数 5
回答已采纳
1回答
MQTT (莫斯科)连接池？
、、、、
您对Java中的Mosquitto连接池有什么建议？我们在建立每个连接上浪费了太多的时间，所以我们认为某种形式的重用会更好。
浏览 1提问于2015-08-20得票数 0
回答已采纳
1回答
正在创建具有执行器的消息监听器池
、、、、
我必须在一个独立的应用程序中创建一个消息侦听器(针对某些jms主题)。因为我收到的每一条消息都要做一些处理。
这种行为延缓了我的整个表演。
因此，我决定为我的消息监听器创建一种池。(与ejb中的MDB相同)。
我开始这样使用Executor类(Java)：
import java.util.concurrent.Executor;
import java.util.concurrent.Executors;
private Executor threadPool = Executors.newCachedThreadPool();
@Override
public
浏览 0提问于2012-10-28得票数 1
回答已采纳
1回答
我们已经编写了一个控制台应用程序(将用作服务)，该应用程序启动几个工作线程，用于处理通过mina传入的请求。当在特定的网络端口上接收到停止信号时，应用程序离开主循环。这是停止服务的预定方式。这很好，但是当接收到停止信号时，应用程序的进程不会立即终止(最多需要5分钟)。我们通过日志消息验证了主函数是否按预期快速保留，并且应用程序创建的所有线程也将终止。但是应用程序继续运行。
在离开主函数之前仍在运行的线程是：
Signal Dispatcher (java.lang.Thread)
Finalizer (java.lang.ref.Finalizer$FinalizerThread)
Aband
浏览 2提问于2015-05-08得票数 8
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
实时音视频活动推荐
腾讯云开发者
