PTL::Threading Namespace Reference

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

Functions
Pid_t	GetPidId ()
unsigned	GetNumberOfCores ()
int	GetThreadId ()
bool	IsWorkerThread ()
bool	IsMasterThread ()
void	SetThreadId (int aNewValue)
bool	SetPinAffinity (int idx, NativeThread &at)
int	WorkerThreadLeavesPool ()
int	WorkerThreadJoinsPool ()
int	GetNumberOfRunningWorkerThreads ()

Enumeration Type Documentation

anonymous enum

anonymous enum

Enumerator
SEQUENTIAL_ID
MASTER_ID
WORKER_ID
GENERICTHREAD_ID

Definition at line 207 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 64 of file Threading.cc.

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

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

GetNumberOfRunningWorkerThreads()

int PTL::Threading::GetNumberOfRunningWorkerThreads

(

)

Definition at line 122 of file Threading.cc.

{
    return numActThreads.load();
}

GetPidId()

Pid_t PTL::Threading::GetPidId

(

)

Definition at line 55 of file Threading.cc.

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

GetThreadId()

int PTL::Threading::GetThreadId

(

)

Definition at line 77 of file Threading.cc.

{
    return ThreadID;
}

IsMasterThread()

bool PTL::Threading::IsMasterThread

(

)

Definition at line 87 of file Threading.cc.

{
    return (ThreadID == MASTER_ID);
}

IsWorkerThread()

bool PTL::Threading::IsWorkerThread

(

)

Definition at line 82 of file Threading.cc.

{
    return (ThreadID >= 0);
}

SetPinAffinity()

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

Definition at line 95 of file Threading.cc.

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

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

SetThreadId()

void PTL::Threading::SetThreadId

(

int

aNewValue

)

Definition at line 72 of file Threading.cc.

{
    ThreadID = value;
}

WorkerThreadJoinsPool()

int PTL::Threading::WorkerThreadJoinsPool

(

)

Definition at line 117 of file Threading.cc.

{
    return numActThreads++;
}

WorkerThreadLeavesPool()

int PTL::Threading::WorkerThreadLeavesPool

(

)

Definition at line 112 of file Threading.cc.

{
    return numActThreads--;
}