Struct ActorHandle 

pub struct ActorHandle {
    pub actor_id: AgentId,
    /* private fields */
}

Handle to a spawned actor thread.

The learner uses ActorHandle::send_broadcast / ActorHandle::send_shutdown; the orchestrating caller consumes the handle with ActorHandle::join after learner_loop returns.

Fields

actor_id: AgentId

Which actor this handle controls.

Implementations

impl ActorHandle

pub fn send_broadcast(&self, broadcast: PolicyBroadcast) -> bool

Send a policy broadcast to this actor. Returns false when the actor has already exited (its receiver is disconnected).

pub fn send_shutdown(&self)

Ask this actor to shut down (best-effort; a dead actor is fine).

pub fn join(self) -> Result<ActorStats>

Wait for the actor thread to exit and return its stats.

Errors

Returns an error when the actor thread panicked or itself returned an error (e.g. a malformed policy broadcast).