线程邮箱伪代码 c语言

线程邮箱（Thread-safe Mailbox）是一种用于在并发环境中安全地传递消息的技术，它通常用于线程间通信，如生产者消费者模型。这里是一个简单的C语言伪代码示例：

// 定义线程邮箱结构体
typedef struct {
    pthread_mutex_t lock; // 锁
    pthread_cond_t condition; // 条件变量
    int messages[MSG_CAPACITY]; // 消息队列
    int head; // 队列头指针
    int tail; // 队列尾指针
} ThreadMailbox;

// 初始化线程邮箱
void init_mailbox(ThreadMailbox *mb) {
    pthread_mutex_init(&mb->lock, NULL);
    pthread_cond_init(&mb->condition, NULL);
    mb->head = -1;
    mb->tail = -1;
}

// 生产者添加消息到邮箱
void producer(ThreadMailbox *mb, void *msg) {
    pthread_mutex_lock(&mb->lock);
    while (mb->tail == mb->head + MSG_CAPACITY) { // 如果队列满
        pthread_cond_wait(&mb->condition, &mb->lock); // 阻塞等待
    }
    mb->messages[mb->tail] = *(int*)msg;
    mb->tail = (mb->tail + 1) % MSG_CAPACITY; // 循环数组
    pthread_cond_signal(&mb->condition); // 唤醒消费者
    pthread_mutex_unlock(&mb->lock);
}

// 消费者从邮箱取出消息
void consumer(ThreadMailbox *mb) {
    pthread_mutex_lock(&mb->lock);
    while (mb->head == mb->tail) { // 如果队列空
        pthread_cond_wait(&mb->condition, &mb->lock); // 阻塞等待
    }
    int msg = mb->messages[mb->head];
    mb->head = (mb->head + 1) % MSG_CAPACITY; // 移动头指针
    pthread_cond_signal(&mb->condition); // 唤醒其他生产者
    pthread_mutex_unlock(&mb->lock);
    // 处理消息...
}

// 相关问题--