Struct smartpool_spatial::SpatialChannel

pub struct SpatialChannel<S: CoordSpace> where
    S::Coord: Copy,  {
    pub focus: Arc<Atomic<S::Coord>>,
    // some fields omitted
}

A priority channel based on the manhattan tree, where each task corresponds to a coordinate in some coordinate space. A shared, atomic coordinate focus is stored, which can be shared between multiple SpatialChannels, and modified externally. The SpatialChannel will always execute the task with the lowest manhattan distance to the current value of the focus.

Fields

focus: Arc<Atomic<S::Coord>>

Methods

impl<S: CoordSpace> SpatialChannel<S> where
    S::Coord: Copy, 

pub fn new(focus: Arc<Atomic<S::Coord>>, space: S) -> Self

Trait Implementations

impl<S: CoordSpace + Default> Default for SpatialChannel<S> where
    S::Coord: Copy + ZeroCoord, 

fn default() -> Self

Returns the "default value" for a type.

impl<S: CoordSpace> Channel for SpatialChannel<S> where
    S::Coord: Copy, 

fn assign_bits(
    &mut self,
    assigner: &mut BitAssigner
) -> Result<(), NotEnoughBits>

fn poll(&self) -> Option<RunningTask>

fn into_shared(self) -> Arc<RwLock<Self>>

Wrap self in a reference counted read/write lock, which is still a channel, and can have shared ownership, allowing it to be used in a scheduler.

impl<S: CoordSpace> ExecParam for SpatialChannel<S> where
    S::Coord: Copy, 

type Param = S::Coord

fn submit(&self, task: RunningTask, param: S::Coord)

Submit a raw running task.

fn exec<impl Future + Send + 'static>(
    &self,
    future: impl Future + Send + 'static,
    param: Self::Param
) where
    impl Future + Send + 'static: 'static + Send + Future<Item = (), Error = ()>, 

Execute a future on this channel.

fn exec_push<I, E, impl Future + Send + 'static>(
    &self,
    future: impl Future + Send + 'static,
    param: Self::Param
) -> PushFutureRecv<I, E> where
    E: 'static + Send,
    I: 'static + Send,
    impl Future + Send + 'static: 'static + Send + Future<Item = I, Error = E>, 

Execute a future on this channel, and push the result to a push future.