online compiler and debugger for c/c++

#include <stdio.h> #include <stdlib.h> #include <string.h> #include <pthread.h> #include <unistd.h> #define BUFFER_SIZE 32 #define NUM_PRODUCERS 2 #define NUM_CONSUMERS 2 struct message { char *content; }; struct circular_buffer { struct message buffer[BUFFER_SIZE]; int head; int tail; int count; pthread_mutex_t mutex; pthread_cond_t not_full; pthread_cond_t not_empty; }; struct thread_args { struct circular_buffer *cb; int id; }; /* Function prototypes */ void message_init(struct message *msg, const char *content); void message_destroy(struct message *msg); void circular_buffer_init(struct circular_buffer *cb); void circular_buffer_destroy(struct circular_buffer *cb); void *producer(void *arg); void *consumer(void *arg); int main(void) { struct circular_buffer cb; pthread_t prod_threads[NUM_PRODUCERS]; pthread_t cons_threads[NUM_CONSUMERS]; struct thread_args prod_args[NUM_PRODUCERS]; struct thread_args cons_args[NUM_CONSUMERS]; int i; circular_buffer_init(&cb); for (i = 0; i < NUM_PRODUCERS; i++) { prod_args[i].cb = &cb; prod_args[i].id = i; pthread_create(&prod_threads[i], NULL, producer, &prod_args[i]); } for (i = 0; i < NUM_CONSUMERS; i++) { cons_args[i].cb = &cb; cons_args[i].id = i; pthread_create(&cons_threads[i], NULL, consumer, &cons_args[i]); } for (i = 0; i < NUM_PRODUCERS; i++) pthread_join(prod_threads[i], NULL); for (i = 0; i < NUM_CONSUMERS; i++) pthread_join(cons_threads[i], NULL); circular_buffer_destroy(&cb); return 0; } void message_init(struct message *msg, const char *content) { msg->content = strdup(content); } void message_destroy(struct message *msg) { free(msg->content); msg->content = NULL; } void circular_buffer_init(struct circular_buffer *cb) { cb->head = 0; cb->tail = 0; cb->count = 0; pthread_mutex_init(&cb->mutex, NULL); pthread_cond_init(&cb->not_full, NULL); pthread_cond_init(&cb->not_empty, NULL); } void circular_buffer_destroy(struct circular_buffer *cb) { pthread_mutex_destroy(&cb->mutex); pthread_cond_destroy(&cb->not_full); pthread_cond_destroy(&cb->not_empty); } void * producer(void *arg) { struct thread_args *args = (struct thread_args *) arg; struct circular_buffer *cb = args->cb; int id = args->id; char message_content[50]; for (int i = 0; i < 10; i++) { snprintf(message_content, sizeof(message_content), "Message %d from Producer %d", i, id); pthread_mutex_lock(&cb->mutex); while (cb->count == BUFFER_SIZE) { pthread_cond_wait(&cb->not_full, &cb->mutex); } message_init(&cb->buffer[cb->tail], message_content); cb->tail = (cb->tail + 1) % BUFFER_SIZE; cb->count++; pthread_cond_signal(&cb->not_empty); pthread_mutex_unlock(&cb->mutex); usleep(rand() % 1000000); /* Sleep up to 1 second */ } /* Send termination message */ pthread_mutex_lock(&cb->mutex); while (cb->count == BUFFER_SIZE) { pthread_cond_wait(&cb->not_full, &cb->mutex); } message_init(&cb->buffer[cb->tail], "Bye"); cb->tail = (cb->tail + 1) % BUFFER_SIZE; cb->count++; pthread_cond_signal(&cb->not_empty); pthread_mutex_unlock(&cb->mutex); return NULL; } void * consumer(void *arg) { struct thread_args *args = (struct thread_args *) arg; struct circular_buffer *cb = args->cb; int id = args->id; struct message msg; while (1) { pthread_mutex_lock(&cb->mutex); while (cb->count == 0) { pthread_cond_wait(&cb->not_empty, &cb->mutex); } msg = cb->buffer[cb->head]; cb->head = (cb->head + 1) % BUFFER_SIZE; cb->count--; pthread_cond_signal(&cb->not_full); pthread_mutex_unlock(&cb->mutex); printf("Consumer %d: %s\n", id, msg.content); if (strcmp(msg.content, "Bye") == 0) { message_destroy(&msg); break; } message_destroy(&msg); usleep(rand() % 100000); /* Sleep up to 1/10 second */ } return NULL; }