Linux实时线程触发非实时任务：线程创建与信号量唤醒的CPU开销对比

我在树莓派3的Linux系统上运行一个实时控制应用：实时线程采用抢占式调度，周期约200微秒，必须在限定时间内完成输出，目前运行正常、内存无压力，核心关注点是CPU占用。特定条件下，该实时线程需要触发一个CPU密集型的非实时任务（无需抢占式调度）。现有两种实现方案：

• 选项A：每次触发任务时调用pthread_create创建新的非实时线程
• 选项B：提前创建一个非实时线程，使其等待信号量/互斥锁，由实时线程通过sem_post/解锁操作唤醒

方案对比与结论 #

哪种方案能显著降低实时线程的CPU占用？ #

选项B能显著降低实时线程的CPU占用

核心原因 #

• 选项A的pthread_create是高开销系统调用：创建新线程需要内核分配线程栈、更新进程线程表、调度新线程等一系列操作，这些步骤会消耗大量CPU周期。对于200微秒周期的实时任务来说，这种开销不仅会直接拉高实时线程的CPU占用，甚至可能导致实时任务超时，打破实时性要求。
• 选项B的sem_post是轻量级操作：实时线程仅需执行一个低开销的信号量投递操作，内核层面的处理成本极低。非实时线程提前创建后，平时处于阻塞等待状态，不占用CPU资源；被唤醒后直接执行任务，完全不会给实时线程带来额外的高负载操作。

更高效的优化方案 #

如果非实时任务触发频率较高，还可以考虑以下优化方向：

1. 线程池模式：提前创建多个非实时线程组成线程池，实时线程触发任务时将任务放入队列，线程池内的空闲线程自动取任务执行。这种方式既保留了提前创建线程的低开销优势，又解决了单线程处理任务的串行瓶颈。
2. 使用eventfd/signalfd替代信号量：这两种Linux原生机制是更高效的事件通知方式，可结合epoll使用，进一步降低线程阻塞时的内核开销，尤其适合多任务场景。
3. 明确非实时线程的调度属性：在创建非实时线程时，通过pthread_attr_setschedpolicy将其调度策略设为SCHED_OTHER（默认非实时策略），并调低优先级，避免它抢占实时线程的CPU时间，确保实时任务的执行不受干扰。

选项A示例代码 #

void*
not_real_time_thread(void* args)
{
    // 执行非实时任务
    return (void*) EXIT_SUCCESS;
}

void*
real_time_thread(void* args)
{
    sem_t sync;
    sem_init(&sync, 0, 0);
    int end_event=0; 
    int running=1;

    int trigger_other_task = 0;
    pthread_t not_real_time_thread_handle;
    pthread_attr_t thread_attrs;    // 线程属性
    // 正确初始化线程属性

    // 实时任务循环
    while(running)
    {
        // 执行实时任务
        if(trigger_other_task)
        {
            pthread_create(&not_real_time_thread_handle, &thread_attrs, not_real_time_thread, NULL);
        }
        if(end_event)
        {
            running=0;
        }
    }
    sem_destroy(&sync);

    return (void*) EXIT_SUCCESS;
}

选项B示例代码 #

int g_running;
sem_t g_semaphore;

void*
not_real_time_thread(void* args)
{
    while(g_running)
    {
        sem_wait(&g_semaphore);
        // 执行非实时任务
    }
    return (void*) EXIT_SUCCESS;
}

void*
real_time_thread(void* args)
{
    sem_t sync;
    sem_init(&sync, 0, 0);
    int end_event=0; 
    g_running=1;

    int trigger_other_task = 0;
    sem_init(&g_semaphore, 0, 0);
    pthread_t not_real_time_thread_handle;
    pthread_attr_t thread_attrs;    // 线程属性
    // 正确初始化线程属性
    pthread_create(&not_real_time_thread_handle, &thread_attrs, not_real_time_thread, NULL);

    // 实时任务循环
    while(g_running)
    {
        // 执行实时任务
        if(trigger_other_task)
        {
            sem_post(&g_semaphore);
        }
        if(end_event)
        {
            g_running=0;
        }
    }
    sem_destroy(&sync);

    int thread_result=0;
    pthread_join(not_real_time_thread_handle, (void*) &thread_result);
    sem_destroy(&g_semaphore);
    return (void*) EXIT_SUCCESS;
}

内容的提问来源于stack exchange，提问作者gscofano