结构体 UnboundedSender 

pub struct UnboundedSender<T> { /* private fields */ }

向关联的 UnboundedReceiver 发送值。

实例 由 unbounded_channel 函数创建。

实现

impl<T> UnboundedSender<T>

pub fn send(&self, message: T) -> Result<(), SendError<T>>

尝试在不阻塞的情况下通过此 UnboundedSender 发送一条消息。

此方法未标记为 async，因为向无界通道发送消息永远不需要任何形式的等待。这是由于通道的无限容量，允许 send 操作立即完成。因此，send 方法可以在同步和异步代码中使用而不会出现问题。

如果通道的接收半部已关闭（无论是因为调用了 close 还是 UnboundedReceiver 已被丢弃），此函数返回错误。错误包含传递给 send 的值。

pub async fn closed(&self)

当接收者已丢弃时完成。

这允许生产者在对所产生值的兴趣被取消时收到通知，并立即停止工作。

Cancel safety

此方法是取消安全的。一旦通道关闭，它将永远保持关闭状态，所有后续对 closed 的调用都将立即返回。

示例

use tokio::sync::mpsc;

let (tx1, rx) = mpsc::unbounded_channel::<()>();
let tx2 = tx1.clone();
let tx3 = tx1.clone();
let tx4 = tx1.clone();
let tx5 = tx1.clone();
tokio::spawn(async move {
    drop(rx);
});

futures::join!(
    tx1.closed(),
    tx2.closed(),
    tx3.closed(),
    tx4.closed(),
    tx5.closed()
);
println!("Receiver dropped");

pub fn is_closed(&self) -> bool

检查通道是否已关闭。当 UnboundedReceiver 被丢弃时或调用 UnboundedReceiver::close 方法时会发生这种情况。

let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<()>();
assert!(!tx.is_closed());

let tx2 = tx.clone();
assert!(!tx2.is_closed());

drop(rx);
assert!(tx.is_closed());
assert!(tx2.is_closed());

pub fn same_channel(&self, other: &Self) -> bool

如果发送者属于同一通道则返回 true。

示例

let (tx, rx) = tokio::sync::mpsc::unbounded_channel::<()>();
let  tx2 = tx.clone();
assert!(tx.same_channel(&tx2));

let (tx3, rx3) = tokio::sync::mpsc::unbounded_channel::<()>();
assert!(!tx3.same_channel(&tx2));

pub fn downgrade(&self) -> WeakUnboundedSender<T>

将 UnboundedSender 转换为 WeakUnboundedSender，它不计入 RAII 语义——也就是说，如果通道的所有 UnboundedSender 实例都已被丢弃且仅剩 WeakUnboundedSender 实例，则通道被关闭。

pub fn strong_count(&self) -> usize

返回 UnboundedSender 句柄的数量。

pub fn weak_count(&self) -> usize

返回 WeakUnboundedSender 句柄的数量。

Trait 实现

impl<T> Clone for UnboundedSender<T>

fn clone(&self) -> Self

返回值的副本。 更多信息

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source. 更多信息

impl<T> Debug for UnboundedSender<T>

fn fmt(&self, fmt: &mut Formatter<'_>) -> Result

使用给定的格式化器格式化此值。 更多信息