3、QNX进程与线程管理：进程创建与销毁、线程同步机制（Mutex、Condvar、Barrier）、优先级调度策略

各位同学，咱们今天聊点硬核的。QNX 作为车规级实时操作系统，它的进程和线程管理，说白了就是整个系统的骨架。你想想看，一辆智能汽车上，从仪表盘到 ADAS，几十个任务同时跑，谁先谁后，谁等谁，谁生谁死，全得靠这套机制来管。我做了这么多年车载项目，可以负责任地告诉你：搞不懂进程线程，你连 Bug 都找不到地方下手。

3.1 进程的创建与销毁：生与死的艺术

在 QNX 里，进程的创建不像 Linux 那么随意。我个人习惯用 spawn() 或者 fork() + exec() 的组合。但说实话，在车机场景下，我更喜欢 spawn()，因为它一步到位，不容易出岔子。

核心函数：

  • pid_t spawn(const char *path, ...) — 创建并启动新进程
  • int kill(pid_t pid, int sig) — 发送信号终止进程
  • int waitpid(pid_t pid, int *stat_loc, int options) — 等待子进程结束

举个例子，假设我们要启动一个传感器数据采集进程：

#include <spawn.h>
#include <sys/wait.h>

pid_t pid;
int status;

// 创建子进程，执行 sensor_acquisition 程序
pid = spawn("sensor_acquisition", 0, NULL, NULL, NULL, NULL);
if (pid == -1) {
    // 我曾经在这里吃过亏，忘了检查返回值
    perror("spawn failed");
    return -1;
}

// 等待子进程结束
waitpid(pid, &status, 0);
if (WIFEXITED(status)) {
    printf("子进程退出码: %d\n", WEXITSTATUS(status));
}

避坑指南： 我曾经在项目里直接用 system() 来启动进程，结果发现它阻塞了主线程，导致仪表盘卡死。后来全部改成 spawn()，问题迎刃而解。记住，车机里千万别用 system()，它太粗暴了。

进程销毁这块，我建议用 SIGTERM 信号优雅退出，而不是直接 SIGKILL。为什么？因为传感器进程可能正在写文件，你一刀砍死它，数据就丢了。嗯，这里要注意，给进程留点善后的时间。

3.2 线程同步机制：别让数据打架

多线程编程最头疼的是什么？竞态条件！说白了就是两个线程同时抢一块数据，结果乱套了。QNX 提供了三种经典的同步机制：Mutex、Condvar 和 Barrier。我一个个说。

3.2.1 Mutex（互斥锁）

Mutex 是最基础的锁。它的作用就是「这玩意儿我先用，你们等着」。我在做传感器数据融合时，多个线程都要写同一个共享缓冲区，不加锁的话，数据就全乱了。

#include <sync.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
int shared_data = 0;

void* writer_thread(void* arg) {
    pthread_mutex_lock(&mutex);
    shared_data = get_sensor_value();  // 临界区
    pthread_mutex_unlock(&mutex);
    return NULL;
}

注意： 千万别在中断服务程序里用 Mutex！我见过有人这么干，结果系统直接死锁。中断上下文里不能阻塞，这是铁律。

3.2.2 Condvar（条件变量）

Condvar 是 Mutex 的好搭档。它解决的是「等某个条件满足再干活」的问题。比如，传感器数据采集线程等数据准备好了，再通知处理线程去拿。

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

// 生产者线程
void* producer(void* arg) {
    pthread_mutex_lock(&mutex);
    data_ready = 1;
    pthread_cond_signal(&cond);  // 通知消费者
    pthread_mutex_unlock(&mutex);
    return NULL;
}

// 消费者线程
void* consumer(void* arg) {
    pthread_mutex_lock(&mutex);
    while (!data_ready) {
        pthread_cond_wait(&cond, &mutex);  // 等待条件
    }
    // 处理数据...
    pthread_mutex_unlock(&mutex);
    return NULL;
}

我个人习惯用 while 循环检查条件，而不是 if。为什么？因为 Condvar 可能有虚假唤醒，用 while 能确保条件真的满足了。这是经验之谈。

3.2.3 Barrier（屏障）

Barrier 的作用是「人到齐了再出发」。在车机里，我常用它来做多传感器的时间同步。比如，摄像头、激光雷达、毫米波雷达三个线程，必须都采集完一帧数据，才能开始融合。

#include <barrier.h>

pthread_barrier_t barrier;
#define NUM_THREADS 3

void* sensor_thread(void* arg) {
    int id = *(int*)arg;
    // 采集数据...
    printf("传感器 %d 数据就绪\n", id);
    pthread_barrier_wait(&barrier);  // 等待所有线程
    // 开始融合...
    return NULL;
}

int main() {
    pthread_barrier_init(&barrier, NULL, NUM_THREADS);
    // 创建3个线程...
    pthread_barrier_destroy(&barrier);
    return 0;
}

小技巧： 我在做 ADAS 项目时，Barrier 的计数一定要和线程数严格匹配。少一个线程，所有线程都会卡死。我曾经调试了一整天，最后发现是少创建了一个线程，Barrier 永远等不齐人。

3.3 优先级调度策略：谁该先跑？

QNX 是实时系统，优先级调度是它的灵魂。车机里，安全相关的任务（比如刹车控制）必须比娱乐系统（比如播放音乐）优先级高。这不用我多说吧？

QNX 支持三种调度策略：

策略 说明 适用场景
SCHED_FIFO 先进先出，同优先级线程按队列执行 实时性要求高的任务
SCHED_RR 时间片轮转，同优先级线程轮流执行 多个同等重要的实时任务
SCHED_OTHER 分时调度，非实时任务 后台任务、日志记录等

设置优先级很简单：

#include <sched.h>

struct sched_param param;
param.sched_priority = 50;  // 优先级范围 1-255

if (pthread_setschedparam(pthread_self(), SCHED_FIFO, ¶m) != 0) {
    perror("设置调度策略失败");
}

警告： 优先级别设太高，尤其是 255。我曾经把某个线程设为最高优先级，结果它占着 CPU 不放，其他线程全饿死了，连看门狗都跑不起来。系统直接重启。记住，高优先级意味着高责任。

最后说一句，优先级反转是个经典问题。低优先级线程拿着锁，高优先级线程等着，中间还有个中优先级线程插队。怎么解决？QNX 的 Mutex 默认支持优先级继承协议，能自动提升低优先级线程的优先级。嗯，这个机制救过我很多次。

好了，这一章的内容就到这。进程线程管理是 QNX 编程的基本功，你得多练。下一章我们讲内存管理，到时候见。

← 上一章 📖 返回目录 下一章 →