Agora
1.2.0
Agora project
|
Classes | |
struct | ItemT |
Functions | |
void | MasterToWorkerStaticMaster (moodycamel::ConcurrentQueue< ItemT > *queue, moodycamel::ProducerToken **ptoks) |
void | MasterToWorkerStaticWorker (size_t worker_id, moodycamel::ConcurrentQueue< ItemT > *queue, moodycamel::ProducerToken *ptok) |
TEST (TestConcurrentQueue, MasterToWorkerStatic) | |
void | WorkerToMasterMaster (moodycamel::ConcurrentQueue< ItemT > *queue) |
void | WorkerToMasterWorkerWithToken (size_t worker_id, moodycamel::ConcurrentQueue< ItemT > *queue, moodycamel::ProducerToken *ptok) |
void | WorkerToMasterWorkerWithoutToken (size_t worker_id, moodycamel::ConcurrentQueue< ItemT > *queue) |
TEST (TestConcurrentQueue, WorkerToMasterWithTokens) | |
TEST (TestConcurrentQueue, WorkerToMasterWithoutTokens) | |
int | main (int argc, char **argv) |
Variables | |
static constexpr size_t | kNumWorkers = 14 |
static constexpr size_t | kMaxTestNum = (1 << 24) |
int main | ( | int | argc, |
char ** | argv | ||
) |
void MasterToWorkerStaticMaster | ( | moodycamel::ConcurrentQueue< ItemT > * | queue, |
moodycamel::ProducerToken ** | ptoks | ||
) |
void MasterToWorkerStaticWorker | ( | size_t | worker_id, |
moodycamel::ConcurrentQueue< ItemT > * | queue, | ||
moodycamel::ProducerToken * | ptok | ||
) |
TEST | ( | TestConcurrentQueue | , |
MasterToWorkerStatic | |||
) |
TEST | ( | TestConcurrentQueue | , |
WorkerToMasterWithoutTokens | |||
) |
TEST | ( | TestConcurrentQueue | , |
WorkerToMasterWithTokens | |||
) |
void WorkerToMasterMaster | ( | moodycamel::ConcurrentQueue< ItemT > * | queue | ) |
void WorkerToMasterWorkerWithoutToken | ( | size_t | worker_id, |
moodycamel::ConcurrentQueue< ItemT > * | queue | ||
) |
void WorkerToMasterWorkerWithToken | ( | size_t | worker_id, |
moodycamel::ConcurrentQueue< ItemT > * | queue, | ||
moodycamel::ProducerToken * | ptok | ||
) |
|
staticconstexpr |
|
staticconstexpr |