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)