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