Struct CheckQueue

pub struct CheckQueue<T> { /* private fields */ }

| Queue for verifications that have to | be performed. | | The verifications are represented | by a type T, which must provide an operator(), | returning a bool. | | One thread (the master) is assumed to | push batches of verifications onto | the queue, where they are processed | by N-1 worker threads. When the master | is done adding work, it temporarily | joins the worker pool as an N’th worker, | until all jobs are done. |

Implementations

impl<T> CheckQueue<T>

pub fn loop_(&mut self, master: bool) -> bool

| Internal function that does bulk of | the verification work. |

pub fn new(n_batch_size_in: u32) -> Self

| Create a new check queue |

pub fn start_worker_threads(&mut self, threads_num: i32)

| Create a pool of new worker threads. |

pub fn wait(&mut self) -> bool

| Wait until execution finishes, and | return whether all evaluations were | successful. |

pub fn add(&mut self, checks: &mut Vec<T>)

| Add a batch of checks to the queue |

pub fn stop_worker_threads(&mut self)

| Stop all of the worker threads. |

Trait Implementations

impl<T> Drop for CheckQueue<T>

fn drop(&mut self)

Executes the destructor for this type.