Kotlin 1.5 通道 trySendBlocking() 与 trySend()

如何解决Kotlin 1.5 通道 trySendBlocking() 与 trySend()

在迁移到 Kotlin 1.5 时，我偶然发现了 Channel 新的 trySendBlocking() 方法的一个问题。

因此，我们有一个演员返回一个 SendChannel<Command>，Command 是我们自己的数据类。

在 Kotlin 1.4 中向 actor 发送命令时，我们曾经像这样使用它的通道：

channel.sendBlocking(command)

现在，建议在 Kotlin 1.5 中使用以下内容：

channel.trySendBlocking(command)

好的，但我想知道为什么不使用 trySend() 而不是 trySendBlocking()？ 我正在挠头的一些事情：

1. 如果我们确定通道的容量足够大，并且actor 消耗它的速度足够快，那么通道不会变满，trySend() 将始终成功。我们可以做这样的事情来解决频道可能已满的少数情况：

   做{ val 结果 = channel.trySend(command) } while (result.isFailure)

2. trySendBlocking() 内部使用 runBlocking() 来阻塞整个线程。根据文档，runblocking() 是“旨在将常规阻塞代码桥接到以挂起风格编写的库，以用于主要功能和测试”。但在这里它的使用方式超出了这个记录用例。它可能会阻塞整个线程。我会认为这是个坏主意吗？

3. trySend() 线程安全吗？如果多个线程在同一个通道上同时调用trySend()，会不会有问题？这就是我们更喜欢trySendBlocking()的原因吗？

谢谢

解决方法

1. 也许您想改用 send() 方法？

2. 据我所知，这正是作者的意思。此方法是同步的，应与阻塞代码一起使用。如果它不可用，为了桥接同步代码和异步代码，您将使用 runBlocking 方法。

3. 快速查看内部后，对我来说看起来像是线程安全的；它使用原子变量和其他与并发相关的东西，但作为不是这些的设计者，我无法确定。 Actor应该是线程安全的。