用两个信号量实现线程同步

#include <stdio.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <sys/types.h>
#include <sys/stat.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
char buf[32];//创建一个缓冲区
sem_t sem_r,sem_w;//定义全局信号量对象
void *function(void *arg);//线程执行的函数
int main(int argc, const char *argv[])
{
	pthread_t a_thread;
	//信号量初始化
	if(sem_init(&sem_r,0,0)<0)
	{
		perror("sem_init");
		exit(-1);
	}
	if(sem_init(&sem_w,0,1)<0)
	{
		perror("sem_init");
		exit(-1);
	}

	if(pthread_create(&a_thread,NULL,function,NULL)!=0)
	{
		printf("线程创建失败\n");
		exit(-1);
	}
	printf("输入“quit”退出\n");
	do{
		sem_wait(&sem_w);//执行p操作，判断有无可写的缓存区
		fgets(buf,32,stdin); 
		sem_post(&sem_r);//写完缓冲区进行v操作唤醒读线程来从缓冲区内读数据
	}while(strncmp(buf,"quit",4)!=0);

	return 0;
}


void *function(void *arg)
{
	while(1)
	{
		sem_wait(&sem_r);//进行p操作，检查是否有可读信号区
		printf("输入字符的个数为%ld\n",strlen(buf));
		sem_post(&sem_w);//缓冲区读完数据进行v操作唤醒写线程在缓冲区里写数据
	}
}