linux 创建线程间通信

#include <sys/mman.h>
#include <fcntl.h>
#include <unistd.h>
#include <pthread.h>

// 创建共享内存
int fd = shm_open("/my_shared_mem", O_CREAT | O_RDWR, 0666);
ftruncate(fd, sizeof(int));
int* shared_mem = (int*)mmap(0, sizeof(int), PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0);

// 线程函数中使用共享内存
void* thread_func(void* arg) {
    *shared_mem = 42; // 写入数据
    return NULL;
}

#include <semaphore.h>
#include <pthread.h>

sem_t sem;

void* thread_func(void* arg) {
    sem_wait(&sem); // 获取信号量
    // 访问共享资源
    sem_post(&sem); // 释放信号量
    return NULL;
}

int main() {
    sem_init(&sem, 0, 1); // 初始化信号量为1
    // 创建线程...
    sem_destroy(&sem); // 销毁信号量
}

#include <pthread.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;
int ready = 0;

void* producer(void* arg) {
    pthread_mutex_lock(&mutex);
    ready = 1;
    pthread_cond_signal(&cond); // 通知消费者
    pthread_mutex_unlock(&mutex);
    return NULL;
}

void* consumer(void* arg) {
    pthread_mutex_lock(&mutex);
    while (!ready) {
        pthread_cond_wait(&cond, &mutex); // 等待通知
    }
    // 处理数据
    pthread_mutex_unlock(&mutex);
    return NULL;
}

#include <mqueue.h>

mqd_t mq;

void* sender(void* arg) {
    mq_send(mq, "Hello", 5, 0); // 发送消息
    return NULL;
}

void* receiver(void* arg) {
    char buffer[10];
    mq_receive(mq, buffer, sizeof(buffer), NULL); // 接收消息
    return NULL;
}

int main() {
    mq = mq_open("/my_queue", O_CREAT | O_RDWR, 0666, NULL);
    // 创建发送者和接收者线程...
    mq_close(mq);
    mq_unlink("/my_queue");
}