hayodea
89947dfc71
This mnemonically ensures that we'll remember to check for these kinds of async loops.
49 lines
830 B
C++
49 lines
830 B
C++
#ifndef ASYNCHRONOUS_LOOP_H
|
|
#define ASYNCHRONOUS_LOOP_H
|
|
|
|
#include <atomic>
|
|
|
|
namespace smo {
|
|
|
|
class AsynchronousLoop
|
|
{
|
|
public:
|
|
AsynchronousLoop(
|
|
const unsigned int nTotal,
|
|
unsigned int nSucceeded=0, unsigned int nFailed=0)
|
|
: nTotal(nTotal), nSucceeded(nSucceeded), nFailed(nFailed)
|
|
{}
|
|
|
|
bool isComplete(void) const
|
|
{
|
|
return nSucceeded + nFailed == nTotal;
|
|
}
|
|
|
|
void incrementSuccessOrFailureDueTo(bool success)
|
|
{
|
|
if (success)
|
|
{ ++nSucceeded; }
|
|
else
|
|
{ ++nFailed; }
|
|
}
|
|
|
|
bool incrementSuccessOrFailureAndTestForCompletionDueTo(bool success)
|
|
{
|
|
incrementSuccessOrFailureDueTo(success);
|
|
return isComplete();
|
|
}
|
|
|
|
bool nTotalIsZero(void) const
|
|
{
|
|
return nTotal == 0;
|
|
}
|
|
|
|
public:
|
|
const unsigned int nTotal;
|
|
std::atomic<unsigned int> nSucceeded, nFailed;
|
|
};
|
|
|
|
} // namespace smo
|
|
|
|
#endif // ASYNCHRONOUS_LOOP_H
|