C语言多线程同步 -- 信号量semaphore.h

多线程读文件使用fopen，出现BUG，然后寻找同步方法，找到这个“信号量“。

首先需要用sem_init(); 初始化sem_t型变量，并设置初始信号量。比如设置为1.

每次调用sem_wait(sem_t *); 信号量减一，当调用sem_post(sem_t *); 信号量加一。

当信号量为0时，sem_wait(); 函数阻塞，等待信号量 >0 时，才进行。

#include <stdio.h>
#include <pthread.h>
#include <semaphore.h>
typedef struct{
	sem_t *lock;
	int num;
}STRUCT;
void test(void * obj)
{
	STRUCT *point = (STRUCT *)obj;
	sem_t *semlock = point->lock;
	sem_wait(semlock);
	FILE *f = fopen("test.txt","a");
	if(f==NULL)
		printf("fopen is wrong\n");
	printf("sem_wait %d\n",point->num);
	int j=0;
	for(j=0;j<30;j++)
	fprintf(f,"%c111111111111\n",'a'+point->num);
	fclose(f);
	sem_post(semlock);

	return;
}


int main()
{
	pthread_t pid[20];  //  pthread_t pid;
	int ret,i=0;
	STRUCT obj[13];
	sem_t semlock;
	if(sem_init(&semlock,0,1)!=0)    // 此处初始信号量设为1. 第二个参数为0表示不应用于其他进程。
		printf("sem_init is wrong\n");
	for(i=0;i<10;i++)
	{
		obj[i].num = i;
		obj[i].lock = &semlock;
		ret = pthread_create(&pid[i],NULL,(void *)test,&obj[i]);
	
		if(ret!=0)
		{
			printf("create thread wrong %d!!\n",i);
			return 0;
		}
		
	}
	for(i=0;i<10;i++)
		pthread_join(pid[i],NULL);  // 等待其他线程结束，如果没有这里，主线程先结束，会释放pid[]及obj[]，则出现BUG。 
	return 0;
}