QNX中如何使用semaphore进行线程同步

介绍在QNX中如何使用semaphore进行线程同步。semaphore是一种用于多线程编程的同步工具，可以用于保护共享资源，确保同一时间只有一个线程可以访问该资源。该示例展示如何在QNX系统上使用semaphore实现线程同步以及如何通过信号量来协调线程的执行。

#include <errno.h>
#include <fcntl.h>
#include <pthread.h>
#include <semaphore.h>
#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>

#define MAX_THREADS  5

sem_t mutex;   // Semaphore对象，用于保护共享资源

void *thread_func(void *arg) {
    int tnum = *(int *)arg;
    // 获取信号量
    if (sem_wait(&mutex) == -1) {
        perror("sem_wait");
        exit(EXIT_FAILURE);
    }

    // 线程执行操作
    printf("Thread %d started\n", tnum);
    sleep(5);

    // 释放信号量
    if (sem_post(&mutex) == -1) {
        perror("sem_post");
        exit(EXIT_FAILURE);
    }

    pthread_exit(NULL);
}

int main() {
    int i, rc;
    pthread_t threads[MAX_THREADS];
    int tnums[MAX_THREADS];

    // 初始化信号量
    if (sem_init(&mutex, 0, 1) == -1) {
        perror("sem_init");
        exit(EXIT_FAILURE);
    }

    // 创建并启动线程
    for (i = 0; i < MAX_THREADS; ++i) {
        tnums[i] = i;
        rc = pthread_create(&threads[i], NULL, thread_func, &tnums[i]);
        if (rc) {
            perror("pthread_create");
            exit(EXIT_FAILURE);
        }
    }

    // 等待所有线程结束
    for (i = 0; i < MAX_THREADS; ++i) {
        pthread_join(threads[i], NULL);
    }

    // 销毁信号量
    if (sem_destroy(&mutex) == -1) {
        perror("sem_destroy");
        exit(EXIT_FAILURE);
    }

    return 0;
}

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