QNX Neutrino中使用Condvar进行线程同步的示例代码

本示例代码演示了如何在QNX Neutrino操作系统中使用Condvar进行线程同步，该方法可以提高多线程应用程序的性能和可靠性。Condvar是一种线程间同步机制，用于等待某个条件的发生，同时避免不必要的占用CPU资源。

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

#define THREAD_NUM 5
pthread_mutex_t mutex;
pthread_cond_t cond;
int count = 0;

void* thread_func(void* arg){
    int tid = (int)arg;
    printf("Thread %d started.\n", tid);
    pthread_mutex_lock(&mutex);
    count++;
    if(count == THREAD_NUM){
        printf("All threads started.\n");
        pthread_cond_signal(&cond);
    }else{
        pthread_cond_wait(&cond, &mutex);
    }
    printf("Thread %d finished.\n", tid);
    pthread_mutex_unlock(&mutex);
    return NULL;
}

int main(){
    pthread_t threads[THREAD_NUM];
    pthread_mutex_init(&mutex,NULL);
    pthread_cond_init(&cond,NULL);
    printf("Main thread started.\n");
    for(int i=0; i<THREAD_NUM; i++){
        pthread_create(&threads[i], NULL, thread_func, (void*)i);
    }
    for(int i=0; i<THREAD_NUM; i++){
        pthread_join(threads[i], NULL);
    }
    printf("Main thread finished.\n");
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    return 0;
}

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