|
|
|
@ -59,9 +59,6 @@ private:
@@ -59,9 +59,6 @@ private:
|
|
|
|
|
*/ |
|
|
|
|
unsigned int nTodo; |
|
|
|
|
|
|
|
|
|
//! Whether we're shutting down.
|
|
|
|
|
bool fQuit; |
|
|
|
|
|
|
|
|
|
//! The maximum number of elements to be processed in one batch
|
|
|
|
|
unsigned int nBatchSize; |
|
|
|
|
|
|
|
|
@ -89,7 +86,7 @@ private:
@@ -89,7 +86,7 @@ private:
|
|
|
|
|
} |
|
|
|
|
// logically, the do loop starts here
|
|
|
|
|
while (queue.empty()) { |
|
|
|
|
if ((fMaster || fQuit) && nTodo == 0) { |
|
|
|
|
if (fMaster && nTodo == 0) { |
|
|
|
|
nTotal--; |
|
|
|
|
bool fRet = fAllOk; |
|
|
|
|
// reset the status for new work later
|
|
|
|
@ -131,7 +128,7 @@ public:
@@ -131,7 +128,7 @@ public:
|
|
|
|
|
boost::mutex ControlMutex; |
|
|
|
|
|
|
|
|
|
//! Create a new check queue
|
|
|
|
|
explicit CCheckQueue(unsigned int nBatchSizeIn) : nIdle(0), nTotal(0), fAllOk(true), nTodo(0), fQuit(false), nBatchSize(nBatchSizeIn) {} |
|
|
|
|
explicit CCheckQueue(unsigned int nBatchSizeIn) : nIdle(0), nTotal(0), fAllOk(true), nTodo(0), nBatchSize(nBatchSizeIn) {} |
|
|
|
|
|
|
|
|
|
//! Worker thread
|
|
|
|
|
void Thread() |
|
|
|
|