跳到主要内容

unbounded_channel

搜索

函数 unbounded_channel 

Source
pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>)
展开描述

创建一个无界 mpsc channel,用于在异步任务之间通信(不提供背压)。

只要接收半尚未关闭, 此通道上的 send 就会始终成功。 如果 receiver 落后, 消息将被任意缓冲。

注意, 可用系统内存量 是通道的隐式上限。 使用 unbounded 通道可能会导致 进程内存耗尽。 在这种情况下, 进程将被中止。