sod-mpsc

sod::Service 实现与 std::sync::mpsc::channel 队列交互。

服务实现

• MpscSender 向 std::sync::mpsc::channel 发送消息。
• MpscSyncSender 向 std::sync::mpsc::sync_channel 发送消息，如果通道已满则阻塞。
• MpscSyncTrySender 尝试向 std::sync::mpsc::sync_channel 发送消息，如果通道已满，则可以通过 sod::RetryService 重试。
• MpscReceiver 从 std::sync::mpsc::channel 或 std::sync::mpsc::sync_channel 接收消息，直到接收到一个元素为止，会阻塞。
• MpscTryReceiver 尝试从 std::sync::mpsc::channel 或 std::sync::mpsc::sync_channel 接收，当通道为空时，可以通过 sod::Retryable 进行重试。

示例

use sod::Service;
use sod_mpsc::{MpscSender, MpscReceiver};
use std::sync::mpsc;

let (tx, rx) = mpsc::channel();
let pusher = MpscSender::new(tx);
let poller = MpscReceiver::new(rx);

pusher.process(1).unwrap();
pusher.process(2).unwrap();

assert_eq!(poller.process(()).unwrap(), 1);
assert_eq!(poller.process(()).unwrap(), 2);