Struct CpuRuntime 

pub struct CpuRuntime {
    node_id: u64,
    kernels: RwLock<RawRwLock, HashMap<KernelId, Arc<CpuKernel>>>,
    total_launched: AtomicU64,
    messages_sent: AtomicU64,
    messages_received: AtomicU64,
    shutdown: RwLock<RawRwLock, bool>,
    k2k_broker: Option<Arc<K2KBroker>>,
}

CPU-based implementation of RingKernelRuntime.

This runtime executes kernels on the CPU, simulating GPU behavior. It’s primarily used for testing and as a fallback when no GPU is available.

Fields

node_id: u64

kernels: RwLock<RawRwLock, HashMap<KernelId, Arc<CpuKernel>>>

total_launched: AtomicU64

messages_sent: AtomicU64

messages_received: AtomicU64

shutdown: RwLock<RawRwLock, bool>

k2k_broker: Option<Arc<K2KBroker>>

Implementations

impl CpuRuntime

pub async fn new() -> Result<CpuRuntime, RingKernelError>

Create a new CPU runtime.

pub async fn with_node_id(node_id: u64) -> Result<CpuRuntime, RingKernelError>

Create a CPU runtime with specific node ID.

pub async fn with_config( node_id: u64, enable_k2k: bool, ) -> Result<CpuRuntime, RingKernelError>

Create a CPU runtime with configuration options.

pub async fn with_k2k_config( node_id: u64, k2k_config: K2KConfig, ) -> Result<CpuRuntime, RingKernelError>

Create a CPU runtime with custom K2K configuration.

pub fn node_id(&self) -> u64

Get node ID.

pub fn is_shutdown(&self) -> bool

Check if runtime is shut down.

pub fn is_k2k_enabled(&self) -> bool

Check if K2K messaging is enabled.

pub fn k2k_broker(&self) -> Option<&Arc<K2KBroker>>

Get the K2K broker (if enabled).

Trait Implementations

impl Drop for CpuRuntime

fn drop(&mut self)

Executes the destructor for this type.

impl RingKernelRuntime for CpuRuntime

fn backend(&self) -> Backend

Get the backend type.

fn is_backend_available(&self, backend: Backend) -> bool

Check if a specific backend is available.

fn launch<'life0, 'life1, 'async_trait>( &'life0 self, kernel_id: &'life1 str, options: LaunchOptions, ) -> Pin<Box<dyn Future<Output = Result<KernelHandle, RingKernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, 'life1: 'async_trait, CpuRuntime: 'async_trait,

Launch a kernel.

fn get_kernel(&self, kernel_id: &KernelId) -> Option<KernelHandle>

Get a handle to an existing kernel.

fn list_kernels(&self) -> Vec<KernelId>

List all kernel IDs.

fn metrics(&self) -> RuntimeMetrics

Get runtime metrics.

fn shutdown<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), RingKernelError>> + Send + 'async_trait>>

where 'life0: 'async_trait, CpuRuntime: 'async_trait,

Shutdown the runtime and terminate all kernels.