80 : indices_(other.indices_)
90 return indices_.empty();
118 toStr(str, affinity);
189 toStr(str, settings);
230 return loopBeforeIdle_;
240 loopBeforeIdle_ = value;
259 toStr(str, settings);
279 Workhorse* workhorse_;
#define ONIXS_CMEMDH_NAMESPACE_BEGIN
#define ONIXS_CMEMDH_LTWT
#define ONIXS_CMEMDH_EXPORTED_CLASS_DECL(typeName)
#define ONIXS_CMEMDH_NAMESPACE_END
#define ONIXS_CMEMDH_NULLPTR
#define ONIXS_CMEMDH_EXPORTED
A pool of threads executing feed engine tasks.
~FeedEngineThreadPool()
Stops all tasks and destructs the working threads.
FeedEngineThreadPool(NetFeedEngine &, const FeedEngineThreadSettings &, FeedEngineThreadPoolListener *=nullptr)
const ThreadPoolSettings & pool() const
Settings related to the thread pool.
ThreadPoolSettings & pool()
Settings related to the thread pool.
void loopBeforeIdle(UInt32 value)
UInt32 loopBeforeIdle() const
FeedEngineThreadSettings()
Current thread related tasks.
static void affinity(CpuIndex)
static void affinity(const ThreadAffinity &)
Sets the processor affinity mask for the current thread.
Represents a set of CPU indices.
ThreadAffinity()
Initializes the empty set.
~ThreadAffinity()
Utilizes internal resources.
ThreadAffinity(const ThreadAffinity &other)
Initializes as a copy of the other set.
CpuIndices & cpus()
Collection of the CPU indices.
const CpuIndices & cpus() const
Read-only access to the indices.
const ThreadAffinity & affinity() const
ThreadAffinity & affinity()
~ThreadPoolSettings()
Cleans everything up.
ThreadPoolSettings & size(UInt32 value)
Defines the number of working threads in the pool.
char Char
Character type alias.
void toStr(std::string &, BookState::Enum)
Serializes book state value into a string.
TinySet< CpuIndex > CpuIndices
Alias for collection of CPU indices.
Int32 CpuIndex
Zero-based index of CPU.
virtual void onFeedEngineThreadBegin(const FeedEngineThreadPool &)
virtual bool onFeedEngineThreadIdle(const FeedEngineThreadPool &)
virtual void onFeedEngineThreadIssue(const FeedEngineThreadPool &, const Char *)
virtual void onFeedEngineThreadEnd(const FeedEngineThreadPool &)