NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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 |
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!!!
|
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().
|
friend |
|
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().