Struct ocl_stream::executor::OCLStreamExecutor

pub struct OCLStreamExecutor { /* fields omitted */ }

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, mut 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

pub fn clone(&self) -> OCLStreamExecutor

Returns a copy of the value.

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

Performs copy-assignment from source.