linux多线程聊天室空格

#include <stdio.h>
#include <string.h>

#define MAX_MSG_LEN 1024

void read_input(char *buffer, size_t size) {
    if (fgets(buffer, size, stdin) != NULL) {
        // Remove newline character if present
        buffer[strcspn(buffer, "\n")] = '\0';
    }
}

int main() {
    char message[MAX_MSG_LEN];
    printf("Enter your message: ");
    read_input(message, sizeof(message));
    printf("You entered: %s\n", message);
    return 0;
}

#include <stdio.h>
#include <string.h>

void parse_message(const char *message) {
    char *token = strtok((char *)message, " ");
    while (token != NULL) {
        printf("Token: %s\n", token);
        token = strtok(NULL, " ");
    }
}

int main() {
    char message[] = "Hello World this is a test";
    parse_message(message);
    return 0;
}

#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <pthread.h>

#define MAX_MSGS 100

typedef struct {
    char messages[MAX_MSGS][MAX_MSG_LEN];
    int count;
    pthread_mutex_t lock;
} MessageQueue;

void init_queue(MessageQueue *queue) {
    queue->count = 0;
    pthread_mutex_init(&queue->lock, NULL);
}

void add_message(MessageQueue *queue, const char *message) {
    pthread_mutex_lock(&queue->lock);
    if (queue->count < MAX_MSGS) {
        strcpy(queue->messages[queue->count++], message);
    }
    pthread_mutex_unlock(&queue->lock);
}

void *reader_thread(void *arg) {
    MessageQueue *queue = (MessageQueue *)arg;
    while (1) {
        pthread_mutex_lock(&queue->lock);
        if (queue->count > 0) {
            printf("Read message: %s\n", queue->messages[--queue->count]);
        }
        pthread_mutex_unlock(&queue->lock);
    }
    return NULL;
}

int main() {
    MessageQueue queue;
    init_queue(&queue);

    pthread_t thread;
    pthread_create(&thread, NULL, reader_thread, &queue);

    char message[MAX_MSG_LEN];
    printf("Enter your message: ");
    read_input(message, sizeof(message));
    add_message(&queue, message);

    pthread_join(thread, NULL);
    return 0;
}