pub fn split<'a>(
ring: &'a mut SpscRingBuffer,
slots: &'a mut [L2Update],
) -> Result<(Producer<'a>, Consumer<'a>), RingInitError>Examples found in repository?
examples/bench.rs (line 68)
63fn bench_spsc_throughput() -> f64 {
64 let mut ring = SpscRingBuffer::default();
65 let mut slots = vec![L2Update::default(); SPSC_CAPACITY];
66
67 let (mut producer, mut consumer) =
68 split(&mut ring, &mut slots).expect("failed to initialize SPSC ring buffer");
69
70 let start = Instant::now();
71
72 thread::scope(|scope| {
73 let producer_handle = scope.spawn(move || {
74 for i in 0..SPSC_MESSAGES {
75 let mut msg = L2Update {
76 market_id: i & 0x1fff,
77 mid_price: 0.45 + ((i % 10_000) as f64) * 0.00001,
78 implied_vol: 0.08 + ((i % 1_000) as f64) * 0.0001,
79 };
80
81 loop {
82 match producer.try_push(msg) {
83 Ok(()) => break,
84 Err(m) => {
85 msg = m;
86 spin_loop();
87 }
88 }
89 }
90 }
91 });
92
93 let consumer_handle = scope.spawn(move || {
94 let mut received = 0_u64;
95 let mut checksum = 0.0_f64;
96
97 while received < SPSC_MESSAGES {
98 if let Some(msg) = consumer.try_pop() {
99 received += 1;
100 checksum += msg.mid_price + msg.implied_vol + (msg.market_id as f64) * 1e-12;
101 } else {
102 spin_loop();
103 }
104 }
105
106 black_box(checksum);
107 received
108 });
109
110 producer_handle
111 .join()
112 .expect("producer thread panicked during benchmark");
113
114 let received = consumer_handle
115 .join()
116 .expect("consumer thread panicked during benchmark");
117 assert_eq!(received, SPSC_MESSAGES, "message loss in SPSC benchmark");
118 });
119
120 let elapsed = start.elapsed();
121 let secs = elapsed.as_secs_f64();
122 (SPSC_MESSAGES as f64 / 1_000_000.0) / secs
123}