第3章 QNX进程与线程管理

第3章：QNX进程与线程管理

大家好，我是你们的老朋友。今天我们来聊聊QNX里最核心的东西——进程与线程管理。说实话，这部分内容我刚开始接触QNX时也绕了不少弯路。尤其是从Linux转过来的时候，总觉得QNX的线程管理怎么这么「死板」？后来才明白，这种「死板」恰恰是它能在汽车上稳定跑十年的原因。

3.1 进程创建与销毁

在QNX里创建进程，最常用的就是spawn()和fork()。我个人习惯用spawn()，为什么呢？因为fork()在QNX里开销比较大，而且容易出问题。

核心区别：

spawn()：直接加载新程序，不复制父进程内存空间
fork()：复制父进程整个地址空间，再执行新程序

来看个实际例子。我在做车载诊断模块时，需要动态启动一个日志采集进程：

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

pid_t pid;
char *argv[] = {"log_collector", "-f", "/dev/shmem/log.bin", NULL};

// 创建进程
int ret = spawn(&pid, "log_collector", NULL, NULL, argv, NULL);
if (ret != 0) {
    // 我曾经在这里吃过亏——忘记检查返回值
    fprintf(stderr, "spawn failed: %s\n", strerror(errno));
    return -1;
}

// 等待进程结束
int status;
waitpid(pid, &status, 0);

销毁进程呢？我建议用SIGTERM信号，而不是直接SIGKILL。你想想看，直接杀掉进程，它来不及释放资源，搞不好就把共享内存搞坏了。

避坑指南：我曾经在项目里用kill(pid, SIGKILL)杀掉一个正在写文件的进程，结果下次启动时发现文件损坏了。后来改成SIGTERM，让进程自己清理，问题就解决了。

3.2 线程同步机制

说到线程同步，QNX提供了三种经典机制：互斥锁、信号量、条件变量。嗯，这里要注意，它们各有各的适用场景，别混着用。

3.2.1 互斥锁（Mutex）

互斥锁是最基础的同步工具。说白了，就是一把锁，谁拿到谁干活。我在做诊断数据采集时，多个线程要写同一个缓冲区，这时候互斥锁就派上用场了。

#include <sync.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

void write_diagnostic_data(uint8_t *data, size_t len) {
    pthread_mutex_lock(&mutex);
    // 临界区：写入共享缓冲区
    memcpy(shared_buf + write_pos, data, len);
    write_pos += len;
    pthread_mutex_unlock(&mutex);
}

注意：互斥锁不是万能的。我见过有人用互斥锁保护一个只有几行代码的临界区，结果导致其他线程频繁阻塞，性能直接掉了一半。记住：锁的粒度要适中，别锁太多，也别锁太少。

3.2.2 信号量（Semaphore）

信号量适合用来控制资源的访问数量。比如，我有一个诊断任务队列，最多允许3个线程同时处理：

#include <semaphore.h>

sem_t sem;
sem_init(&sem, 0, 3);  // 初始值为3，表示最多3个线程同时访问

void process_diagnostic_task(task_t *task) {
    sem_wait(&sem);  // 获取信号量
    // 处理任务...
    sem_post(&sem);  // 释放信号量
}

我个人习惯用信号量来做生产者-消费者模型。比如，诊断事件的生产者线程和消费者线程之间，用信号量来协调，既简单又高效。

3.2.3 条件变量（Condition Variable）

条件变量是配合互斥锁用的。它解决的是「等待某个条件成立」的问题。举个例子，诊断线程要等数据采集线程把数据准备好才能处理：

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

// 消费者线程
void *diagnostic_worker(void *arg) {
    pthread_mutex_lock(&cond_mutex);
    while (!data_ready) {
        pthread_cond_wait(&cond, &cond_mutex);
    }
    // 处理数据...
    data_ready = 0;
    pthread_mutex_unlock(&cond_mutex);
    return NULL;
}

// 生产者线程
void data_collector(uint8_t *data) {
    pthread_mutex_lock(&cond_mutex);
    // 写入数据...
    data_ready = 1;
    pthread_cond_signal(&cond);  // 唤醒等待的线程
    pthread_mutex_unlock(&cond_mutex);
}

小技巧：条件变量的while循环判断条件，而不是if。为什么？因为pthread_cond_wait可能被虚假唤醒。我曾经在这个坑里摔过一次，后来就老老实实写while了。

3.3 优先级调度策略

QNX的调度策略，说白了就是决定「哪个线程先跑」。它支持三种策略：

策略	说明	适用场景
`SCHED_FIFO`	先进先出，同优先级线程按队列顺序执行	实时性要求高的任务，如CAN总线处理
`SCHED_RR`	时间片轮转，同优先级线程轮流执行	多个同等重要的任务，如诊断会话管理
`SCHED_OTHER`	分时调度，优先级动态调整	后台任务，如日志写入

我在做远程升级模块时，就遇到过优先级设置不当导致的问题。升级线程优先级设得太高，结果把CAN通信线程给饿死了，升级过程中车辆直接断网。后来我把升级线程的优先级降到比CAN通信低一级，问题就解决了。

经验之谈：优先级设置有个原则——关键性任务优先级高，非关键性任务优先级低。但别把所有任务都设成最高优先级，那样跟没设一样。我一般会留出1-2个优先级给紧急任务，比如安全相关的诊断。

设置优先级的方法很简单：

#include <sched.h>

struct sched_param param;
param.sched_priority = 20;  // 优先级范围：0-255，数值越大优先级越高

pthread_t thread;
pthread_setschedparam(thread, SCHED_FIFO, &param);

警告：别把优先级设成255！那是系统保留给内核线程的。我曾经手贱设了一次，结果系统直接死机。嗯，从那以后我就老实了，最高只用到250。

好了，这一章的内容就到这里。进程创建与销毁、线程同步机制、优先级调度策略，这三块是QNX开发的基础。你想想看，如果连线程同步都搞不定，那诊断数据采集和远程升级这些高级功能根本跑不起来。下一章我们聊聊内存管理，到时候我会分享一些我在共享内存使用上的踩坑经历。

📚 课程目录