在QNX上实现多线程并发操作

本示例演示如何使用QNX操作系统的多线程机制实现并发操作。使用pthread库创建和管理线程，通过共享内存实现线程间数据传输和共享，保证多线程的安全性和正确性。

#include <stdlib.h>
#include <stdio.h>
#include <pthread.h>
#include <stdint.h>
#include <string.h>
#include <fcntl.h>
#include <errno.h>
#include <unistd.h>
#include <sys/mman.h>

#define SHM_NAME "/mysharedmemory"
#define SHM_SIZE sizeof(int)

// 共享内存结构，存储一个整数，用于线程间共享数据
typedef struct {
  int data;
} shared_memory;

shared_memory* shm_ptr;

// 线程1，将共享内存中的整数加1
void* thread1_func(void* arg) {
  while (1) {
    usleep(1000);
    pthread_mutex_lock(&shm_ptr->mutex);
    int val = shm_ptr->data;
    val += 1;
    shm_ptr->data = val;
    printf("Thread 1: %d\n", val);
    pthread_mutex_unlock(&shm_ptr->mutex);
  }
  return NULL;
}

// 线程2，将共享内存中的整数乘2
void* thread2_func(void* arg) {
  while (1) {
    usleep(1000);
    pthread_mutex_lock(&shm_ptr->mutex);
    int val = shm_ptr->data;
    val *= 2;
    shm_ptr->data = val;
    printf("Thread 2: %d\n", val);
    pthread_mutex_unlock(&shm_ptr->mutex);
  }
  return NULL;
}

int main() {
  int fd = shm_open(SHM_NAME, O_CREAT | O_RDWR, 0666); // 创建共享内存
  if (fd < 0) {
    printf("Error in shm_open(): %s\n", strerror(errno));
    exit(1);
  }
  ftruncate(fd, SHM_SIZE); // 设置共享内存大小
  shm_ptr = (shared_memory*) mmap(NULL, SHM_SIZE, PROT_READ | PROT_WRITE, MAP_SHARED, fd, 0); // 映射共享内存
  if (shm_ptr == MAP_FAILED) {
    printf("Error in mmap(): %s\n", strerror(errno));
    exit(1);
  }

  pthread_mutex_init(&shm_ptr->mutex, NULL); // 初始化锁

  pthread_t thread1, thread2;
  pthread_create(&thread1, NULL, thread1_func, NULL); // 创建线程1
  pthread_create(&thread2, NULL, thread2_func, NULL); // 创建线程2

  pthread_join(thread1, NULL);
  pthread_join(thread2, NULL);

  pthread_mutex_destroy(&shm_ptr->mutex); // 销毁锁

  munmap(shm_ptr, SHM_SIZE); // 解除映射
  shm_unlink(SHM_NAME); // 销毁共享内存

  return 0;
}

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