Struct cubecl_core::channel::RefCellComputeChannel

pub struct RefCellComputeChannel<Server> { /* private fields */ }

A channel using a ref cell to access the server with mutability.

Important

Only use this channel if you don’t use any threading in your application, otherwise it will panic or cause undefined behaviors.

This is mosly useful for no-std environments where threads aren’t supported, otherwise prefer the mutex or the mpsc channels.

Implementations

impl<Server> RefCellComputeChannel<Server>

where Server: ComputeServer,

pub fn new(server: Server) -> RefCellComputeChannel<Server>

Create a new cell compute channel.

Trait Implementations

impl<S> Clone for RefCellComputeChannel<S>

fn clone(&self) -> RefCellComputeChannel<S>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<Server> ComputeChannel<Server> for RefCellComputeChannel<Server>

where Server: ComputeServer + Send,

fn read( &self, binding: Binding<Server>, ) -> Pin<Box<dyn Future<Output = Vec<u8>> + Send>>

Given a binding, returns owned resource as bytes

fn get_resource( &self, binding: Binding<Server>, ) -> <<Server as ComputeServer>::Storage as ComputeStorage>::Resource

Given a resource handle, return the storage resource.

fn create(&self, resource: &[u8]) -> Handle<Server>

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

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

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

unsafe fn execute( &self, kernel_description: <Server as ComputeServer>::Kernel, count: <Server as ComputeServer>::DispatchOptions, bindings: Vec<Binding<Server>>, kind: ExecutionMode, )

Executes the kernel over the given bindings.

fn sync(&self, sync_type: SyncType)

Perform some synchronization of commands on the server.

impl<Server> Debug for RefCellComputeChannel<Server>

where Server: Debug,

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

Formats the value using the given formatter.

impl<Server> Send for RefCellComputeChannel<Server>

where Server: ComputeServer,

This is unsafe, since no concurrency is supported by the RefCell channel. However using this channel should only be done in single threaded environments such as no-std.

impl<Server> Sync for RefCellComputeChannel<Server>

where Server: ComputeServer,