pub fn unbounded<T>() -> (OCLStream<T>, OCLStreamSender<T>)where T: Send + Sync,
Creates a new OCLStream with the corresponding sender to communicate between the scheduler thread and the receiver thread