[go: up one dir, main page]

Struct Worker

Source
pub struct Worker<T> { /* private fields */ }
Expand description

Worker side of a work-stealing deque.

There is only one worker per deque.

Implementations§

Source§

impl<T> Worker<T>

Source

pub fn len(&self) -> usize

Returns the number of elements in the deque.

If used concurrently with other operations, the returned number is just an estimate.

§Examples
use coco::deque;

let (w, _) = deque::new();
for i in 0..30 {
    w.push(i);
}
assert_eq!(w.len(), 30);
Source

pub fn push(&self, value: T)

Pushes an element onto the bottom of the deque.

§Examples
use coco::deque;

let (w, _) = deque::new();
w.push(1);
w.push(2);
Source

pub fn pop(&self) -> Option<T>

Pops an element from the bottom of the deque.

§Examples
use coco::deque;

let (w, _) = deque::new();
w.push(1);
w.push(2);

assert_eq!(w.pop(), Some(2));
assert_eq!(w.pop(), Some(1));
assert_eq!(w.pop(), None);
Source

pub fn steal(&self) -> Option<T>

Steals an element from the top of the deque.

§Examples
use coco::deque;

let (w, _) = deque::new();
w.push(1);
w.push(2);

assert_eq!(w.steal(), Some(1));
assert_eq!(w.steal(), Some(2));
assert_eq!(w.steal(), None);
Source

pub fn steal_weak(&self) -> Steal<T>

Steals an element from the top of the deque, but may sometimes spuriously fail.

If another concurrent operation gets in the way when stealing data, this method will return immediately with Steal::Inconsistent instead of retrying.

§Examples
use coco::deque::{self, Steal};

let (w, _) = deque::new();
w.push(1);
assert_eq!(w.steal_weak(), Steal::Data(1));

Trait Implementations§

Source§

impl<T> Debug for Worker<T>

Source§

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

Formats the value using the given formatter. Read more
Source§

impl<T: Send> Send for Worker<T>

Auto Trait Implementations§

§

impl<T> Freeze for Worker<T>

§

impl<T> RefUnwindSafe for Worker<T>
where T: RefUnwindSafe,

§

impl<T> !Sync for Worker<T>

§

impl<T> Unpin for Worker<T>

§

impl<T> UnwindSafe for Worker<T>
where T: RefUnwindSafe,

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

impl<T, U> Into<U> for T
where U: From<T>,

Source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

Source§

impl<T> IntoEither for T

Source§

fn into_either(self, into_left: bool) -> Either<Self, Self>

Converts self into a Left variant of Either<Self, Self> if into_left is true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
where F: FnOnce(&Self) -> bool,

Converts self into a Left variant of Either<Self, Self> if into_left(&self) returns true. Converts self into a Right variant of Either<Self, Self> otherwise. Read more
Source§

impl<T, U> TryFrom<U> for T
where U: Into<T>,

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
Source§

impl<T, U> TryInto<U> for T
where U: TryFrom<T>,

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.