Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

use sched_yield() instead of non-standard pthread_yield()

Browse source 
Signed-off-by: Steffen Vogel <post@steffenvogel.de>
This commit is contained in:
Steffen Vogel 2022-12-02 18:22:28 +01:00
parent 31d6e25c5f
commit de013aca25
1 changed files with 9 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
tests/unit/queue.cpp
View file

@ -79,7 +79,7 @@ static void * producer(void *ctx)
/* Wait for global start signal */
while (p->start == 0)
pthread_yield();
sched_yield();
/* Wait for a random time */
for (size_t i = 0; i != nops; i += 1)
@ -89,7 +89,7 @@ static void * producer(void *ctx)
for (intptr_t count = 0; count < p->iter_count; count++) {
do {
ret = queue_push(&p->queue, (void *) count);
pthread_yield();
sched_yield();
} while (ret != 1);
}
@ -106,7 +106,7 @@ static void * consumer(void *ctx)
/* Wait for global start signal */
while (p->start == 0)
pthread_yield();
sched_yield();
/* Wait for a random time */
for (size_t i = 0; i != nops; i += 1)
@ -138,7 +138,7 @@ void * producer_consumer(void *ctx)
/* Wait for global start signal */
while (p->start == 0)
pthread_yield();
sched_yield();
/* Wait for a random time */
for (size_t i = 0; i != nops; i += 1)
@ -150,13 +150,13 @@ void * producer_consumer(void *ctx)
for (intptr_t i = 0; i < p->batch_size; i++) {
void *ptr = (void *) (iter * p->batch_size + i);
while (!queue_push(&p->queue, ptr))
pthread_yield(); /* queue full, let other threads proceed */
sched_yield(); /* queue full, let other threads proceed */
}
for (intptr_t i = 0; i < p->batch_size; i++) {
void *ptr;
while (!queue_pull(&p->queue, &ptr))
pthread_yield(); /* queue empty, let other threads proceed */
sched_yield(); /* queue empty, let other threads proceed */
}
}
@ -172,7 +172,7 @@ void * producer_consumer_many(void *ctx)
/* Wait for global start signal */
while (p->start == 0)
pthread_yield();
sched_yield();
/* Wait for a random time */
for (size_t i = 0; i != nops; i += 1)
@ -190,14 +190,14 @@ void * producer_consumer_many(void *ctx)
do {
pushed += queue_push_many(&p->queue, &ptrs[pushed], p->batch_size - pushed);
if (pushed != p->batch_size)
pthread_yield(); /* queue full, let other threads proceed */
sched_yield(); /* queue full, let other threads proceed */
} while (pushed < p->batch_size);
int pulled = 0;
do {
pulled += queue_pull_many(&p->queue, &ptrs[pulled], p->batch_size - pulled);
if (pulled != p->batch_size)
pthread_yield(); /* queue empty, let other threads proceed */
sched_yield(); /* queue empty, let other threads proceed */
} while (pulled < p->batch_size);
}