3. QNX进程与线程管理：进程创建与销毁、线程调度策略、优先级管理、同步与互斥（Mutex/Condvar）

好，咱们今天聊聊QNX里最核心的东西——进程与线程管理。说实话，这部分是实时系统的命根子。你进程怎么创建、线程怎么调度、优先级怎么设、同步怎么做，直接决定了你的系统稳不稳、快不快。

我在做车载信息娱乐系统的时候，就吃过一次大亏。一个音频解码线程优先级设低了，结果导航语音出来的时候，音乐卡顿得像老式收音机。后来才明白，QNX的调度策略和优先级管理，真不是随便填个数字就完事的。

3.1 进程创建与销毁

QNX里创建进程，最常用的就是 spawn() 和 fork()。我个人习惯用 spawn()，因为它更干净、更可控。

核心区别：

  • fork()：复制当前进程，子进程继承父进程的地址空间、文件描述符等。开销大，但灵活。
  • spawn()：直接加载一个新程序，不复制父进程。开销小，适合启动独立任务。

举个例子，启动一个日志采集进程：

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

pid_t pid;
char *argv[] = {"/usr/bin/log_collector", "-f", "/etc/log.conf", NULL};
struct inheritance inherit;

// 设置继承属性
inherit.flags = SPAWN_ALIGN_DEFAULT;
inherit.pgroup = 0;  // 与父进程同组

int ret = spawn(pid, "log_collector", NULL, &inherit, argv, environ);
if (ret == 0) {
    printf("进程创建成功，PID: %d\n", pid);
} else {
    printf("创建失败，错误码: %d\n", errno);
}

销毁进程呢？我建议用 SIGTERM 信号优雅退出，而不是直接 SIGKILL。你想想看，一个进程可能正在写文件，你一刀砍下去，数据就丢了。

我的习惯：

  • 先发 SIGTERM，给进程3秒时间清理资源。
  • 如果没反应，再发 SIGKILL。
  • 用 waitpid() 回收僵尸进程。
// 优雅终止进程
kill(pid, SIGTERM);
sleep(3);
if (waitpid(pid, NULL, WNOHANG) == 0) {
    // 还没退出，强制杀掉
    kill(pid, SIGKILL);
    waitpid(pid, NULL, 0);
}

3.2 线程调度策略

QNX支持三种调度策略：FIFO、Round Robin 和 Sporadic。嗯，这里要注意，选错了策略，实时性就没了。

策略 特点 适用场景
SCHED_FIFO 先入先出，不抢占直到主动让出 高实时性、短任务
SCHED_RR 时间片轮转，同优先级轮流执行 多个同等重要的周期性任务
SCHED_SPORADIC 突发性任务，有预算和周期限制 偶发但紧急的事件处理

我曾经在ADAS项目中，把摄像头数据采集线程设成了FIFO。结果一个计算任务卡住了，整个采集链路都停了。后来改成RR，每个线程分到固定时间片，问题就解决了。

避坑指南：

我曾经把FIFO线程的优先级设得过高，导致低优先级的看门狗线程饿死。系统死锁了都没人发现。记住：FIFO策略下，高优先级线程如果不主动让出CPU，低优先级线程永远没机会跑。

3.3 优先级管理

QNX的优先级范围是0到255，数字越大优先级越高。但说实话，你不需要用满整个范围。我一般只用1到63，留出高位给系统关键任务。

设置优先级用 pthread_setschedparam()：

#include <pthread.h>

struct sched_param param;
param.sched_priority = 50;  // 中等优先级

int ret = pthread_setschedparam(thread_id, SCHED_RR, ¶m);
if (ret != 0) {
    printf("设置优先级失败: %s\n", strerror(ret));
}

为什么我建议不要用满255？因为QNS内核本身有一些高优先级的内核线程，比如中断处理。你把自己的线程设成254，万一和内核线程抢资源，系统可能不稳定。

优先级分配原则（我自己的经验）：

  • 1-10：后台任务、日志写入、非实时统计
  • 11-30：普通业务逻辑、状态机处理
  • 31-50：中等实时性任务、通信协议处理
  • 51-63：高实时性任务、传感器数据采集
  • 64以上：保留给系统关键任务，一般不用

3.4 同步与互斥（Mutex/Condvar）

多线程编程，最头疼的就是同步问题。QNX提供了Mutex和Condvar，用好了是利器，用不好就是灾难。

3.4.1 Mutex（互斥锁）

Mutex说白了就是一把锁。谁拿到锁，谁就进临界区。我见过很多新手犯一个错误：忘记解锁。

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

void safe_update(int data) {
    pthread_mutex_lock(&mutex);
    // 临界区操作
    shared_data = data;
    pthread_mutex_unlock(&mutex);
}

嗯，这里要注意：如果临界区里调用了可能阻塞的函数，比如 sleep() 或 read()，那其他线程就全堵住了。我曾经在调试一个网络协议栈时，发现所有线程都卡在锁上，就是因为一个线程在锁里调了 recv()。

我的建议：

  • 临界区尽量短，只做必要的操作。
  • 不要在锁里调用阻塞函数。
  • 考虑用 pthread_mutex_trylock() 避免死锁。

3.4.2 Condvar（条件变量）

Condvar是用来等待某个条件成立的。比如一个生产者线程生产数据，消费者线程等待数据到来。用轮询太浪费CPU，用Condvar就优雅多了。

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

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

// 消费者线程
void consumer() {
    pthread_mutex_lock(&mutex);
    while (!data_ready) {
        pthread_cond_wait(&cond, &mutex);  // 等待条件
    }
    // 消费数据
    data_ready = 0;
    pthread_mutex_unlock(&mutex);
}

你想想看，为什么 pthread_cond_wait() 要用 while 而不是 if？因为可能有虚假唤醒。也就是说，条件没满足，但线程被唤醒了。用 while 可以重新检查条件，确保万无一失。

避坑指南：

我曾经在Condvar的使用中犯过一个低级错误：在 pthread_cond_signal() 之后没有解锁Mutex。结果消费者线程被唤醒后，发现锁还被生产者拿着，又睡回去了。这叫「惊群效应」的变种，浪费了不少CPU时间。

3.5 实战经验总结

好了，咱们把今天的内容串一下。进程与线程管理，说白了就是三件事：

  1. 创建和销毁：用 spawn() 启动进程，用 SIGTERM 优雅退出。
  2. 调度和优先级：FIFO适合短任务，RR适合轮转任务。优先级别用满，留点余地。
  3. 同步和互斥：Mutex保护临界区，Condvar等待条件。记住：锁要短，等待要循环。

我在项目中见过太多因为线程管理不当导致的崩溃。有的死锁，有的优先级反转，有的条件变量用错。其实只要记住几个原则，大部分问题都能避免。

嗯，今天就聊到这儿。下一章咱们讲QNX的内存管理，那可是另一个大坑。到时候我给大家讲讲怎么用 mmap() 做共享内存，还有怎么避免内存泄漏。咱们下章见。

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