kotlin - Kotlin 协程：并发执行节流

Question

想象一下，我们正在从消息队列中读取消息，并在接收时将它们推送到线程池中进行处理。线程数量有限，所以如果所有线程都忙，我们就会有自然的背压。

在 Kotlin 协程世界中如何解决这个问题？如果我们为每条传入消息创建一个协程，我们很快就会遇到内存不足错误（例如，如果每个任务都需要从数据库加载一些数据）和其他问题。

有没有解决这个问题的机制或模式？

标签： kotlincoroutinekotlinx.coroutinesbackpressure

Answer 1

解决问题的一种方法是在其上创建一个Channel和send您的数据。其他线程可以将 aconsumeEach放在通道上以从中接收数据。通道的容量可以根据您的线程需求进行调整。

协程文档中的扇出和扇入示例也很有帮助。