QNX操作系统下实现多线程同步的示例代码及解析

QNX是一个实时操作系统，其多线程处理能力强大，但在多线程并发执行时，需要良好的同步机制。示例代码演示了在QNX环境下使用信号量实现多线程同步的方法，确保线程间资源访问的安全性。

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

#define NUM_THREADS 2

sem_t semaphore;

void *thread_function(void *thread_id) {
    long tid;
    tid = (long)thread_id;

    printf("线程 %ld 正在执行\n", tid);

    // 模拟线程执行过程
    // ...

    printf("线程 %ld 执行完毕\n", tid);
    sem_post(&semaphore); // 线程执行完毕后释放信号量
    pthread_exit(NULL);
}

int main() {
    pthread_t threads[NUM_THREADS];
    int rc;
    long t;

    sem_init(&semaphore, 0, 0); // 初始化信号量

    for (t = 0; t < NUM_THREADS; t++) {
        printf("创建线程 %ld\n", t);
        rc = pthread_create(&threads[t], NULL, thread_function, (void *)t);
        if (rc) {
            printf("Error: 无法创建线程，错误代码 %d\n", rc);
            return -1;
        }
    }

    // 等待所有线程执行完毕
    for (t = 0; t < NUM_THREADS; t++) {
        sem_wait(&semaphore); // 等待信号量释放
    }

    printf("所有线程执行完毕\n");

    sem_destroy(&semaphore); // 销毁信号量
    pthread_exit(NULL);
    return 0;
}

免责申明：文章和图片全部来源于公开网络，如有侵权，请通知删除 server@dude6.com