cupchan 0.1.2

Simple async overwriting channel between two threads that is wait & block free by swapping cups around
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
32
33
34
35
36
37
38
39
40
41

//! note to self: do not use the various LOOM_ flags, they will make loom crash on this test for some reason

#![cfg(loom)]
use cupchan::cupchan;
use loom::thread;

#[test]
fn loom_test() {
	loom::model(|| {
		let (mut writer, reader) = cupchan(0);

		const MAX: usize = 4;
		let join = thread::spawn(move || {
			for i in 0..MAX {
				let ptr = writer.loom_ptr();
				unsafe {
					*ptr.deref() = i;
				}
				drop(ptr);
				writer.flush();
				thread::yield_now();
			}
		});

		let mut current = 0;
		// let mut array = [0usize; MAX];
		while current < MAX - 1 {
			let ptr = reader.loom_ptr();
			let read = unsafe { *ptr.deref() };
			drop(ptr);
			assert!(current <= read && read < MAX);
			// array[read] += 1;
			current = read;
			thread::yield_now();
		}

		assert!(current == MAX - 1);

		join.join().unwrap();
	});
}