PTL::Threading Namespace Reference

Enumerations
enum	{ SEQUENTIAL_ID = -2 , MASTER_ID = -1 , WORKER_ID = 0 , GENERICTHREAD_ID = -1000 }

Functions
Pid_t	GetPidId ()
unsigned	GetNumberOfPhysicalCpus ()
unsigned	GetNumberOfCores ()
int	GetThreadId ()
void	SetThreadId (int aNewValue)
bool	SetPinAffinity (int idx)
bool	SetThreadPriority (int _v)
bool	SetPinAffinity (int idx, NativeThread &_t)
bool	SetThreadPriority (int _v, NativeThread &_t)

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
SEQUENTIAL_ID
MASTER_ID
WORKER_ID
GENERICTHREAD_ID

Definition at line 84 of file Threading.hh.

{
    SEQUENTIAL_ID    = -2,
    MASTER_ID        = -1,
    WORKER_ID        = 0,
    GENERICTHREAD_ID = -1000
};

Function Documentation

GetNumberOfCores()

unsigned PTL::Threading::GetNumberOfCores

(

)

Definition at line 63 of file Threading.cc.

{
    return std::thread::hardware_concurrency();
}

Referenced by PTL::ThreadPool::execute_on_all_threads(), PTL::ThreadPool::execute_on_specific_threads(), and GetNumberOfPhysicalCpus().

GetNumberOfPhysicalCpus()

unsigned PTL::Threading::GetNumberOfPhysicalCpus

(

)

Definition at line 71 of file Threading.cc.

{
#if defined(PTL_MACOS)
    int    count;
    size_t count_len = sizeof(count);
    sysctlbyname("hw.physicalcpu", &count, &count_len, nullptr, 0);
    return static_cast<unsigned>(count);
#elif defined(PTL_LINUX)
    unsigned      core_id_count = 0;
    std::ifstream ifs("/proc/cpuinfo");
    if(ifs)
    {
        std::set<std::string> core_ids;
        while(true)
        {
            std::string line = {};
            getline(ifs, line);
            if(!ifs.good())
                break;
            if(line.find("core id") != std::string::npos)
            {
                for(std::string itr : { "core id", ":", " ", "\t" })
                {
                    static auto _npos = std::string::npos;
                    auto        _pos  = _npos;
                    while((_pos = line.find(itr)) != _npos)
                        line = line.replace(_pos, itr.length(), "");
                }
                core_ids.insert(line);
            }
        }
        core_id_count = static_cast<unsigned>(core_ids.size());
        if(core_id_count > 0)
            return core_id_count;
    }
    return GetNumberOfCores();
#else
    return GetNumberOfCores();
#endif
}

GetPidId()

Pid_t PTL::Threading::GetPidId

(

)

Definition at line 54 of file Threading.cc.

{
    // In multithreaded mode return Thread ID
    return std::this_thread::get_id();
}

GetThreadId()

int PTL::Threading::GetThreadId

(

)

Definition at line 121 of file Threading.cc.

{
    return ThreadID;
}

SetPinAffinity() [1/2]

bool PTL::Threading::SetPinAffinity

(

int

idx

)

Definition at line 129 of file Threading.cc.

{
#if defined(__linux__) || defined(_AIX)
    cpu_set_t _cpu_set{};
    CPU_ZERO(&_cpu_set);
    if(_cpu >= 0)
        CPU_SET(_cpu, &_cpu_set);
    return (pthread_setaffinity_np(pthread_self(), sizeof(cpu_set_t), &_cpu_set) == 0);
#else  // Not available for Mac, WIN,...
    ConsumeParameters(_cpu);
    return true;
#endif
}

Referenced by PTL::ThreadPool::set_affinity().

SetPinAffinity() [2/2]

bool PTL::Threading::SetPinAffinity	(	int	idx,
		NativeThread &	_t
	)

Definition at line 159 of file Threading.cc.

{
#if defined(__linux__) || defined(_AIX)
    cpu_set_t _cpu_set{};
    CPU_ZERO(&_cpu_set);
    CPU_SET(_cpu, &_cpu_set);
    return (pthread_setaffinity_np(static_cast<pthread_t>(_t), sizeof(cpu_set_t),
                                   &_cpu_set) == 0);
#else  // Not available for Mac, WIN,...
    ConsumeParameters(_cpu, _t);
    return true;
#endif
}

SetThreadId()

void PTL::Threading::SetThreadId

(

int

aNewValue

)

Definition at line 115 of file Threading.cc.

{
    ThreadID = value;
}

Referenced by PTL::ThreadPool::add_thread_id(), and PTL::ThreadPool::start_thread().

SetThreadPriority() [1/2]

bool PTL::Threading::SetThreadPriority

(

int

_v

)

Definition at line 146 of file Threading.cc.

{
#if defined(__linux__) || defined(_AIX)
    return (pthread_setschedprio(pthread_self(), _prio) == 0);
#else  // Not available for Mac, WIN,...
    ConsumeParameters(_prio);
    return true;
#endif
}

Referenced by PTL::ThreadPool::set_priority().

SetThreadPriority() [2/2]

bool PTL::Threading::SetThreadPriority	(	int	_v,
		NativeThread &	_t
	)

Definition at line 176 of file Threading.cc.

{
#if defined(__linux__) || defined(_AIX)
    return (pthread_setschedprio(static_cast<pthread_t>(_t), _prio) == 0);
#else
    ConsumeParameters(_prio, _t);
    return true;
#endif
}