Linux操作系统下的多线程编程详细解析

　　函数sem_post( sem_t *sem )用来增加信号量的值。当有线程阻塞在这个信号量上时，调用这个函数会使其中的一个线程不在阻塞，选择机制同样是由线程的调度策略决定的。

　　函数sem_wait( sem_t *sem )被用来阻塞当前线程直到信号量sem的值大于0，解除阻塞后将sem的值减一，表明公共资源经使用后减少。函数sem_trywait ( sem_t *sem )是函数sem_wait（）的非阻塞版本，它直接将信号量sem的值减一。

　　函数sem_destroy(sem_t *sem)用来释放信号量sem。

　　下面我们来看一个使用信号量的例子。在这个例子中，一共有4个线程，其中两个线程负责从文件读取数据到公共的缓冲区，另两个线程从缓冲区读取数据作不同的处理（加和乘运算）。

/* File sem.c */ #include #include #include #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=%dn",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=%dn",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); }