QNX上使用C++实现线程同步

该示例代码使用C++语言在QNX系统上实现了线程同步的功能，包括互斥锁和条件变量。使用互斥锁锁住共享资源，条件变量用于线程等待和唤醒。该功能可用于多线程编程中的资源共享和并发控制。

#include <pthread.h>
#include <iostream.h>
#include <msg.h>

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

void producer() {
    while (1) {
        pthread_mutex_lock(&mutex);
        if (global < 5) {
            global++;
            cout<<"producer push, global="<<global<<endl;
            pthread_cond_signal(&cond);
        }
        pthread_mutex_unlock(&mutex);
        delay(100);
    }
}

void consumer() {
    while (1) {
        pthread_mutex_lock(&mutex);
        if (global == 0) {
            pthread_cond_wait(&cond, &mutex);
        } else {
            global--;
            cout<<"consumer pop, global="<<global<<endl;
        }
        pthread_mutex_unlock(&mutex);
        delay(200);
    }
}

int main(int argc, char *argv[]) {
    pthread_t prod_tid, cons_tid;
    pthread_create(&prod_tid, NULL, (void *(*)(void *))producer, NULL);
    pthread_create(&cons_tid, NULL, (void *(*)(void *))consumer, NULL);
    pthread_join(prod_tid, NULL);
    pthread_join(cons_tid, NULL);
    return 0;
}

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