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

进程和线程，是QNX系统里最基础的概念。很多刚接触QNX的工程师，容易把Linux那套思维直接搬过来。嗯，我当年也犯过这个错。QNX的进程管理，其实比Linux更强调实时性和确定性。今天我们就来聊聊进程创建与销毁、线程同步机制，还有调度策略。

3.1 进程创建与销毁

在QNX里，创建进程最常用的就是spawn()和fork()。我个人习惯用spawn()，因为它更直接，不需要像fork()那样先复制父进程再替换。

核心函数：

  • pid_t spawn(const char *path, ...) — 直接启动一个新进程
  • pid_t fork(void) — 复制当前进程
  • int exec*() — 替换当前进程映像
  • void exit(int status) — 终止当前进程
  • int waitpid(pid_t pid, int *stat_loc, int options) — 等待子进程结束

举个例子，我在做车载音频路由模块时，需要动态启动一个音频处理进程。用spawn()就特别方便：

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

pid_t pid;
char *argv[] = {"/usr/bin/audio_proc", "-c", "config.json", NULL};
char *envp[] = {NULL};

// 启动音频处理进程
int ret = spawn(&pid, "/usr/bin/audio_proc", NULL, NULL, argv, envp);
if (ret != 0) {
    // 处理错误
    perror("spawn failed");
    return -1;
}

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

销毁进程呢？通常用kill()发送信号。但要注意，直接kill -9可能会造成资源泄漏。我建议先发SIGTERM，让进程自己清理，如果它不响应再发SIGKILL。

避坑指南：我曾经在项目中直接用SIGKILL杀掉一个音频采集进程，结果导致共享内存没有释放，下次启动时直接崩溃。后来改成先发SIGTERM，在信号处理函数里做资源清理，问题就解决了。

3.2 线程同步机制

多线程编程，说白了就是解决「谁先谁后」和「谁用谁等」的问题。QNX提供了三种常用的同步机制：Mutex、Condvar和Barrier。

3.2.1 Mutex（互斥锁）

Mutex是最基础的同步工具。它保证同一时间只有一个线程能访问共享资源。你想想看，如果两个线程同时往一个缓冲区写数据，那不乱套了？

#include <sync.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

