NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
Utility class that introduce a barrier for N threads. The barrier resets when N threads call wait(). More...
#include <ThreadBarrier.hpp>
Public Member Functions | |
ThreadBarrier (uint32_t size) | |
Create a Barrier for size threads. More... | |
ThreadBarrier ()=delete | |
ThreadBarrier (const ThreadBarrier &)=delete | |
ThreadBarrier & | operator= (const ThreadBarrier &)=delete |
~ThreadBarrier () | |
void | wait () |
This method will block the calling thread until N threads have invoke wait(). More... | |
Utility class that introduce a barrier for N threads. The barrier resets when N threads call wait().
|
inlineexplicit |
Create a Barrier for size threads.
size |
References NES::Runtime::NesThread::MaxNumThreads, NES_ASSERT2_FMT, and size().
|
delete |
|
delete |
|
inline |
References NES::Runtime::NesThread::MaxNumThreads, and NES_ASSERT2_FMT.
|
delete |
|
inline |
This method will block the calling thread until N threads have invoke wait().
References NES::Runtime::NesThread::MaxNumThreads, and NES_ASSERT2_FMT.