信号量--System V信号量 与 Posix信号量

#include<sys/type.h>
#include<sys/ipc.h>
#include<sys/sem.h>

int semget(key_t key,int nsems,int semflg);
/*
nsems:创建多少个
semflg:IPC_CREAT、IPC_EXCL;
*/

typedef int sem_t;
union semun
{
	int val;				
	struct semid_ds *buf;	//semid_ds的指针
	unsigned short *array;	//数组类型
} arg;						//定义一个全局变量

sem_t CreateSem(key_t key,int value)
{
	union semun sem;	//信号量结构变量
	sem_t sem_id;
	sem.val = value;	//设置初始值

	sem_id = semget(key,0,IPC_CREAT|0666);	//获取信号量id
	if(sem_id == -1)
	{
		printf("create sem failedn");
	 	exit(-1);
	}
	semctl(sem_id,0,SETVAL,sem);			//发送命令，建立value个初始信号量
	return sem_id;
}

/*
参数释义：
struct sembuf
{
	ushort sem_num;	//信号量的编号
	short sem_op;	//信号量的操作 {正负零}	
	short sem_flg;	//信号量的操作标志 {NOWAIT}
};
//sem_op取0表示将信号量设为睡眠状态，直到信号量的值为0为止

nsops：该数组中操作的个数
*/

int Sem_P(sem_t semid)
{
	struct sembuf sops = {0,+1,IPC_NOWAIT};
	return (semop(semid,&sops,1));
}

intSem_V(sem_t semid)
{
	struct sembuf sops = {0,-1,IPC_NOWAIT};
	return (semop(semid,&sops,1));
}

#include<sys/type.h>
#include<sys/ipc.h>
#include<sys/sem.h>
int semctl(int semid,int semnum,int cmd,...);

/*
该函数是在信号量的集合上执行控制操作函数。
参数释义：
semnum：将要被执行操作的信号量编号。对于集合中的第一个信号量，它的值为0。
cmd：
	IPC_STAT:获取某个集合的semid_ds结构，并把它存在semun联合体的buf中。
	IPC_SET：设置某个集合的semid_ds中的ipc_perm成员的值。该命令所取值从buf中获取。
	IPC_RMID：从内核删除该集合。
	GETTALL：用于获取集合中所有的信号量的值，存放在semun联合体的array中。
	GETPID：返回最后一次调用semop的PID。
	GETVAL：返回集合中某个信号量的值。
	GETZCNT：返回正在等待资源利用率达到百分百的进程的数目。
	SETALL：把集合中所有信号量的值设置为semun联合体中array中的值。
	SETVAL：把集合中某个信号量的值设置为semun联合体中val的值。
*/

void DestroySem(sem_t semid)
{
	union semun sem;
	sem.val = 0;
	se,ctl(semid,0,IPC_RMID,sem);
}

//实现线程互斥

#include <iostream>
#include<unistd.h>
#include<stdlib.h>
#include<semaphore.h>
#include<errno.h>
#include<pthread.h>
using namespace std;
 
sem_t sem;
void* productor(void* arg)
{
    while(1)
    {
        sem_wait(&sem);
        cout << "create noodle!!!" << endl;
        sem_post(&sem);
        usleep(10);
    }
    return NULL;
}
 
void* consumer(void* arg)
{
    while(1)
    {
        sem_wait(&sem);
        cout << "eat noodle!!!" << endl;
        sem_post(&sem);
        usleep(10);
    }
    return NULL;
}
int main()
{
    pthread_t tid1,tid2;
    
    sem_init(&sem, 0, 1);
 
    pthread_create(&tid1, NULL, productor, NULL);
    pthread_create(&tid2, NULL, consumer, NULL);
 
    pthread_join(tid1, NULL);
    pthread_join(tid2, NULL);
    
    sem_destroy(&sem);
    return 0;
}