您的位置:首页 > 运维架构 > Linux

Linux进程间通信(IPC)之三——信号量(Semaphore)

2011-05-04 00:02 627 查看
信号量的数据结构是sem_t类型,他本质上是一个长整型。

#include<semaphore.h>

int sem_init(sem_t *sem , int pshared, unsigned value)

初始化一个信号量。 pshared=0 表示该信号量只能由初始化这个信号量的进程中的线程使用。如果非零,表示任何可以访问到这个信号量的进程都可以使用。 value为信号量的初始值。 成功返回0,不成功返回-1

int sem_destroy(sem_t *sem)

销毁sem。成功返回0,不成功返回-1

int sem_post(sem_t *sem)

给信号量sem的值加1. 成功返回0,不成功返回-1

int sem_wait(sem_t *sem)

给信号量sem的值减1.

如果sem的值是0,则阻塞。它永远会先等待该信号量为一个非零值才开始做减法。也就是说,如果你对 一个值为2的信号量调用sem_wait(),线程将会继续执行,介信号量的值将减到1。如果对一个值为0的信号量调用sem_wait(),这个函数就 会地等待直到有其它线程增加了这个值使它不再是0为止。如果有两个线程都在sem_wait()中等待同一个信号量变成非零值,那么当它被第三个线程增加 一个“1”时,等待线程中只有一个能够对信号量做减法并继续执行,另一个还将处于等待状态。

成功返回0,不成功返回-1

iint sem_trywait(sem_t *sem),它是sem_wait的非阻塞搭档。

信号量举例

#include<pthread.h>
#include<stdio.h>
#include<semaphore.h>
#define UPBOUND 100
sem_t sem1;
sem_t sem2;
void * threadfun1(void * arg)
{
int i=0;
while(i<UPBOUND)
{
sem_wait(&sem1);
i++;
printf("Thread 1: i = %d/n",i);
sem_post(&sem2);
}
return NULL;
}
void * threadfun2(void * arg)
{
int i=0;
while(i<UPBOUND)
{
sem_wait(&sem2);
i++;
printf("Thread 2: i = %d/n",i);
sem_post(&sem1);
}
return NULL;
}
int main()
{
pthread_t tid1,tid2;
int i = sem_init(&sem1,0,5);
printf("%d/n",i);
sem_init(&sem2,0,5);
printf("Semaphores are initialized./n");
pthread_create(&tid1,NULL,&threadfun1,NULL);
pthread_create(&tid2,NULL,&threadfun2,NULL);
printf("Threads are started/n");
pthread_join(tid1,NULL);
pthread_join(tid2,NULL);
printf("Threads finished./n");
sem_destroy(&sem1);
sem_destroy(&sem2);
return 0;
}
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: