pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>)展开描述
创建一个无界 mpsc channel,用于在异步任务之间通信(不提供背压)。
只要接收半尚未关闭,
此通道上的 send
就会始终成功。
如果 receiver 落后,
消息将被任意缓冲。
注意,
可用系统内存量
是通道的隐式上限。
使用 unbounded
通道可能会导致
进程内存耗尽。
在这种情况下,
进程将被中止。
pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>)创建一个无界 mpsc channel,用于在异步任务之间通信(不提供背压)。
只要接收半尚未关闭,
此通道上的 send
就会始终成功。
如果 receiver 落后,
消息将被任意缓冲。
注意,
可用系统内存量
是通道的隐式上限。
使用 unbounded
通道可能会导致
进程内存耗尽。
在这种情况下,
进程将被中止。