Linux IPC POSIX 信號(hào)量

模型

#include#include#includesem_open() //初始化并打開有名信號(hào)量sem_init() //創(chuàng)建/獲得無名信號(hào)量sem_wait()/sem_trywait()/sem_timedwait()/sem_post()/sem_getvalue() //操作信號(hào)量sem_close() //退出有名信號(hào)量sem_unlink() //銷毀有名信號(hào)量sem_destroy() //銷毀無名信號(hào)量

sem_open()

//創(chuàng)建/打開一個(gè)有名信號(hào)量，成功返回新信號(hào)量的地址，失敗返回SEM_FAILED設(shè)errno// //#define SEM_FAILED ((sem_t *) 0//#define SEM_VALUE_MAX (2147483647)//Link with -pthread.sem_t *sem_open(const char *name, int oflag);sem_t *sem_open(const char *name, int oflag, mode_t mode, unsigned int value);

oflag

O_CREAT如果信號(hào)量不存在就創(chuàng)建信號(hào)量，信號(hào)量的UID被設(shè)為調(diào)用進(jìn)程的effective UID，GID被設(shè)為調(diào)用程序的GID，可以在mode指定權(quán)限O_EXCL和O_CREAT連用，確?？梢詣?chuàng)建新的信號(hào)量，如果已存在就報(bào)錯(cuò)value?:配合O_CREAT使用，設(shè)置信號(hào)量的初始值

sem_init()

//初始化無名信號(hào)量，成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_init(sem_t *sem, int pshared, unsigned int value);

sem?創(chuàng)建無名信號(hào)量的指針
pthread指定信號(hào)量是在線程間使用還是進(jìn)程間使用

0表示信號(hào)量在一個(gè)進(jìn)程內(nèi)的線程間使用，此時(shí)信號(hào)量應(yīng)該分配的在線程可見的內(nèi)存區(qū)域(eg,全局區(qū)，BSS段，堆區(qū))

非0表示信號(hào)量在進(jìn)程間使用，此時(shí)信號(hào)量應(yīng)該分配在共享內(nèi)存里，If pshared !=0,

sem_wait()/sem_trywait()/sem_timedwait()

//Link with -pthread.//成功返回降低后的信號(hào)量的值，失敗返回-1設(shè)errno//試圖占用信號(hào)量，如果信號(hào)量值>0,就-1,如果已經(jīng)=0,就block，直到>0int sem_wait(sem_t *sem);//試圖占用信號(hào)量，如果信號(hào)量已經(jīng)=0，立即報(bào)錯(cuò)int sem_trywait(sem_t *sem);//試圖占用信號(hào)量//如果信號(hào)量=0,就block abs_timeout那么久，從 Epoch, 1970-01-01 00:00:00 +0000 (UTC).開始按納秒計(jì)//如果時(shí)間到了信號(hào)量還沒>0，報(bào)錯(cuò)int sem_timedwait(sem_t *sem, const struct timespec *abs_timeout);

struct timespec { time_t tv_sec; /* Seconds */ long tv_nsec; /* Nanoseconds [0 .. 999999999] */};

sem_post()

//歸還信號(hào)量，成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_post(sem_t *sem);

sem_getvalue()

//獲得信號(hào)量sem的當(dāng)前的值，放到sval中。如果有線程正在block這個(gè)信號(hào)量，sval可能返回兩個(gè)值，0或“-正在block的線程的數(shù)目”，Linux返回0//成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_getvalue(sem_t *sem, int *sval);

sem_close()

//關(guān)閉有名信號(hào)量，成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_close(sem_t *sem);

sem_unlink()

//試圖銷毀信號(hào)量，一旦所有占用該信號(hào)量的進(jìn)程都關(guān)閉了該信號(hào)量，那么就會(huì)銷毀這個(gè)信號(hào)量//成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_unlink(const char *name);

sem_destroy()

//銷毀信號(hào)量，成功返回0,失敗返回-1設(shè)errno//Link with -pthread.int sem_destroy(sem_t *sem);

?