Struct BlockingQueue

pub struct BlockingQueue<E, Q: QueueBehavior<E>> { /* private fields */ }

Implementations

impl<E, Q: QueueBehavior<E>> BlockingQueue<E, Q>

pub fn new(queue: Q) -> Self

Trait Implementations

impl<E: Element + 'static, Q: QueueBehavior<E>> BlockingQueueBehavior<E> for BlockingQueue<E, Q>

fn put(&mut self, e: E) -> Result<()>

Inserts the specified element into this queue. If necessary, waits until space is available.
指定された要素をこのキューに挿入します。必要に応じて、空きが生じるまで待機します。

fn take(&mut self) -> Result<Option<E>>

Retrieve the head of this queue and delete it. If necessary, wait until an element becomes available.
このキューの先頭を取得して削除します。必要に応じて、要素が利用可能になるまで待機します。

impl<E: Clone, Q: Clone + QueueBehavior<E>> Clone for BlockingQueue<E, Q>

fn clone(&self) -> BlockingQueue<E, Q>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<E: Debug, Q: Debug + QueueBehavior<E>> Debug for BlockingQueue<E, Q>

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

Formats the value using the given formatter.

impl<E: Element + 'static, Q: QueueBehavior<E>> QueueBehavior<E> for BlockingQueue<E, Q>

fn len(&self) -> QueueSize

Returns the length of this queue.
このキューの長さを返します。

fn capacity(&self) -> QueueSize

Returns the capacity of this queue.
このキューの最大容量を返します。

fn offer(&mut self, e: E) -> Result<()>

The specified element will be inserted into this queue, if the queue can be executed immediately without violating the capacity limit.
容量制限に違反せずにすぐ実行できる場合は、指定された要素をこのキューに挿入します。

fn poll(&mut self) -> Result<Option<E>>

Retrieves and deletes the head of the queue. Returns None if the queue is empty.
キューの先頭を取得および削除します。キューが空の場合は None を返します。

fn is_empty(&self) -> bool

Returns whether this queue is empty.
このキューが空かどうかを返します。

fn non_empty(&self) -> bool

Returns whether this queue is non-empty.
このキューが空でないかどうかを返します。

fn is_full(&self) -> bool

Returns whether the queue size has reached its capacity.
このキューのサイズが容量まで到達したかどうかを返します。

fn non_full(&self) -> bool

Returns whether the queue size has not reached its capacity.
このキューのサイズが容量まで到達してないかどうかを返します。