futex.hpp

浏览该文件的文档.

#ifndef NEFORCE_CORE_ASYNC_FUTEX_HPP__
#define NEFORCE_CORE_ASYNC_FUTEX_HPP__

 
#include "NeForce/core/typeinfo/type_traits.hpp"
NEFORCE_BEGIN_NAMESPACE__



using platform_wait_t =
#ifdef NEFORCE_PLATFORM_WINDOWS
        long;
#else
        int;
#endif
 

enum class futex_wait_flags : platform_wait_t {
#ifdef NEFORCE_PLATFORM_LINUX
    private_flag = 0x80, 
#else
    private_flag = 0, 
#endif
    wait = 0,                                         
    wake = 1,                                         
    requeue = 3,                                      
    cmp_requeue = 4,                                  
    wake_op = 5,                                      
    lock_pi = 6,                                      
    unlock_pi = 7,                                    
    trylock_pi = 8,                                   
    wait_bitset = 9,                                  
    wake_bitset = 10,                                 
    wait_requeue_pi = 11,                             
    cmp_requeue_pi = 12,                              
    wait_private = wait | private_flag,               
    wake_private = wake | private_flag,               
    wait_bitset_private = wait_bitset | private_flag, 
    wake_bitset_private = wake_bitset | private_flag, 
    bitset_match_any = -1                             
};
 

void NEFORCE_API futex_wait(void* addr, platform_wait_t value) noexcept;

bool NEFORCE_API futex_wait_until(void* addr, platform_wait_t value, bool has_timeout, int64_t sec, int64_t ns,
                                  bool is_monotonic = false);

void NEFORCE_API futex_notify(void* addr, bool all) noexcept;
 
#ifdef NEFORCE_PLATFORM_LINUX
#    define NEFORCE_FUTEX_HAS_ADVANCED 1
 
int futex(void* wait_addr, futex_wait_flags flags, int wake_count, void* requeue_addr, int requeue_count,
          int cmp_value) noexcept;

int NEFORCE_API futex_requeue(void* wait_addr, int wake_count, void* requeue_addr, int requeue_count) noexcept;

int NEFORCE_API futex_wake_op(void* addr, int wake_count, void* op_addr, int op_arg, int op, int cmp,
                              int cmp_arg) noexcept;
 
int NEFORCE_API futex_lock_pi(void* addr) noexcept;
int NEFORCE_API futex_trylock_pi(void* addr) noexcept;
int NEFORCE_API futex_unlock_pi(void* addr) noexcept;

int NEFORCE_API futex_wait_requeue_pi(void* wait_addr, int value, void* requeue_addr) noexcept;
 
#endif // NEFORCE_PLATFORM_LINUX
 // Futex
 // AsyncComponents
 
NEFORCE_END_NAMESPACE__
#endif // NEFORCE_CORE_ASYNC_FUTEX_HPP__