agenda 0.0.1

Safe collections that can be mutated while being iterated through
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16


use rayon::iter::ParallelIterator;

use Queue;

use std::sync::Mutex;
use std::sync::Arc;

pub struct ParQueue<T>(Arc<Mutex<Queue<T>>>);

impl<'a, T: Send + Sync> ParallelIterator for ParQueue<T> {
    type Item = T;
    //fn drive_unindexed(self

}