bbq-rs 0.1.1

A Block-based Bounded Queue for Exchanging Data and Profiling
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

# BBQ: A Block-based Bounded Queue for Exchanging Data and Profiling

This is a concurrent queue that supports multiple producers and multiple consumers. It is implemented based on the paper "BBQ: A Block-based Bounded Queue for Exchanging Data and Profiling" and can be used as follows:

## Usage

Add `bbq-rs` to your `Cargo.toml` dependencies:

```toml
[dependencies]
bbq-rs = "0.1.1"
``` 

## Example:

```rust
use bbq_rs::Bbq;  
use bbq_rs::BlockingQueue;  
  
fn main() {  
    let queue = Bbq::new(100, 100).unwrap();  
  
    // Create four producer threads  
    for i in 0..4 {  
        let q = queue.clone();  
        std::thread::spawn(move || {  
        q.push(i);  
    });

    // Create four consumer threads  
    for _ in 0..4 {  
        let q = queue.clone();  
        std::thread::spawn(move || {  
            println!("{}", q.pop().unwrap());  
        });  
    }
}
```