Trait parallel_processor::execution_manager::executor::AsyncExecutor

pub trait AsyncExecutor: Sized + Send + Sync + 'static {
    type InputPacket: Send + Sync + 'static;
    type OutputPacket: PacketTrait + Send + Sync + 'static;
    type GlobalParams: Send + Sync + 'static;
    type InitData: Send + Sync + Clone + 'static;
    type AsyncExecutorFuture<'a>: Future<Output = ()> + Send + 'a;

    fn new() -> Self;
    fn async_executor_main<'a>(
        &'a mut self,
        global_params: &'a Self::GlobalParams,
        receiver: ExecutorReceiver<Self>,
        memory_tracker: MemoryTracker<Self>
    ) -> Self::AsyncExecutorFuture<'a>;

    fn generate_new_address(data: Self::InitData) -> ExecutorAddress { ... }
}

Required Associated Types

type InputPacket: Send + Sync + 'static

type OutputPacket: PacketTrait + Send + Sync + 'static

type GlobalParams: Send + Sync + 'static

type InitData: Send + Sync + Clone + 'static

type AsyncExecutorFuture<'a>: Future<Output = ()> + Send + 'a

Required Methods

fn new() -> Self

fn async_executor_main<'a>(
    &'a mut self,
    global_params: &'a Self::GlobalParams,
    receiver: ExecutorReceiver<Self>,
    memory_tracker: MemoryTracker<Self>
) -> Self::AsyncExecutorFuture<'a>

Provided Methods

fn generate_new_address(data: Self::InitData) -> ExecutorAddress

Implementors