Producer/Consumer C pthreads

main.c

// Producer / consumer example
// build with `cls && gcc -O2 -Wall -pthread main.c -o main.exe && main.exe`
#include <stdio.h>
#include <stdlib.h>
#include <pthread.h>

#define MESSAGES 20

// global integer buffer
int global_buffer;
pthread_mutex_t buffer_mutex = PTHREAD_MUTEX_INITIALIZER;

// producer thread function
void *producer_thread(void *args) {
    int i = 0;
    // send messages while received count < MESSAGES
    while (i < MESSAGES) {
        // lock mutex
        pthread_mutex_lock(&buffer_mutex);
        if (global_buffer == 0) {
            global_buffer++;
            printf("Producer: SEND %d\n", i);
            i++;
        }
        // unlock mutex
        pthread_mutex_unlock(&buffer_mutex);
    }

    pthread_exit(NULL);
    return 0;
}

// receiver thread function
void *consumer_thread(void *args) {
    int i = 0;
    // receive messages while received count < MESSAGES
    while (i < MESSAGES) {
        // lock mutex
        pthread_mutex_lock(&buffer_mutex);
        if (global_buffer > 0) {
            printf("Consumer: RESV %d\n", i);
            global_buffer--;
            i++;
        }
        // unlock mutex
        pthread_mutex_unlock(&buffer_mutex);
    }

    pthread_exit(NULL);
    return 0;
}

int main() {
    pthread_t producer,consumer;
    // create threads
    pthread_create(&producer,NULL,producer_thread,NULL);
    pthread_create(&consumer,NULL,consumer_thread,NULL);
    // then join threads
    pthread_join(producer,NULL);
    pthread_join(consumer,NULL);
    return 0;
}

👍