mirror of
https://sourceware.org/git/glibc.git
synced 2024-11-06 05:10:05 +00:00
46 lines
747 B
Plaintext
46 lines
747 B
Plaintext
|
Semaphores pseudocode
|
||
|
==============================
|
||
|
|
||
|
int sem_wait(sem_t * sem);
|
||
|
int sem_trywait(sem_t * sem);
|
||
|
int sem_post(sem_t * sem);
|
||
|
int sem_getvalue(sem_t * sem, int * sval);
|
||
|
|
||
|
struct sem_t {
|
||
|
|
||
|
unsigned int count;
|
||
|
- current semaphore count, also used as a futex
|
||
|
}
|
||
|
|
||
|
sem_wait(sem_t *sem)
|
||
|
{
|
||
|
for (;;) {
|
||
|
|
||
|
if (atomic_decrement_if_positive(sem->count))
|
||
|
break;
|
||
|
|
||
|
futex_wait(&sem->count, 0)
|
||
|
}
|
||
|
}
|
||
|
|
||
|
sem_post(sem_t *sem)
|
||
|
{
|
||
|
n = atomic_increment(sem->count);
|
||
|
futex_wake(&sem->count, n);
|
||
|
}
|
||
|
|
||
|
sem_trywait(sem_t *sem)
|
||
|
{
|
||
|
if (atomic_decrement_if_positive(sem->count)) {
|
||
|
return 0;
|
||
|
} else {
|
||
|
return EAGAIN;
|
||
|
}
|
||
|
}
|
||
|
|
||
|
sem_getvalue(sem_t *sem, int *sval)
|
||
|
{
|
||
|
*sval = sem->count;
|
||
|
read_barrier();
|
||
|
}
|