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>
impl<T> Worker<T>
Sourcepub fn len(&self) -> usize
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);Sourcepub fn push(&self, value: T)
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);Sourcepub fn pop(&self) -> Option<T>
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);Sourcepub fn steal(&self) -> Option<T>
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);Sourcepub fn steal_weak(&self) -> Steal<T>
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§
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> 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
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
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 moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
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