linux信号量机制.docVIP

linux信号量机制（semaphore）/* File sem.c */ #include stdio.h #include pthread.h #include semaphore.h #define MAXSTACK 100 int stack[MAXSTACK][2]; int size=0; sem_t sem; /* 从文件1.dat读取数据，每读一次，信号量加一*/ void ReadData1(void){ FILE *fp=fopen(1.dat,r); while(!feof(fp)){ fscanf(fp,%d %d,stack[size][0],stack[size][1]); sem_post(sem); ++size; } fclose(fp); } /*从文件2.dat读取数据*/ void ReadData2(void){ FILE *fp=fopen(2.dat,r); while(!feof(fp)){ fscanf(fp,%d %d,stack[size][0],stack[size][1]); sem_post(sem); ++size; } fclose(fp); } /*阻塞等待缓冲区有数据，读取数据后，释放空间，继续等待*/ void HandleData1(void){ while(1){ sem_wait(sem); printf(Plus:%d+%d=%d\n,stack[size][0],stack[size][1], stack[size][0]+stack[size][1]); --size; } } void HandleData2(void){ while(1){ sem_wait(sem); printf(Multiply:%d*%d=%d\n,stack[size][0],stack[size][1], stack[size][0]*stack[size][1]); --size; } } int main(void){ pthread_t t1,t2,t3,t4; sem_init(sem,0,0); pthread_create(t1,NULL,(void *)HandleData1,NULL); pthread_create(t2,NULL,(void *)HandleData2,NULL); pthread_create(t3,NULL,(void *)ReadData1,NULL); pthread_create(t4,NULL,(void *)ReadData2,NULL); /* 防止程序过早退出，让它在此无限期等待*/ pthread_join(t1,NULL); } 　　在Linux下，用命令gcc -lpthread sem.c -o sem生成可执行文件sem。 事先编辑好数据文件1.dat和2.dat，假设它们的内容分别为1 2 3 4 5 6 7 8 9 10和 -1 -2 -3 -4 -5 -6 -7 -8 -9 -10 ，运行./sem，得到如下的结果： Multiply:-1*-2=2 Plus:-1+-2=-3 Multiply:9*10=90 Plus:-9+-10=-19 Multiply:-7*-8=56 Plus:-5+-6=-11 Multiply:-3*-4=12 Plus:9+10=19 Plus:7+8=15 Plus:5+6=11 　　从中可以看出各个线程间的竞争关系。而数值并未按我们原先的顺序显示出来这是由于size这个数值被各个线程任意修改的缘故。这也往往是多线程编程要注意的问题 信号量和临界区 wait(s) critical section signal(s); remainder section b：线程同步 process 1 executes: process 2 executes: a; wait(sync); signal(sync); b; 3. POSIX:SEM无名信号量 信号量是一个sem_t类型的变量，有相关的原子操作来对它的值进行初始化、增量和减量操作。如果一个实现在unistd.h中定义了_POSIX_SEMAPHORES,那么这个实现就支持POSIX:SEM信号量。无名信号量和命名信号量之间的区别类似于普通管道和命名管道之间的区别 信号量的申明： #include semaphore.h sem_t sem; 信号量的初始化：必须在使用信号量之前对其进行初始化 #include semaphore.h int sem_init(sem_t *sem, int psh