NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::ThreadBarrier Class Reference

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
 
ThreadBarrieroperator= (const ThreadBarrier &)=delete
 
 ~ThreadBarrier ()
 
void wait ()
 This method will block the calling thread until N threads have invoke wait(). More...
 

Detailed Description

Utility class that introduce a barrier for N threads. The barrier resets when N threads call wait().

Constructor & Destructor Documentation

◆ ThreadBarrier() [1/3]

NES::ThreadBarrier::ThreadBarrier ( uint32_t  size)
inlineexplicit

Create a Barrier for size threads.

Parameters
size

References NES::Runtime::NesThread::MaxNumThreads, NES_ASSERT2_FMT, and size().

Here is the call graph for this function:

◆ ThreadBarrier() [2/3]

NES::ThreadBarrier::ThreadBarrier ( )
delete

◆ ThreadBarrier() [3/3]

NES::ThreadBarrier::ThreadBarrier ( const ThreadBarrier )
delete

◆ ~ThreadBarrier()

NES::ThreadBarrier::~ThreadBarrier ( )
inline

Member Function Documentation

◆ operator=()

ThreadBarrier& NES::ThreadBarrier::operator= ( const ThreadBarrier )
delete

◆ wait()

void NES::ThreadBarrier::wait ( )
inline

This method will block the calling thread until N threads have invoke wait().

References NES::Runtime::NesThread::MaxNumThreads, and NES_ASSERT2_FMT.


The documentation for this class was generated from the following file: