Struct ethcore::client::ExecutionQueue

pub struct ExecutionQueue<ITEM> where
    ITEM: 'static + Send,  { /* private fields */ }

Creates thread and uses AsyncQueue to queue and execute items that are received in queue function. Queue is restricted by max_items and will return false if we want enqueue items on full queue.

Implementations

impl<ITEM> ExecutionQueue<ITEM> where
    ITEM: 'static + Send, 

pub fn new<EXEC>(
    max_items: usize,
    batch_size: usize,
    exec: EXEC,
    symbolic_name: &str
) -> ExecutionQueue<ITEM> where
    EXEC: 'static + FnMut(Vec<ITEM, Global>) + Send, 

Create and spawn one thread that executed exec every time item is queue-ed.

pub fn enqueue(&self, item: ITEM) -> bool

Add item to queue

pub fn end(&mut self)

End execution and close thread. Pending items will be abandoned.

pub fn len(&self) -> usize

Items currently in queue.