有一个Processor
类,试图用协程替换一些代码。因为它位于非协程上下文中,所以添加了val serviceScope = CoroutineScope(Dispatchers.IO + serviceJob)
并将其用于启动协程。
添加了CoroutineScope
,并在使用线程{}.start()的地方使用了serviceScope.launch{}
。
在函数restart()中,它将CountDownLatch
的使用替换为
serviceScope.launch {
withContext(Dispatchers.IO) {
doReset()
}
}
问:这个launch/withContext实际上不会停止下一个if (!conDoProcess)
的代码执行--所以它无法完成latch
过去所做的事情。
在doReset()
之前停止代码执行的正确方法是什么?完成了吗?
另一个问题是,当处理这个调用serviceScope.cancel()
的Processor
对象时,
如果使用serviceJob.cancel()
调用,有什么不同
class Processor {
private val serviceJob = Job()
private val serviceScope = CoroutineScope(Dispatchers.IO + serviceJob)
.........
/* return false if the it does not start the processing */
fun restart(): Boolean {
synchronized(_lock) {
.........
// 1.old code using latch to wait
/******************
val latch = CountDownLatch(1)
streamThreadPoolExecutor.execute {
doReset() //
latch.countDown()
}
latch.await(3, TimeUnit.SECONDS) // wait at most for 3 seconds if no one calls countDown
*******************/
// 2. change to using coroutines to suspend
serviceScope.launch {
withContext(Dispatchers.IO) {
doReset()
}
}
// wait until reset is done
if (!conDoProcess) {// the doRest() should update conDoProcess
return false
}
for (i in providers.indices) {
val pr = provider[i]
serviceScope.launch {
pr.doProcess()
}
}
return true
}
}
fun dispose() {
synchronized(_lock) {
.........
serviceScope.cancel()
// or should it use
// serviceJob.cancel()
//==========>
}
}
}
发布于 2019-07-11 03:45:25
我认为它错误地使用了serviceScope.launch
,它应该在阻塞部分withContext(Dispatchers.IO)
之后包含rest部分,但是在serviceScope.launch
内部。
// 2. change to using coroutines to suspend
serviceScope.launch {
withContext(Dispatchers.IO) {
doReset()
}
// wait until reset is done
if (!conDoProcess) {// the doRest() should update conDoProcess
return false
}
for (i in providers.indices) {
val pr = provider[i]
serviceScope.launch {
pr.doProcess()
}
}
}
return true
https://stackoverflow.com/questions/56875045
复制相似问题