|
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.