void *audio_thread(void *arg) {
    while (1) {
        pthread_mutex_lock(&mutex);
        // 访问共享音频缓冲区
        process_audio_buffer();
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}

个人经验：我在做多路音频混音时，每个输入通道一个线程，共享输出缓冲区。如果不用Mutex，混音结果会出现「毛刺」——其实就是数据竞争导致的。加上Mutex后，声音就干净了。

3.2.2 Condvar（条件变量）

Condvar通常和Mutex配合使用。它解决的是「等待某个条件成立」的问题。比如音频播放线程要等缓冲区有数据才能播放，用Condvar就比轮询高效得多。

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

// 生产者线程
void *producer(void *arg) {
    while (1) {
        // 填充音频数据
        fill_audio_buffer();
        
        pthread_mutex_lock(&mutex);
        buffer_ready = 1;
        pthread_cond_signal(&cond);  // 通知消费者
        pthread_mutex_unlock(&mutex);
    }
}

// 消费者线程
void *consumer(void *arg) {
    while (1) {
        pthread_mutex_lock(&mutex);
        while (!buffer_ready) {
            pthread_cond_wait(&cond, &mutex);  // 等待条件
        }
        // 处理音频数据
        play_audio_buffer();
        buffer_ready = 0;
        pthread_mutex_unlock(&mutex);
    }
}

注意那个while循环。为什么不用if？因为pthread_cond_wait可能被「虚假唤醒」。嗯，这是POSIX标准允许的，所以必须用while重新检查条件。

3.2.3 Barrier（屏障）

Barrier用于多个线程「齐步走」。所有线程都到达屏障点后，才能继续往下执行。这在音频处理中很有用，比如多个通道的数据必须同步处理。

#include <barrier.h>

pthread_barrier_t barrier;
#define NUM_THREADS 4

void *worker(void *arg) {
    int id = *(int *)arg;
    
    // 第一阶段：采集数据
    collect_audio_data(id);
    
    // 等待所有线程完成采集
    pthread_barrier_wait(&barrier);
    
    // 第二阶段：同步处理
    process_audio_data(id);
    
    return NULL;
}

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

什么时候用Barrier？我在做多麦克风阵列波束成形时，4个麦克风通道必须同时开始处理。用Barrier确保所有通道的数据采集完成后，再一起进入处理阶段。如果不用Barrier，先完成的线程可能会读到不完整的数据。

3.3 调度策略

QNX的调度策略，是它作为实时操作系统的核心优势。说白了，就是决定「下一个该谁跑」。QNX支持三种策略：FIFO、RR和Sporadic。

策略 特点 适用场景
FIFO（先入先出） 同优先级线程按队列顺序执行，直到主动让出CPU 音频播放线程、中断处理
RR（轮转） 同优先级线程轮流执行，每个线程有固定时间片 多个同等重要的后台任务
Sporadic（零星调度） 允许低优先级线程在紧急时临时提升优先级 偶发的高优先级事件处理

3.3.1 FIFO调度

FIFO策略下，线程一旦获得CPU，就会一直运行直到主动阻塞或主动让出。我习惯把音频播放线程设为FIFO最高优先级，确保它不会被其他线程打断。

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

pthread_t thread;
pthread_attr_t attr;
pthread_attr_init(&attr);
pthread_attr_setschedpolicy(&attr, SCHED_FIFO);
pthread_attr_setschedparam(&attr, &param);

pthread_create(&thread, &attr, audio_playback, NULL);

注意：FIFO线程如果一直不阻塞，会「饿死」低优先级线程。我曾经见过一个FIFO线程在死循环里做计算，结果系统界面完全卡死。所以FIFO线程里一定要有阻塞点，比如pthread_cond_wait或sleep。

3.3.2 RR调度

RR和FIFO类似，但多了时间片限制。每个线程运行一个时间片后，如果没主动让出CPU，系统会强制切换到下一个同优先级线程。

我个人觉得RR适合那些「大家差不多重要」的场景。比如多个音频效果器线程，每个都需要CPU，但谁也不比谁更紧急。

3.3.3 Sporadic调度

Sporadic调度是QNX的特色。它允许一个低优先级线程，在特定条件下临时提升到高优先级。处理完紧急任务后，再降回原来的优先级。

举个例子，音频系统中有一个后台日志线程，平时优先级很低。但当检测到音频异常时，它需要临时提升优先级来快速记录错误信息。用Sporadic就很合适。

struct sched_param param;
param.sched_priority = 10;       // 正常优先级
param.sched_ss_low_priority = 5; // 低优先级
param.sched_ss_repl_period = 10000000; // 10ms补充周期
param.sched_ss_init_budget = 5000000;  // 5ms预算

pthread_attr_setschedpolicy(&attr, SCHED_SPORADIC);
pthread_attr_setschedparam(&attr, &param);

我的建议：刚开始用Sporadic时，预算和时间周期要设置合理。预算太小，紧急任务可能做不完；预算太大，又会影响其他高优先级线程。我一般先设一个保守值，然后通过pthread_getschedparam监控实际使用情况，再逐步调整。

3.4 综合应用：音频系统中的线程设计

最后，我分享一个实际项目中的线程设计思路。一个典型的车机音频系统，通常包含以下线程：

  • 音频采集线程：FIFO高优先级，从麦克风读取数据
  • 音频处理线程：FIFO中优先级，做混音、降噪等处理
  • 音频输出线程：FIFO最高优先级，将数据写入扬声器
  • 控制线程：RR调度，处理音量调节、音效切换等命令
  • 日志线程：Sporadic调度，平时低优先级，异常时临时提升

线程之间通过Mutex保护共享缓冲区，用Condvar实现生产-消费模型。Barrier用于多通道同步处理。嗯，这套架构我在多个项目中验证过，稳定性和实时性都很好。

好了，关于进程与线程管理，今天就聊到这里。下一章我们会深入QNX的内存管理，包括共享内存和消息传递。到时候再聊！

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