pub struct NotificationQueue;Expand description
只负责有界内存队列的工厂,不创建任务、线程或网络客户端。
Implementations§
Source§impl NotificationQueue
impl NotificationQueue
Sourcepub fn bounded(
provider_ids: Vec<String>,
capacity: usize,
) -> Result<(NotificationProducer, NotificationReceiver), ConfigError>
pub fn bounded( provider_ids: Vec<String>, capacity: usize, ) -> Result<(NotificationProducer, NotificationReceiver), ConfigError>
业务作用:按已引用 provider 的冻结目录预分配通知指标和有界队列。
参数说明:
provider_ids:为唯一合法标识capacity:为 1..=65536 的队列容量。
返回:生产端与唯一接收端;非法目录或容量不分配运行资源。
Auto Trait Implementations§
impl Forget for NotificationQueue
impl Freeze for NotificationQueue
impl Move for NotificationQueue
impl RefUnwindSafe for NotificationQueue
impl Send for NotificationQueue
impl Sync for NotificationQueue
impl Unpin for NotificationQueue
impl UnsafeUnpin for NotificationQueue
impl UnwindSafe for NotificationQueue
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more