linux下semaphore的⽤法,c++semaphore信号量的使⽤
前⾔
⽬前⽹上可以查到很多关于信号量的实现⽂章,但是讲解在linux下使⽤semaphore的⽂章⽐较少;
c++ linux semaphore信号量的使⽤
⼀、c++中semaphore在Linux下使⽤
1、sem_init函数
sem_init函数是Posix信号量操作中的函数。sem_init() 初始化⼀个定位在 sem 的匿名信号量。value 参数指定信号量的初始值。pshared 参数指明信号量是由进程内线程共享,还是由进程之间共享。如果 pshared 的值为 0,那么信号量将被进程内的线程共享,并且应该放置在这个进程的所有线程都可见的地址上(如全局变量,或者堆上动态分配的变量)。
如果 pshared 是⾮零值,那么信号量将在进程之间共享,并且应该定位共享内存区域(见 shm_open(3)、mmap(2) 和 shmget(2))。因为通过 fork(2) 创建的孩⼦继承其⽗亲的内存映射,因此它也可以见到这个信号量。所有可以访问共享内存区域的进程都可以⽤
sem_post(3)、sem_wait(3) 等等操作信号量。初始化⼀个已经初始的信号量其结果未定义。
#include
// 初始化
int sem_init(sem_t *sem,int pshared,unsigned int value);
返回值 :
sem_init() 成功时返回 0;错误时,返回 -1,并把 errno 设置为合适的值。
2、semaphore相关函数
// 销毁
int sem_destroy(sem_t *sem);
//
int sem_wait(sem_t *sem); // 资源减少1
int sem_trywait(sem_t *sem);
int sem_post(sem_t *sem); // 资源增加1
int sem_getvalue(sem_t *sem);
例⼦:
#include // printf(),
#include // exit(), EXIT_SUCCESS
#include // pthread_create(), pthread_join()
#include // sem_init()
// g++ -lpthread pthread_create_semaphore.cpp
sem_t binSem;
void* helloWorld(void* arg);
int main() {
// Result for System call
res = sem_init(&binSem, 0, 0);
if (res) {
printf("Semaphore initialization failed!!\n");
exit(EXIT_FAILURE);
}
// Create thread
pthread_t thdHelloWorld;
// 第⼀个参数是要绑定的线程对象
// 第⼆个参数是可以被⽤来设置线程属性,⼀般使⽤NULL
/
/ 第三个参数需要绑定的函数名称
// 第四个参数是函数传⼊的参数
res = pthread_create(&thdHelloWorld, NULL, helloWorld, NULL); if (res) {
printf("Thread creation failed!!\n");
exit(EXIT_FAILURE);
}
while(1) {
// Post semaphore
sem_post(&binSem);
printf("In main, sleep several seconds.\n");
sleep(1);
linux下的sleep函数}
// Wait for thread synchronization
void *threadResult;
res = pthread_join(thdHelloWorld, &threadResult);
if (res) {
printf("Thread join failed!!\n");
exit(EXIT_FAILURE);
}
exit(EXIT_SUCCESS);
}
void* helloWorld(void* arg) {
sem_wait(&binSem); printf("Hello World\n"); }
}

版权声明:本站内容均来自互联网,仅供演示用,请勿用于商业和其他非法用途。如果侵犯了您的权益请与我们联系QQ:729038198,我们将在24小时内删除。