C에서 sempahore로 제작자 및 소비자 작업

Question

생산자/소비자 응용 프로그램을 만들려고합니다. 문제는 제 제작자가 전체 버퍼를 채우는 것입니다. 그러면 소비자가 전체 버퍼를 제거하고 있습니다 ... 생산자가 세마포어에 post을 작성하자마자 버퍼에서 항목을 제거한다고 가정하지 않았습니까?

내 코드 :

void* producerFunc(void* arg) 
{ 
    while(n_insertions < N_PRODUCTS) 
    { 
     sem_wait(&sem_postAvaliable); 
     sem_wait(&mutex); 
     //Insert Item 
     sem_post(&mutex); 
     sem_post(&sem_posTaken); 
    } 
    pthread_exit(NULL); 
} 

void* consumerFunc(void* arg) 
{ 
    while(n_consumed < N_PRODUCTS) 
    { 
     sem_wait(&sem_posTaken); 
     sem_wait(&mutex); 
     //Remove from bufer 
     sem_post(&mutex); 
     sem_post(&sem_postAvaliable); 
    } 
    pthread_exit(NULL); 
} 

n_insertions 버퍼에 삽입 된 항목의 수를 계산하는 글로벌 정수이고;

n_consumed은 소비자가 버퍼에서 항목을 소비 한 횟수를 계산하는 전역 정수입니다.

Answer 1

매우 높은 수준에서 sem_post(&sem_posTaken)을 수행하면 소비자는 "안녕하세요. 당신이 소비 할 수 있습니다"라고 말했지만 프로세서 스케줄러에 따라 생산자는 세마포어 카운터가 작동하지 않을 때까지 계속 생산할 수 있습니다 소비자를 허용하지 않으므로 생산자가 무언가를 삽입 한 직후 또는 어쩌면 3 개의 삽입 이후에 소비자가 소비 할 수 있습니까? 카운터가 0 인 세마포어의 sem_wait을 만들려고하면 스레드가 차단됩니다.

삽입과 제거를 번갈아 가며 사용하려면 sem_postAvaliable에서 1으로 초기화하십시오. 먼저, 다른 스레드가 sem_post(&sem_postAvaliable)을 기다리는 것을 막을 것이기 때문에 한 소비자가 버퍼에 삽입 한 내용을 소비 할 수 있지만이 경우에는 1보다 큰 크기의 버퍼는 의미가 없습니다.