Struct MpscComputeChannel

pub struct MpscComputeChannel<Server>
where
    Server: ComputeServer,
{ /* private fields */ }

Create a channel using a [multi-producer, single-consumer channel to communicate with the compute server spawn on its own thread.

Implementations

impl<Server> MpscComputeChannel<Server>

where Server: ComputeServer + 'static,

pub fn new(server: Server) -> Self

Create a new mpsc compute channel.

Trait Implementations

impl<Server: ComputeServer> Clone for MpscComputeChannel<Server>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Server> ComputeChannel<Server> for MpscComputeChannel<Server>

where Server: ComputeServer + 'static,

async fn read(&self, binding: Binding) -> Vec<u8>

Given a binding, returns owned resource as bytes

fn get_resource(&self, binding: Binding) -> BindingResource<Server>

Given a resource handle, return the storage resource.

fn create(&self, data: &[u8]) -> Handle

Given a resource as bytes, stores it and returns the resource handle

fn empty(&self, size: usize) -> Handle

Reserves size bytes in the storage, and returns a handle over them

unsafe fn execute( &self, kernel: Server::Kernel, count: CubeCount, bindings: Vec<Binding>, kind: ExecutionMode, )

Executes the kernel over the given bindings.

fn flush(&self)

Flush outstanding work of the server.

async fn sync(&self)

Wait for the completion of every task in the server.

async fn sync_elapsed(&self) -> TimestampsResult

Wait for the completion of every task in the server.

fn memory_usage(&self) -> MemoryUsage

Get the current memory usage of the server.

fn enable_timestamps(&self)

Enable collecting timestamps.

fn disable_timestamps(&self)

Disable collecting timestamps.

impl<Server> Debug for MpscComputeChannel<Server>

where Server: ComputeServer + Debug,

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.