QNX实时操作系统下多线程同步示例

本示例演示如何在QNX实时操作系统中使用多线程实现同步操作。通过互斥锁和条件变量，确保多个线程之间的数据同步，防止竞态条件的发生。

#include <stdio.h>
#include <pthread.h>
#include <sys/neutrino.h>

// 定义全局变量和同步结构
int sharedData = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

// 线程函数
void* threadFunction(void* arg) {
    int threadID = *((int*)arg);

    // 获取互斥锁
    pthread_mutex_lock(&mutex);

    // 等待条件变量满足
    while (sharedData < 10) {
        pthread_cond_wait(&cond, &mutex);
    }

    // 执行线程任务
    sharedData += 2;
    printf("线程%d执行后，sharedData = %d\n", threadID, sharedData);

    // 释放互斥锁
    pthread_mutex_unlock(&mutex);

    return NULL;
}

int main() {
    // 创建两个线程
    pthread_t thread1, thread2;
    int id1 = 1, id2 = 2;

    // 启动两个线程
    pthread_create(&thread1, NULL, threadFunction, &id1);
    pthread_create(&thread2, NULL, threadFunction, &id2);

    // 模拟条件满足，通知等待线程
    pthread_mutex_lock(&mutex);
    sharedData = 10;
    pthread_cond_broadcast(&cond);
    pthread_mutex_unlock(&mutex);

    // 等待线程结束
    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);

    return 0;
}

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