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

#include <NesThread.hpp>

Static Public Member Functions

static WorkerThreadId getId ()
 Call static method Thread::getId() to get the executing thread's ID. More...
 

Static Public Attributes

static constexpr WorkerThreadId::Underlying MaxNumThreads = 256
 

Friends

class ThreadId
 

Detailed Description

Gives every thread a unique, numeric thread ID, and recycles IDs when threads exit. do not use this class from components that do not belong to the worker execution engine!!!

Member Function Documentation

◆ getId()

static WorkerThreadId NES::Runtime::NesThread::getId ( )
inlinestatic

Call static method Thread::getId() to get the executing thread's ID.

Referenced by NES::Network::detail::createNetworkChannel(), NES::Runtime::DynamicQueryManager::processNextTask(), NES::Runtime::MultiQueueQueryManager::processNextTask(), NES::Network::NetworkSource::reconfigure(), NES::Network::NetworkSink::reconfigure(), NES::Runtime::ThreadPool::start(), and NES::TEST_P().

Here is the caller graph for this function:

Friends And Related Function Documentation

◆ ThreadId

friend class ThreadId
friend

Member Data Documentation

◆ MaxNumThreads

constexpr WorkerThreadId::Underlying NES::Runtime::NesThread::MaxNumThreads = 256
staticconstexpr

The number of entries in table. Currently, this is fixed at 256 and never changes or grows. If the table runs out of entries, then the current implementation will throw a std::runtime_error. do not change this value

Referenced by NES::ThreadBarrier::ThreadBarrier(), NES::ThreadBarrier::wait(), and NES::ThreadBarrier::~ThreadBarrier().


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