Struct parallel_processor::execution_manager::executor::ExecutorAddressOperations

pub struct ExecutorAddressOperations<'a, E: AsyncExecutor> { /* private fields */ }

Implementations

impl<'a, E: AsyncExecutor> ExecutorAddressOperations<'a, E>

pub async fn receive_packet(&self) -> Option<Packet<E::InputPacket>>

pub fn declare_addresses(&self, addresses: Vec<ExecutorAddress>, priority: usize)

pub async fn pool_alloc_await(
    &self,
    new_size: usize
) -> Arc<PoolObject<PacketsPool<E::OutputPacket>>>

pub fn packet_send(
    &self,
    address: ExecutorAddress,
    packet: Packet<E::OutputPacket>
)

pub fn get_context(&self) -> &ExecutionContext

pub fn make_spawner(&self) -> ExecutorsSpawner<'a>

pub fn get_address(&self) -> WeakExecutorAddress

Trait Implementations

impl<'a, E: AsyncExecutor> Drop for ExecutorAddressOperations<'a, E>

fn drop(&mut self)

Executes the destructor for this type.