sod-crossbeam

sod::Service 实现用于与 crossbeam 队列交互。

服务实现

• ArrayQueuePusher 向 crossbeam::queue::ArrayQueue 推送数据
• ArrayQueueForcePusher 强制向 crossbeam::queue::ArrayQueue 推送数据
• ArrayQueuePopper 从 crossbeam::queue::ArrayQueue 弹出数据
• SegQueuePusher 向 crossbeam::queue::SegQueue 推送数据
• SegQueuePopper 从 crossbeam::queue::SegQueue 弹出数据

异步

任何服务都可以使用 self.into_async() 表示为 AsyncService。

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();

阻塞

sod::PollService 可能封装了 ArrayQueuePopper 或 SegQueuePopper，以提供一种退避机制，避免在轮询循环中忙等待 CPU。

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 可能封装了 ArrayQueuePusher，以阻塞并连续重试将元素推送到 ArrayQueue，直到成功。

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();