具有结构化并发和协同机制的“火与忘”

Question

我有一个看起来像这样的小端点

val numbers = it.bodyAsString.parseJsonList<Numbers>()
processedNumbers = numberService.process(numbers)
GlobalScope.launch {
    sqsService.sendToSqs(processedNumbers)
}
it.response.setStatusCode(204).end()

我之所以使用GlobalScope，是因为生产者只需要在数字被处理后才能确认，所以我试图做一次火灾，并在平行轨道上忘记能够立即响应生产者。

用结构化货币做这件事的“最佳做法”是什么？我是否应该创建自己的作用域(比如fireAndForgetScope而不是GlobalScope)？

Answer 1

正如您已经猜到的，在这种情况下，创建您自己的范围将是一个很好的解决方案。

您可以将其定义为控制器的成员：

private val bgScope = CoroutineScope(newFixedThreadPoolContext(4, "background-tasks"))

那么，用法与您所做的非常相似：

val numbers = it.bodyAsString.parseJsonList<Numbers>()
processedNumbers = numberService.process(numbers)
bgScope.launch {
    sqsService.sendToSqs(processedNumbers)
}
it.response.setStatusCode(204).end()