Struct OCLStreamExecutor 

pub struct OCLStreamExecutor { /* private fields */ }

Stream executor for OpenCL Programs

Implementations

impl OCLStreamExecutor

pub fn new(pro_que: ProQue) -> Self

Creates a new OpenCL Stream executor

use ocl::ProQue;
use ocl_stream::OCLStreamExecutor;
let pro_que = ProQue::builder().src("__kernel void bench_int() {}").build().unwrap();
let executor = OCLStreamExecutor::new(pro_que);

pub fn set_concurrency(&mut self, num_tasks: usize)

Sets how many threads should be used to schedule kernels on the gpu. Using multiple threads reduces the idle time of the gpu. While one kernel is running, the next one can be prepared in a different thread. A value of 0 means that the number of cpu cores should be used.

pub fn execute_bounded<F, T>(&self, size: usize, func: F) -> OCLStream<T>

where F: Fn(ExecutorContext<T>) -> OCLStreamResult<()> + Send + Sync + 'static, T: Send + Sync + 'static,

Executes a closure in the ocl context with a bounded channel

pub fn pro_que(&self) -> &ProQue

Returns the inner pro_que object

pub fn execute_unbounded<F, T>(&self, func: F) -> OCLStream<T>

where F: Fn(ExecutorContext<T>) -> OCLStreamResult<()> + Send + Sync + 'static, T: Send + Sync + 'static,

Executes a closure in the ocl context with an unbounded channel for streaming

pub fn create_shared_buffer<T>(&self, len: usize) -> Result<SharedBuffer<T>>

where T: OclPrm,

Creates a new shard buffer with a given length

Trait Implementations

impl Clone for OCLStreamExecutor

fn clone(&self) -> OCLStreamExecutor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.