Crate sod_crossbeam 

sod::Service implementations to interact with crossbeam queues.

Service Impls

• ArrayQueue can be pushed with ArrayQueuePusher or ArrayQueueForcePusher and popped with ArrayQueuePopper
• SegQueue can be pushed with SegQueuePusher or SegQueuePopper

Async

Any of the services can be represented as an AsyncService using [`sod::IntoAsyncService::into_async].

use crossbeam::queue::ArrayQueue;
use sod::{PollService, Service};
use sod_crossbeam::ArrayQueuePopper;
use std::{sync::Arc, time::Duration};

let q = Arc::new(ArrayQueue::<i32>::new(128));
let async_popper = ArrayQueuePopper::new(Arc::clone(&q)).into_mut();

Blocking

sod::PollService may encapsulate a ArrayQueuePopper or SegQueuePopper to provide a backoff mechanism to avoid busy-spinning the CPU in a poll loop.

use crossbeam::queue::ArrayQueue;
use sod::{idle::backoff, PollService, Service};
use sod_crossbeam::ArrayQueuePopper;
use std::{sync::Arc, time::Duration};

let q = Arc::new(ArrayQueue::<i32>::new(128));
let popper = PollService::new(ArrayQueuePopper::new(Arc::clone(&q)), backoff);

loop {
    println!("received: {}", popper.process(()).unwrap());
}

sod::RetryService may encapsulate a ArrayQueuePusher to block and continuously retry pushing an element to an ArrayQueue until it succeeds.

use crossbeam::queue::ArrayQueue;
use sod::{RetryService, Service, idle::yielding};
use sod_crossbeam::ArrayQueuePusher;
use std::sync::Arc;

let q = Arc::new(ArrayQueue::new(128));
let pusher = RetryService::new(ArrayQueuePusher::new(Arc::clone(&q)), yielding);

pusher.process(123).unwrap();
pusher.process(456).unwrap();

Structs

ArrayQueueForcePusher

A sod::Service that force pushes input to an underlying crossbeam::queue::ArrayQueue.

ArrayQueuePopper

A sod::Service that pops an element from an underlying crossbeam::queue::ArrayQueue.

ArrayQueuePusher

A sod::Service that is sod::Retryable and pushes input to an underlying crossbeam::queue::ArrayQueue, returning the element as an error when the queue is full.

SegQueuePopper

A sod::Service that pops an element from an underlying crossbeam::queue::SegQueue.

SegQueuePusher

A sod::Service that pushes input to an underlying crossbeam::queue::SegQueue.