crossbeam 0.4.1

extern crate crossbeam;

use crossbeam::scope;
use crossbeam::queue::MsQueue;

use std::sync::Arc;

const DUP: usize = 4;
const THREADS: u32 = 2;
const COUNT: u64 = 100000;

fn main() {
    scope(|s| {
        for _i in 0..DUP {
            let q = Arc::new(MsQueue::new());
            let qs = q.clone();

            s.spawn(move || {
                for i in 1..COUNT {
                    qs.push(i)
                }
            });

            for _i in 0..THREADS {
                let qr = q.clone();
                s.spawn(move || {
                    let mut cur: u64 = 0;
                    for _j in 0..COUNT {
                        if let Some(new) = qr.try_pop() {
                            assert!(new > cur);
                            cur = new;
                        }
                    }
                });
            }
        }
    });
}