sema.h

Go to the documentation of this file.

 
 
#pragma once
 
#include <cx/cx.h>
#include <cx/thread/atomic.h>
#include <cx/time/time.h>
#include <cx/utils/macros.h>
#include "aspin.h"
#include "futex.h"
 
CX_C_BEGIN
 
enum SEMA_Flags {
    SEMA_NoSpin = 0x00000001,   
};
 
typedef struct Semaphore {
    Futex ftx;            
    AdaptiveSpin aspin;   
} Semaphore;
 
void _semaInit(_Out_ Semaphore* sema, int32 count, uint32 flags);
 
#define semaInit(sema, count, ...) _semaInit(sema, count, opt_flags(__VA_ARGS__))
 
bool semaDestroy(_Pre_valid_ _Post_invalid_ Semaphore* sema);
 
bool semaTryDecTimeout(_Inout_ Semaphore* sema, int64 timeout);
 
_meta_inline bool semaTryDec(_Inout_ Semaphore* sema)
{
    int32 curcount = atomicLoad(int32, &sema->ftx.val, Relaxed);
    bool ret       = (curcount > 0 &&
                atomicCompareExchange(int32,
                                      strong,
                                      &sema->ftx.val,
                                      &curcount,
                                      curcount - 1,
                                      Acquire,
                                      Relaxed));
    if (ret)
        aspinRecordUncontended(&sema->aspin);
    return ret;
}
 
_meta_inline bool semaDec(_Inout_ Semaphore* sema)
{
    return semaTryDecTimeout(sema, timeForever);
}
 
_meta_inline bool semaInc(_Inout_ Semaphore* sema, int32 count)
{
    atomicFetchAdd(int32, &sema->ftx.val, count, Release);
    futexWakeMany(&sema->ftx, count);
    return true;
}
 
CX_C_END
 
// end of thread_sema group