使用JMS线程池协程重复的线程
基础概念
JMS（Java Message Service）是Java平台中用于处理消息传递的标准API。它允许应用程序之间通过消息进行异步通信。线程池是一种管理线程的机制，通过重用线程来减少创建和销毁线程的开销。协程是一种轻量级的线程，可以在单个线程内并发执行多个任务。
相关优势
- 性能提升：通过线程池和协程的重用机制，减少了线程创建和销毁的开销，提高了系统的响应速度和吞吐量。
- 资源管理：线程池可以有效地管理和控制并发线程的数量，避免系统资源被过度消耗。
- 简化编程模型：协程提供了一种更简单的并发编程模型，使得编写异步代码更加容易。
类型
- 固定大小的线程池：线程池中的线程数量是固定的，适用于任务数量相对稳定的场景。
- 可缓存的线程池：线程池中的线程数量可以根据需要动态调整，适用于任务数量波动较大的场景。
- 单线程的线程池：线程池中只有一个线程，适用于需要顺序执行任务的场景。
应用场景
- Web服务器：处理大量并发请求。
- 消息队列：处理异步消息传递。
- 批处理系统：处理大量数据任务。
问题及原因
在使用JMS线程池和协程时，可能会遇到线程重复的问题。这通常是由于以下原因造成的：
- 线程池配置不当：线程池的大小设置不合理，导致线程被频繁创建和销毁。
- 协程调度问题：协程调度器没有正确管理协程的生命周期，导致协程被重复执行。
- 资源竞争：多个线程或协程竞争同一资源，导致线程重复执行。
解决方法
- 合理配置线程池：根据系统的负载情况，合理设置线程池的大小。可以使用
Executors类提供的工厂方法来创建线程池。 - 合理配置线程池：根据系统的负载情况，合理设置线程池的大小。可以使用
Executors类提供的工厂方法来创建线程池。 - 正确管理协程：确保协程调度器正确管理协程的生命周期，避免协程被重复执行。可以使用
CompletableFuture来管理异步任务。 - 正确管理协程：确保协程调度器正确管理协程的生命周期，避免协程被重复执行。可以使用
CompletableFuture来管理异步任务。 - 避免资源竞争：使用同步机制（如
synchronized关键字或Lock接口）来避免多个线程或协程竞争同一资源。 - 避免资源竞争：使用同步机制（如
synchronized关键字或Lock接口）来避免多个线程或协程竞争同一资源。
参考链接
通过以上方法，可以有效解决JMS线程池和协程重复线程的问题，提高系统的性能和稳定性。
相关·内容
当您开始学习Kotlin协程时，您看到的第一个示例之一是可以启动数十万个协程，但在尝试对线程执行相同的操作时会遇到OutOfMemory异常。
虽然这个例子很“酷”，但我不认为它对现实世界的Android应用程序开发有什么用处，甚至有点误导。当然，您可以启动数十万个只做delay()的协程，但在现实中，您要么启动执行某种IO或某种计算的协程。
例如，如果您启动了数十万个协程，并且每个协程都使用Retrofit执行一个网络请求，那么它不会比传统地使用没有协程的Retrofit更轻量级，因为okhttp仍然会为每个请求阻塞一个线程。
当您使用协程进行计算时，情况也是如此。那么它也不是更轻量级的，因
浏览 1提问于2020-05-07得票数 3
考虑下面这段代码： suspend fun childTaskExecutor() {
GlobalScope.future(Dispatchers.Default) {
val currentThread = Thread.currentThread()
logger.info("[childTaskExecutor] running on ${currentThread.name} group : ${currentThread.threadGroup}")
}.awaitOrNull()
} 当我运行这个命令时，输出是：
浏览 17提问于2020-11-05得票数 1
1回答
假设我有一个包含10个线程的线程池。假设池中的一个线程执行某个任务。我希望在某些情况下，任务将停止执行，线程将执行另一个任务，只有稍后它才会返回到前一个任务，并从停止的地方继续执行。
这个是可能的吗？我该怎么做呢？
浏览 4提问于2021-10-08得票数 0
在协程中执行IO绑定函数(例如，从后端请求数据)可以让我暂停执行，直到请求的结果可用，对吧？然而，一个受CPU限制的函数(例如，解析一个巨大的文本文件)并不“等待”任何东西，它只是做了大量的工作。那么，在协程中执行它不是给了我暂停执行它的好处吗？当涉及到CPU绑定函数时，协程给我的唯一(有价值的)优势是能够选择在执行函数时将被阻塞的线程(或线程池)，我说的对吗？
浏览 2提问于2019-05-07得票数 2
我创建了一个协程，只有一个计算循环，退出条件为isActive。当我指定默认的dispatcher时，它会正确地取消，但当没有定义dispatcher时，它不会取消。 //This example cancels as expected
fun main() = runBlocking {
val job = launch(Dispatchers.Default) {
println("Start job 1")
var i =0
while (isActive){
print(i++)
浏览 22提问于2021-10-31得票数 1
回答已采纳
我正在尝试实现开始同步过程，而应用程序出现在前台。
我想在后台线程中进行多个API调用，对于这种情况，Kotlin Coroutines和ThreadPool executor哪个更好？
我试过使用Kotlin Coroutines，但它似乎试图并行执行所有函数调用，这会导致应用程序初始时间的一些延迟。有没有并行执行多个函数的最佳方法？
浏览 4提问于2019-09-30得票数 1
问题是我的Lua服务器无法同时接受多个请求。我试图让每个客户端消息在其上协同程序中处理，但似乎失败了。
while true do
local client = server:accept()
coroutine.resume(coroutine.create( function()
GiveMessage( client )
end ) )
end
这段代码实际上似乎不能同时接受多个客户端消息。这种方法有什么问题？谢谢你的帮助。
浏览 2提问于2011-02-19得票数 1
回答已采纳
1回答
我将以下Kotlin代码部署为OpenShift中的容器： fun main(args: Array<String>): Unit = io.ktor.server.netty.EngineMain.main(args)
@kotlin.jvm.JvmOverloads
fun Application.module() {
launch { consumeProductionGeneratingUnits1hTopic() }
launch { consumeProductionLargeGeneratingUnits1hTopic() }
launc
浏览 32提问于2021-09-02得票数 1
回答已采纳
2回答
Jetbrains在每一篇关于kotlin的文章中都谈到了异步编程。但我不明白为什么它们被称为异步？据我所知，kotlin协程--这是一个带有预初始化线程池的状态机。我们有一个工作线程池和一个io线程池。对我来说，这只是一个多线程编程。如果我们向协程发送阻塞代码，线程将被阻塞。如果我们使用async方法(来自默认协程库)，它会给我们一种异步工作的错觉，但这只是将“job”发送到另一个线程。
如果我们使用带有协程的async io，另一个问题。但这是IO API异步，而不是kotlin协程。与其他语言相比，Java没有很好的io异步api (可能是错误的)。据我所知，.NET已经重建了他们的异步
浏览 5提问于2021-09-17得票数 3
代码：
以上代码链接中的代码片段：
override suspend fun activateTask(taskId: String) {
withContext(ioDispatcher) {
(getTaskWithId(taskId) as? Success)?.let { it ->
activateTask(it.data)
}
}
}
override suspend fun clearCompletedTasks() {
浏览 34提问于2021-06-09得票数 2
好的，我有一个控制器方法，它需要对外部服务进行一系列soap调用，每个调用都相当繁重。我正在尝试用parralel执行这些操作以节省时间，但是除非我从GlobalScope构建async调用，否则延迟的调用将按顺序进行解析。让我来给你展示。 执行以下代码 @ResponseBody
@GetMapping(path = ["/buildSoapCall"])
fun searchStations(): String = runBlocking {
var travels: List<Travel> = service.getTravels().take(
浏览 13提问于2020-03-28得票数 1
回答已采纳
1回答
Kotlin corutines对于有限状态机和一些任务运行器(例如，默认ForkJoinPool)来说是糖。
换句话说，java/kotlin运行时中还没有运行时协程(但这可能会随着的变化而改变)。Kotlin协程只是一个接一个地执行的任务的顺序。每个任务都可以在线程池中的任何线程中执行。
Go运行时支持“协程”。但是goroutines并不是真正的协程。Goroutines不允许在程序中设置屈服点。另外，Go不允许设置自定义线程池。您可以仅设置默认池中线程的大小。
kotlin协程和goroutines之间的第一个区别是Go运行时管理此时正在运行的协程。当goroutine在某些IO操作(
浏览 2提问于2017-10-21得票数 44
回答已采纳
1回答
我期望的结果是(0，1)或(0，1，2)，但打印的数字不断增加。我在学习关于协程的知识。我遵循了这个例子，但我对它很好奇，所以我写了代码，发现了一些奇怪的东西。 class test {
@Test
fun test() = runBlocking {
val startTime = System.currentTimeMillis()
val job = launch {
var nextTime = startTime
var i = 0
while (isActiv
浏览 21提问于2021-07-25得票数 0
我经常创建具有包含协程的函数的类。并不总是清楚该函数是否由绑定到UI的某个组件使用，或者它是否正在进行更多面向IO的后台工作。下面是一个例子：
fun myFunction() {
GlobalScope.launch {
// Do something
}
}
在本例中，未指定Dispatcher.MAIN或Dispatchers.IO。这是正确的方法吗？协程是否使用调用客户端恰好正在使用的作用域？当我明确知道我需要一个特定的作用域时，我应该只指定一个调度程序吗？
浏览 3提问于2020-01-13得票数 2
1回答
如果线程被阻塞了3秒，为什么它会在1秒后打印'a‘？ 当一个线程被阻塞时，它不能做任何计算，直到它被解锁。当这个线程被Thread.sleep()阻塞时，怎么可能执行println('a')呢？ import kotlinx.coroutines.*
fun main() = runBlocking(Dispatchers.Default) {
GlobalScope.launch(Dispatchers.Default) {
delay(1000L)
println("a")
}
Thread
浏览 11提问于2020-07-22得票数 1
回答已采纳
的CoroutineScope是什么
runBlocking {
// some code here
}
在Kotlin Coroutines？
当类被垃圾回收时，它是被调用的类的本地，并且协程被垃圾回收吗?如果它还在运行，它会导致内存泄漏吗？
浏览 4提问于2021-09-20得票数 1
我对Kotlin协程和线程的理解是这样的： 一个线程一次只能运行一个协程。一个线程可以同时处理多个协程。它可以挂起一个协程并运行一个不同的协程。但是在给定的时间点上，一个线程上只有一个协程在运行。您不能在同一时间点在同一线程上运行多个协程。 是这样的吗？
浏览 81提问于2020-10-05得票数 1
回答已采纳
4回答
对于对其他语言(Python/JavaScript)有一定异步经验的人来说，当谈论异步/等待时，总是会假设在某个地方有一个事件循环。但是对于C++，我已经浏览了文档，没有找到任何讨论事件循环的地方。为什么会这样呢？
对于Node，它只有一个默认的事件循环。对于Python，如果需要，您可以创建多个。但是对于C++，这个事件循环是不是和Node一样呢？或者出于某种原因，我们根本不需要它吗？
浏览 7提问于2021-02-20得票数 19
1回答
我正在尝试从这段代码打印Hello in between World 4。
import kotlinx.coroutines.*
import java.util.*
fun main() = runBlocking <Unit> {
launch { //COR-1
var now = Date().time
val c= timeConusmingFunct(now) //may be some IO work
print(" World $c") //once done lets process
浏览 0提问于2019-08-01得票数 2
2回答
我已经看到很多关于python中的协程的演讲和文章。它们被认为是“微线程”，我听说它们可以提高性能。
协程如何提高性能？到目前为止，我看到的是它们是单线程的，并且是按顺序执行的。我同意从设计的角度来看，它们非常优雅，特别是在生产者/消费者类型的应用程序中。
我想我没有抓住要点。有人能帮我解释一下吗？
浏览 0提问于2011-07-05得票数 16
回答已采纳
我在使用套接字时收到此警告。我从IO作用域协程调用startConnection方法，如果startConnection方法是挂起的，我会收到警告。我将其设为suspend，因为稍后我将从它调用一些其他的suspend方法。有什么办法可以解决这个问题吗?或者我是否应该禁止显示警告？ private suspend fun startConnection(ip: String, port: Int) {
try {
socket = Socket(ip, port)
.
.
浏览 81提问于2020-09-17得票数 0
我在Kotlin中遇到了等待的问题，如果我只使用2个awaits，这个runBlocking块可以工作10秒，但是当我尝试使用4个awaits时，它可以工作20秒。据我所知，runBlocking中只有两个异步线程。我怎样才能增加这个计数？
fun testFun() {
val z1 = async { Thread.sleep(10000) }
val z2 = async { Thread.sleep(10000) }
val z3 = async { Thread.sleep(10000) }
val z4 = async { Thread.sleep(
浏览 6提问于2018-03-01得票数 8
回答已采纳
4回答
我在将当前的应用程序从Java转换为Kotlin时遇到了这个问题。 用于使用线程从服务器传输数据的java实现。 它将创建大约100个不同的线程来请求数据，但从我看到的情况来看，一次运行的线程不超过4个，其他线程将等待线程完成后再启动。 在将其翻译为Kotlin时，我使用了协程 这就产生了一个问题，因为服务器显然无法处理实际发送的100个请求。 所有协程都在相同的作用域中启动，所以是这样的： //this is a custom scope that launches on Dispatchers.IO + a job that I can use to cancel everything
浏览 30提问于2019-10-17得票数 6
回答已采纳
1回答
我正在使用带有协程的Room来存储/检索数据。从另一篇文章中我看到，从技术上讲，你可以同时从数据库中进行无限次的检索。目前，我正在处理一个非常大的数据集，我想要检索它。这大约是10,000,000行。我将它拆分成更小的读数，比如4 (2,500,000)，所有这些都是并行发生的。这减少了我的检索时间的30-40%，这是我想要的(这是相对于单个数据库读取)。令我困扰的是，当我将这个拆分值增加到4以上时，它实际上会变慢。我认为添加更多的并行协程会不断地将时间拆分。 我验证了所有并行工作的协程都是唯一的线程，所以它们不会以这种方式冲突。 有人知道为什么会发生这种事吗？我在想，可能Room/SQL对
浏览 86提问于2019-06-18得票数 2
正在尝试使用一些挂起功能运行此repo。有没有人能给点提示？ 假设我们有一个 suspend fun log(){
mLog.subscribeAlways<GroupMessageEvent> { event ->
if (event.message.content.contains("Error")) {
print("****")
} else if (event.message.content.contains("Warning")) {
浏览 37提问于2020-06-26得票数 0
回答已采纳
示例代码中的注释说明了delay()是非阻塞的。它应该暂停吗？https://kotlinlang.org/docs/reference/coroutines/basics.html fun main() {
GlobalScope.launch { // launch new coroutine in background and continue
delay(1000L) // non-blocking delay for 1 second (default time unit is ms)
println("World!") //
浏览 173提问于2019-03-25得票数 0
回答已采纳
给定一个受io和cpu限制的任务列表。当使用带有超时的asyncio.wait等待它们时，超时被触发得很晚。是否可以确定挂起超时的优先级？
此示例定义了模拟1秒cpu和1秒io绑定操作的工作进程。它并行运行其中的一些，并等待10秒。
async def worker():
for _ in range(200):
# approx one second of cpu bound operations
for _ in range(10000000):
random.random()
# one second of
浏览 7提问于2021-03-12得票数 1
回答已采纳
这是我的代码，我已经尝试了所有的协程选项，我在两个函数的开头都有语句，它会打印，但它不会在循环中做任何事情
coroutine.wrap(constantWork)()
coroutine.wrap(lookForKeys)()
循环开始于第170行之后
浏览 1提问于2020-11-29得票数 1
在Lua中遇到了协同例程的概念后，我觉得它们似乎是一种更好的并发软件编程模型，我想知道为什么Java中没有使用它？
协同例程似乎让开发人员编写在多个函数之间跳转的代码，每次前进几个步骤，提供并发执行的错觉，就像Java中CPU在多个线程之间进行时间片一样，但是协同例程允许开发人员决定何时跳出一个函数并开始执行另一个函数。这允许开发人员决定步骤应该有多细粒度，即并发程度，以及何时应该发生上下文切换，这可以防止延迟关键时代价高昂的上下文切换。
浏览 1提问于2013-10-23得票数 3
2回答
我正在遵循一个Java示例，它使用完成服务将查询提交给第三方应用程序，该应用程序通过调用以下命令来接收数据包：
completionService.submit(new FetchData());
然后它调用：
Future<Data> future = completionService.take();
Data data = future.get(timeout, TimeUnit.MILLISECONDS);
它等待提交的任务之一完成并返回数据。这两个调用在一个while(true)循环中。
我正在用c#开发一个应用程序，我想知道这是不是正确的等待数据包的方式，如果这是我如
浏览 0提问于2012-08-29得票数 1
我在网上看了很多文章，但我仍然有点困惑，当挂起函数在协程中被挂起时，会发生什么。
我知道，在幕后，挂起函数只是一个带有允许它恢复的延续参数的常规函数，但我的困惑是，挂起函数或协程在恢复后会在哪里返回。
我听过一些人说“他们不一定回到同一个主题”，我不明白，有人能一步一步地给我解释一下吗？
浏览 4提问于2020-04-23得票数 4
我使用Objectify 6.0.5，Ktor 1.2.6，com.google.appengine:appengine:1.9.60 我用tutorial https://github.com/objectify/objectify/wiki/Setup设置了web.xml，bootstrapper web.xml ...
<listener>
<listener-class>com.group.Bootstrapper</listener-class>
</listener>
<fil
浏览 37提问于2020-01-06得票数 1
回答已采纳
如果我在启动时使用while循环，它将继续运行，单击事件将不会执行，最终导致ANR。StateFlowImpl collect有一个while循环，它什么时候退出循环，这是我的例子：
class MainActivity : AppCompatActivity(), CoroutineScope by MainScope() {
private val TAG = "MainActivity"
val flow = MutableStateFlow(0)
override fun onCreate(savedInstanceState: Bundle?)
浏览 9提问于2021-12-01得票数 0
2回答
如果我们在main函数中使用协程，那么协程如何在延迟后恢复执行。就像在这个图像中，协程在主函数中，延迟2秒后代码恢复。所以我只想知道延迟后如何执行返回到代码。我知道状态机和android中的协程是如何工作的。我问的是kotlin的main函数(不是android activity )。
浏览 8提问于2021-09-15得票数 0
使用aiobotocore，我使用以下命令创建客户端： import botocore
import aiobotocore
s3_session = aiobotocore.get_session(loop=loop)
client = s3_session.create_client(
's3',
config=botocore.client.Config(connect_timeout=10, read_timeout=10, retries={'max_attempts': 0}),
endpoint_url=endpoint
浏览 18提问于2019-09-16得票数 0
回答已采纳
2回答
我想单击一个按钮，这将从Firebase中提取一些数据，然后我想转到下一个活动，传递一个包含Firebase数据的数组。我仍然不能理解异步代码，我希望有人能用最简单的方法来帮助我完成这项工作。
我已经尝试过运行阻塞、挂起函数、等待和异步，但我似乎不能正确地使用它。这是我的on click监听器：
btn_games_quiz.setOnClickListener {
listenForQuestions()
val intent = Intent(this, QuizActivity::class.java)
intent.putExtra("questio
浏览 0提问于2019-04-02得票数 2
1回答
import kotlinx.coroutines.*
import kotlin.system.measureTimeMillis
private val started = System.currentTimeMillis()
suspend fun main(args: Array<String>) {
debug("Start run blocking")
debug("starting")
coroutineScope {
debug("Inside runBlocking")
浏览 1提问于2021-09-05得票数 2
4回答
在我的Android应用程序中，我有一个用例，在这个用例中，只要应用程序运行，我就需要在循环中运行一些代码。
示例代码：
fun exampleRunCodeInLoop() {
viewModelScope.launch(Dispatchers.Default) {
while (true) {
delay(5000) // Wait for 5 seconds
// @param someCondition is just an example for the if statement
if (someConditi
浏览 4提问于2021-10-22得票数 0
2回答
带延迟的Kotlin协程单元测试
、、、、
我正在尝试对一个使用delay()的Kotlin协程进行单元测试。对于单元测试，我并不关心delay()，它只会减慢测试速度。我希望以某种方式运行测试，使其在调用delay()时不会真正延迟。
我尝试使用委托给CommonPool的自定义上下文运行协程：
class TestUiContext : CoroutineDispatcher(), Delay {
suspend override fun delay(time: Long, unit: TimeUnit) {
// I'd like it to call this
}
overrid
浏览 106提问于2017-11-08得票数 36
回答已采纳
下面是两个代码片段，它们几乎是相同的，除了一个在挂起协程中有线程，另一个没有。
第一个代码是：
suspend fun main(args: Array<String>) {
log(0)
coroutineScope {
log(1)
val result = suspendCoroutine<String> { continuation ->
log(2)
Thread {
log(3)
contin
浏览 6提问于2020-03-21得票数 1
试图弄清楚协程是不是正确的方法。
我有三个不同的类来执行操作；我希望这三个类以任何顺序执行它们的工作，一旦这三个类都完成了，我就可以进入下一个循环，再次调用这三个类中的方法来重新开始。
和现在一样，我在每个类中都有一个方法来完成工作；在主类中，我创建了一个协程，这是我的过程的主循环。协程有一个条件，即3个类中的所有3个方法都必须完成，在一个while循环中产生返回void。这是协程的简化版本：
IEnumerator void loopFunction()
{
while (!classA.method() && !classB.method() &&
浏览 0提问于2016-02-21得票数 1
我有一些代码在协程的函数调用中使用请求作用域的bean。看起来spring并不知道我还在同一个请求中。
有没有可能让spring理解我仍然想要请求作用域的bean，即使调用来自异步Kotlin协程？
当代码运行时，我收到以下错误消息：
org.springframework.beans.factory.BeanCreationException:
Error creating bean with name 'scopedTarget.wsContext':
Scope 'request' is not active for the current threa
浏览 1提问于2019-04-07得票数 5
如何像围棋中的等待组一样，在lua中等待所有的协程完成？使用Semaphobe完成了go中的Waitgroup。但是如何在lua中完成它呢？或者其他更好的方案？
浏览 2提问于2020-01-28得票数 1
1回答
我在代码中使用回调流从Firebase数据库中检索数据。以下是我的代码 @ExperimentalCoroutinesApi
suspend fun getUserOrder() = callbackFlow<UserOrder>{
println("Current Thread name is ${Thread.currentThread().name}")
databaseReference.child("Order").addValueEventListener(object : Valu
浏览 13提问于2020-06-28得票数 0
回答已采纳
1回答
我通过lua脚本从浏览器执行python脚本：
os.execute('python scriptname.py --arg1 Test --arg2 Test2')
我再次这样做(例如，通过刷新页面，发送表单)
os.execute('python scriptname.py --arg1 Test3 --arg2 Test4')
我希望第二个脚本只被执行时，第一个脚本完成到最后。我希望脚本被添加到队列中，并从最旧的脚本到最新的脚本执行。我该怎么做呢？
浏览 2提问于2018-07-08得票数 0
我是第一次接触龙卷风，对龙卷风的协程有一些问题。如果我有一个调用堆栈，看起来像这样：
func_a => func_b => func_c => func_d
func_d是一个异步函数，我使用了yield和@gen.coroutine装饰器。
就像这样：
@gen.coroutine
def redis_data(self, id):
ret = yield asyn_function()
raise gen.Return(ret)
我必须将yield和@gen.coroutine与func_c、func_b和func_a一起使用吗
浏览 2提问于2015-03-03得票数 1
我调用进程，当进程终止时，我调用函数 IEnumeratorLoadImageSet被称为startcorutine，但没有被调用 如果startcorutine被注释掉了，这个循环就会正常运行，但是如果没有注释掉，这个循环只会被调用一次，然后就会停止。 public void StartProcess(string path)
{
process= DI.Process.Start(path);
process.EnableRaisingEvents = true;
process.Exited += (obj, e) =>
浏览 58提问于2021-01-19得票数 0
回答已采纳
不久前，我从David Beazley的协程程序上读到了，我想知道是否有实际的基于Python的软件使用它们？
为什么协程看起来像是Python中最未使用的功能？
浏览 0提问于2011-04-23得票数 8
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
实时音视频
对象存储
云直播活动推荐
腾讯云开发者
