Bitcoin ABC 0.30.3
P2P Digital Currency
|
Queue for verifications that have to be performed. More...
#include <checkqueue.h>
Public Member Functions | |
CCheckQueue (unsigned int nBatchSizeIn) | |
Create a new check queue. More... | |
void | StartWorkerThreads (const int threads_num) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) |
Create a pool of new worker threads. More... | |
bool | Wait () EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) |
Wait until execution finishes, and return whether all evaluations were successful. More... | |
void | Add (std::vector< T > &&vChecks) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) |
Add a batch of checks to the queue. More... | |
void | StopWorkerThreads () EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) |
Stop all of the worker threads. More... | |
~CCheckQueue () | |
Public Attributes | |
Mutex | m_control_mutex |
Mutex to ensure only one concurrent CCheckQueueControl. More... | |
Private Member Functions | |
std::vector< T > queue | GUARDED_BY (m_mutex) |
The queue of elements to be processed. More... | |
int nIdle | GUARDED_BY (m_mutex) |
The number of workers (including the master) that are idle. More... | |
int nTotal | GUARDED_BY (m_mutex) |
The total number of workers (including the master). More... | |
bool fAllOk | GUARDED_BY (m_mutex) |
The temporary evaluation result. More... | |
unsigned int nTodo | GUARDED_BY (m_mutex) |
Number of verifications that haven't completed yet. More... | |
bool m_request_stop | GUARDED_BY (m_mutex) |
bool | Loop (bool fMaster) EXCLUSIVE_LOCKS_REQUIRED(!m_mutex) |
Internal function that does bulk of the verification work. More... | |
Private Attributes | |
Mutex | m_mutex |
Mutex to protect the inner state. More... | |
std::condition_variable | m_worker_cv |
Worker threads block on this when out of work. More... | |
std::condition_variable | m_master_cv |
Master thread blocks on this when out of work. More... | |
const unsigned int | nBatchSize |
The maximum number of elements to be processed in one batch. More... | |
std::vector< std::thread > | m_worker_threads |
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.
Definition at line 28 of file checkqueue.h.
|
inlineexplicit |
Create a new check queue.
Definition at line 140 of file checkqueue.h.
|
inline |
|
inline |
Add a batch of checks to the queue.
Definition at line 168 of file checkqueue.h.
|
private |
The queue of elements to be processed.
As the order of booleans doesn't matter, it is used as a LIFO (stack)
|
inlineprivate |
The number of workers (including the master) that are idle.
Definition at line 44 of file checkqueue.h.
|
inlineprivate |
The total number of workers (including the master).
Definition at line 47 of file checkqueue.h.
|
inlineprivate |
The temporary evaluation result.
Definition at line 50 of file checkqueue.h.
|
inlineprivate |
Number of verifications that haven't completed yet.
This includes elements that are no longer queued, but still in the worker's own batches.
Definition at line 57 of file checkqueue.h.
|
inlineprivate |
Definition at line 63 of file checkqueue.h.
|
inlineprivate |
Internal function that does bulk of the verification work.
Definition at line 66 of file checkqueue.h.
|
inline |
Create a pool of new worker threads.
Definition at line 144 of file checkqueue.h.
|
inline |
Stop all of the worker threads.
Definition at line 181 of file checkqueue.h.
|
inline |
Wait until execution finishes, and return whether all evaluations were successful.
Definition at line 163 of file checkqueue.h.
Mutex CCheckQueue< T >::m_control_mutex |
Mutex to ensure only one concurrent CCheckQueueControl.
Definition at line 137 of file checkqueue.h.
|
private |
Master thread blocks on this when out of work.
Definition at line 37 of file checkqueue.h.
|
private |
Mutex to protect the inner state.
Definition at line 31 of file checkqueue.h.
|
private |
Worker threads block on this when out of work.
Definition at line 34 of file checkqueue.h.
|
private |
Definition at line 62 of file checkqueue.h.
|
private |
The maximum number of elements to be processed in one batch.
Definition at line 60 of file checkqueue.h.