Struct parallel_processor::execution_manager::execution_context::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)