1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

//! mpmc-ringbuf focuses on offering a easy and efficient way to share data between different instance.
//! And we offer the different mode `Fixed`,`Dynamic` to satisfy the demand.
//!
//! simple example
//!
//! single thread
//! ```rust
//!  let mut msg_queue: MsgQueue<u8> = MsgQueue::new();
//!  let mut writer1 = msg_queue.add_producer();
//!  let mut read1 = msg_queue.add_consumer();
//!  writer1.write(vec![10; 100]);
//!  assert_eq!(read1.size(), 100);
//!  let mut read2 = msg_queue.add_consumer();
//!  assert_eq!(read2.size(), 0);
//!  assert_eq!(msg_queue.get_consumer_count(), 2);
//!  writer1.write(vec![0; 100]);
//!  assert_eq!(read1.size(), 200);
//!  assert_eq!(read2.size(), 100);
//!  read2.read(50);
//!  assert_eq!(read1.size(), 200);
//!  assert_eq!(read2.size(), 50);
//! ```
pub mod core;