#include <iostream>

#include <stdlib.h>

#include <pthread.h>

#include <semaphore.h>

using namespace std;

#define NUM 5

#define Count 20

#define ProCount 40

sem_t mutex,full;

int  amount=;

void *Producer(void *arg)

{

    int i=;

   while(i<ProCount)

    {

        sem_wait(&mutex);

        if (amount>=NUM)

        {

            cout<<"已满"<<endl;

        }

        else

        {

            amount++;

            cout<<"余下："<<amount<<endl;

            i++;

        }

        sem_post(&full);

    }

}

void *Consumer(void *arg)

{

    int i=;

    while(i<Count)

    {

        sem_wait(&full);

        if (amount<=)

        {

            cout<<"为空"<<endl;

        }

        else

        {

            amount--;

            cout<<"余下："<<amount<<endl;

            i++;

        }

        sem_post(&mutex);

    }

}

int  main(int argc, char const *argv[])

{

    int test=sem_init(&mutex,,);

    test+=sem_init(&full,,);

    if (test!=)

    {

        cout<<"sem error"<<endl;

        return -;

    }

    pthread_t id[];

    pthread_create(&id[],NULL,Producer,NULL);

    pthread_create(&id[],NULL,Consumer,NULL);

    pthread_create(&id[],NULL,Consumer,NULL);

    pthread_join(id[],NULL);

    pthread_join(id[],NULL);

    pthread_join(id[],NULL);

    sem_destroy(&mutex);

    sem_destroy(&full);

    return ;

}