Struct ChannelManager 

pub(crate) struct ChannelManager {
    gc_state: Mutex<GcState>,
    gc_access: RwLock<()>,
    channels: RwLock<HashMap<u64, Arc<ChannelState>>>,
    next_channel_id: AtomicU64,
    recv_count: AtomicUsize,
    gc_threshold: usize,
}

The channel manager state

Fields

gc_state: Mutex<GcState>

GC state (block, roots, and next_limit) all guarded by a single Mutex We also leak a static reference to the RootSet for HeapRoot creation

gc_access: RwLock<()>

Ensures mutual exclusion between GC and channel operations. Channel operations acquire read lock when accessing rooted data, GC acquires write lock for exclusive access during trace.

channels: RwLock<HashMap<u64, Arc<ChannelState>>>

All channels managed by this manager

next_channel_id: AtomicU64

Counter for generating unique channel IDs

recv_count: AtomicUsize

Counter for receives since last GC

gc_threshold: usize

Trigger GC after this many receives

Implementations

impl ChannelManager

fn new() -> Self

fn create_channel(&self, capacity: usize) -> u64

Create a new channel and return its ID

pub(crate) fn increment_sender(&self, channel_id: u64)

Increment sender count for a channel

pub(crate) fn increment_receiver(&self, channel_id: u64)

Increment receiver count for a channel

pub(crate) fn try_send<'ob>( &self, channel_id: u64, obj: Gc<ObjectType<'ob>>, ) -> Result<(), SendError>

Try to send an object to a channel (non-blocking)

pub(crate) fn send<'ob>( &self, channel_id: u64, obj: Gc<ObjectType<'ob>>, ) -> Result<(), SendError>

Send an object to a channel (blocking)

pub(crate) fn try_recv<'ob>( &self, channel_id: u64, target_block: &'ob Block<false>, ) -> Result<Gc<ObjectType<'ob>>, RecvError>

Try to receive an object from a channel (non-blocking)

pub(crate) fn recv<'ob>( &self, channel_id: u64, target_block: &'ob Block<false>, ) -> Result<Gc<ObjectType<'ob>>, RecvError>

Receive an object from a channel (blocking)

pub(crate) fn close_sender(&self, channel_id: u64)

Close the sender side of a channel

pub(crate) fn close_receiver(&self, channel_id: u64)

Close the receiver side of a channel

fn collect_garbage(&self)

Trigger garbage collection in the manager’s block

pub(crate) fn cleanup_channel(&self, channel_id: u64)

Remove a channel that has no more senders or receivers

impl ChannelManager

pub(crate) fn new_channel_pair(&self, capacity: usize) -> (u64, u64)

Trait Implementations

impl Send for ChannelManager

impl Sync for ChannelManager