Struct ExecutionContext

pub struct ExecutionContext { /* private fields */ }

Implementations

impl ExecutionContext

pub fn new() -> Arc<Self>

pub fn register_executor_type<E: AsyncExecutor>( &self, executors_max_count: usize, pool_alloc_mode: PoolAllocMode, pool_init_data: <E::OutputPacket as PoolObjectTrait>::InitData, )

pub fn get_allocated_executors(&self, executor_type_id: &TypeId) -> u64

pub fn register_executors_batch( self: &Arc<Self>, executors: Vec<ExecutorAddress>, priority: usize, )

pub fn send_packet<T: PacketTrait>( &self, addr: ExecutorAddress, packet: Packet<T>, )

pub fn start(&self)

pub fn wait_for_completion<E: AsyncExecutor>(&self, _handle: ExecutorsHandle<E>)

pub fn get_pending_executors_count<E: AsyncExecutor>( &self, _handle: ExecutorsHandle<E>, ) -> u64

pub fn join_all(&self)