Struct crossbeam_channel::flavors::tick::Channel

pub(crate) struct Channel {
    delivery_time: AtomicCell<Instant>,
    duration: Duration,
}

Channel that delivers messages periodically.

Fields

delivery_time: AtomicCell<Instant>

The instant at which the next message will be delivered.

duration: Duration

The time interval in which messages get delivered.

Implementations

impl Channel

pub(crate) fn new(delivery_time: Instant, dur: Duration) -> Self

Creates a channel that delivers messages periodically.

pub(crate) fn try_recv(&self) -> Result<Instant, TryRecvError>

Attempts to receive a message without blocking.

pub(crate) fn recv( &self, deadline: Option<Instant> ) -> Result<Instant, RecvTimeoutError>

Receives a message from the channel.

pub(crate) unsafe fn read(&self, token: &mut Token) -> Result<Instant, ()>

Reads a message from the channel.

pub(crate) fn is_empty(&self) -> bool

Returns true if the channel is empty.

pub(crate) fn is_full(&self) -> bool

Returns true if the channel is full.

pub(crate) fn len(&self) -> usize

Returns the number of messages in the channel.

pub(crate) fn capacity(&self) -> Option<usize>

Returns the capacity of the channel.

Trait Implementations

impl SelectHandle for Channel

fn try_select(&self, token: &mut Token) -> bool

Attempts to select an operation and returns true on success.

fn deadline(&self) -> Option<Instant>

Returns a deadline for an operation, if there is one.

fn register(&self, _oper: Operation, _cx: &Context) -> bool

Registers an operation for execution and returns true if it is now ready.

fn unregister(&self, _oper: Operation)

Unregisters an operation for execution.

fn accept(&self, token: &mut Token, _cx: &Context) -> bool

Attempts to select an operation the thread got woken up for and returns true on success.

fn is_ready(&self) -> bool

Returns true if an operation can be executed without blocking.

fn watch(&self, _oper: Operation, _cx: &Context) -> bool

Registers an operation for readiness notification and returns true if it is now ready.

fn unwatch(&self, _oper: Operation)

Unregisters an operation for readiness notification.