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 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64
pub mod noloss; use std::cell::UnsafeCell; use std::sync::Arc; use super::cb::{CircularBuffer, CircularBufferIterator}; pub struct Sender<T> { inner: Arc<UnsafeCell<CircularBuffer<T>>>, } unsafe impl<T> Send for Sender<T> { } pub struct Receiver<T> { inner: Arc<UnsafeCell<CircularBuffer<T>>>, } unsafe impl<T> Send for Receiver<T> { } pub fn channel<T: Send>(size : usize) -> (Sender<T>, Receiver<T>) { let a = Arc::new(UnsafeCell::new(CircularBuffer::new(size))); (Sender::new(a.clone()), Receiver::new(a)) } impl<T: Send> Sender<T> { fn new(inner: Arc<UnsafeCell<CircularBuffer<T>>>) -> Sender<T> { Sender { inner: inner, } } #[inline(always)] pub fn put<F>(&mut self, setter: F) -> usize where F : FnMut(&mut Option<T>) { unsafe { (*self.inner.get()).put(setter) } } #[inline(always)] pub fn tmp<F>(&mut self, setter: F) where F : FnMut(&mut Option<T>){ unsafe { (*self.inner.get()).tmp(setter) } } #[inline(always)] pub fn seqno(&self) -> usize{ unsafe { (*self.inner.get()).seqno() } } } impl<T: Send> Receiver<T> { fn new(inner: Arc<UnsafeCell<CircularBuffer<T>>>) -> Receiver<T> { Receiver { inner: inner, } } #[inline(always)] pub fn iter(&mut self) -> CircularBufferIterator<T> { unsafe { (*self.inner.get()).iter() } } #[inline(always)] pub fn seqno(&self) -> usize{ unsafe { (*self.inner.get()).seqno() } } } #[cfg(test)] pub mod tests;