Crate sod_crossbeam
source ·Expand description
sod::Service
implementations to interact with crossbeam
queues.
Service Impls
- [
ArrayQueue
] can be pushed withArrayQueuePusher
orArrayQueueForcePusher
and popped withArrayQueuePopper
- [
SegQueue
] can be pushed withSegQueuePusher
orSegQueuePopper
Async
Any of the services can be represented as an AsyncService
using [`sod::IntoAsyncService::into_async].
use crossbeam::queue::ArrayQueue;
use sod::{PollService, IntoMutService, 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
- A
sod::Service
that force pushes input to an underlying [crossbeam::queue::ArrayQueue
]. - A
sod::Service
that pops an element from an underlying [crossbeam::queue::ArrayQueue
]. - A
sod::Service
that issod::Retryable
and pushes input to an underlying [crossbeam::queue::ArrayQueue
], returning the element as an error when the queue is full. - A
sod::Service
that pops an element from an underlying [crossbeam::queue::SegQueue
]. - A
sod::Service
that pushes input to an underlying [crossbeam::queue::SegQueue
].