disruptor 4.1.0

Low latency inter-thread communication via a ringbuffer (inspired by the LMAX Disruptor).
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31

use core_affinity::CoreId;

pub(crate) fn cpu_has_core_else_panic(id: usize) {
	let available: Vec<usize> = core_affinity::get_core_ids()
		.unwrap()
		.iter()
		.map(|core_id| core_id.id)
		.collect();

	if !available.contains(&id) {
		panic!("No core with ID={} is available.", id);
	}
}

/// No-op on MacOS.
#[cfg(target_os = "macos")]
pub(crate) fn set_affinity_if_defined(_core_affinity: Option<CoreId>, _thread_name: &str) {}

/// Sets the core affinity.
#[cfg(not(target_os = "macos"))]
pub(crate) fn set_affinity_if_defined(core_affinity: Option<CoreId>, thread_name: &str) {
	if let Some(core_id) = core_affinity {
		let got_pinned = core_affinity::set_for_current(core_id);
		if !got_pinned {
			panic!(
				"Could not pin processor thread '{}' to {:?}.",
				thread_name, core_id
			);
		}
	}
}