nerdcruft/libcruft-util
1
0
Fork 0
Code Issues Releases Activity

job/queue: expose default_parallelism query

Browse Source
This commit is contained in:
Danny Robson 2019-03-08 09:41:44 +11:00
parent 976d44b1d9
commit e0f4fdc308
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
job/queue.cpp
View File

@ -15,8 +15,8 @@ using cruft::job::queue;
/////////////////////////////////////////////////////////////////////////////// ///////////////////////////////////////////////////////////////////////////////
static unsigned unsigned
default_parallelism (void) queue::default_parallelism (void) noexcept
{ {
if (auto var = getenv ("JOB_THREADS")) { if (auto var = getenv ("JOB_THREADS")) {
return cruft::from_string<unsigned> (var); return cruft::from_string<unsigned> (var);

2
job/queue.hpp
View File

@ -42,6 +42,8 @@ namespace cruft::job {
queue& operator= (const queue&) = delete; queue& operator= (const queue&) = delete;
queue& operator= (queue&&) = delete; queue& operator= (queue&&) = delete;
static unsigned default_parallelism (void) noexcept;
auto parallelism (void) const { return m_threads.size (); } auto parallelism (void) const { return m_threads.size (); }
auto capacity (void) const { return m_tasks.store.capacity (); } auto capacity (void) const { return m_tasks.store.capacity (); }