QNX下实现多线程并发

该示例代码介绍在QNX操作系统下，使用多线程并发技术实现任务调度的方法。使用QNX提供的pthread库，利用互斥锁和条件变量机制实现线程同步，避免多线程之间的竞争和死锁。

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <pthread.h>

//全局变量，互斥锁和条件变量
pthread_mutex_t mutex;
pthread_cond_t cond;

//子线程程序
void *child_proc(void *arg) {
    int tid = *((int*)arg);
    pthread_mutex_lock(&mutex);
    printf("thread %d start\n", tid);
    pthread_cond_wait(&cond, &mutex);
    printf("thread %d end\n", tid);
    pthread_mutex_unlock(&mutex);
    return NULL;
}

//主程序
int main(int argc, char *argv[]) {
    int i, n;
    // 设置互斥锁和条件变量
    pthread_mutex_init(&mutex, NULL);
    pthread_cond_init(&cond, NULL);

    printf("please input thread numbers: ");
    scanf("%d", &n);
    printf("create %d threads\n", n);
    pthread_t *tid = (pthread_t*)malloc(n * sizeof(pthread_t));
    int *ids = (int*)malloc(n * sizeof(int));
    for (i = 0; i < n; ++i) {
        ids[i] = i;
        pthread_create(&tid[i], NULL, child_proc, &ids[i]);
    }
    sleep(2);  //等待所有线程创建完成
    printf("signal all threads to run\n");
    pthread_cond_broadcast(&cond); //信号广播，所有线程开始执行
    //等待所有子线程结束
    for (i = 0; i < n; ++i) {
        pthread_join(tid[i], NULL);
    }
    //销毁互斥锁和条件变量资源
    pthread_mutex_destroy(&mutex);
    pthread_cond_destroy(&cond);
    free(ids);
    free(tid);
    printf("main thread end\n");
    return 0;
}

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