lf_semaphore.h

Go to the documentation of this file.

/* Semaphore utility for reactor C. */
 
 
#ifndef LF_SEMAPHORE_H
#define LF_SEMAPHORE_H
 
#ifndef NUMBER_OF_WORKERS
#define NUMBER_OF_WORKERS 1
#endif // NUMBER_OF_WORKERS
 
#include "low_level_platform.h"
#include <stdlib.h>
 
typedef struct {
  size_t count;
  lf_mutex_t mutex;
  lf_cond_t cond;
} lf_semaphore_t;
 
lf_semaphore_t* lf_semaphore_new(size_t count);
 
void lf_semaphore_release(lf_semaphore_t* semaphore, size_t i);
 
void lf_semaphore_acquire(lf_semaphore_t* semaphore);
 
void lf_semaphore_wait(lf_semaphore_t* semaphore);
 
void lf_semaphore_destroy(lf_semaphore_t* semaphore);
 
#endif // LF_SEMAPHORE_H