结构体 WeakUnboundedSender 

pub struct WeakUnboundedSender<T> { /* 私有字段 */ }

不会阻止 channel 被关闭的无界 sender。

如果 channel 的所有 UnboundedSender 实例都已被 drop，仅剩下 WeakUnboundedSender 实例，则 channel 关闭。

为了发送消息，WeakUnboundedSender 需要使用 WeakUnboundedSender::upgrade 进行升级，该函数返回 Option<UnboundedSender>。如果所有 UnboundedSender 都已被 drop，则返回 None，否则返回 UnboundedSender。

示例

use tokio::sync::mpsc::unbounded_channel;

let (tx, _rx) = unbounded_channel::<i32>();
let tx_weak = tx.downgrade();

// 升级会成功，因为 `tx` 仍然存在。
assert!(tx_weak.upgrade().is_some());

// 如果 drop 掉 `tx`，则升级会失败。
drop(tx);
assert!(tx_weak.clone().upgrade().is_none());

实现

impl<T> WeakUnboundedSender<T>

pub fn upgrade(&self) -> Option<UnboundedSender<T>>

尝试将 WeakUnboundedSender 转换为 UnboundedSender。如果存在其他存活的 Sender 实例且 channel 之前未被 drop，则返回 Some，否则返回 None。

pub fn strong_count(&self) -> usize

返回 UnboundedSender 句柄的数量。

pub fn weak_count(&self) -> usize

返回 WeakUnboundedSender 句柄的数量。

trait 实现

impl<T> Clone for WeakUnboundedSender<T>

fn clone(&self) -> Self

返回值的副本。 更多信息

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

Performs copy-assignment from source. 更多信息

impl<T> Debug for WeakUnboundedSender<T>

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

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

impl<T> Drop for WeakUnboundedSender<T>

fn drop(&mut self)

执行此类型的析构函数。 更多信息