嵌入式多线程开发：pthread 线程与互斥锁实战

嵌入式多线程开发pthread 线程与互斥锁实战一、引言上一篇文章我们讨论了fork多进程开发。进程固然好——每个进程独立地址空间崩溃不互相影响——但创建开销大、进程间通信IPC麻烦。在很多嵌入式场景中我们需要轻量级的并行这时多线程就登场了。线程Thread是共享同一进程地址空间的执行流。多个线程之间切换开销远小于进程切换而且可以直接访问同一块内存通信几乎零成本——但也正因如此必须用互斥锁等手段保护共享数据。本文从pthread的创建讲起深入互斥锁的原理与死锁排查最后给出一个传感器数据采集并发的实战模型。二、线程 vs 进程一张表看懂对比维度进程线程创建开销大分配独立地址空间小共享地址空间切换开销大切换页表小只切换寄存器和栈内存共享IPC 手段管道/共享内存天然共享全局变量和堆崩溃影响不影响其他进程一个线程崩溃可能拖垮整个进程适用场景隔离性要求高高并发、实时性要求高在嵌入式 Linux 中线程的优势尤为明显传感器线程、网络通信线程、数据处理线程可以各司其职互不阻塞。三、创建线程pthread_create#includepthread.hintpthread_create(pthread_t*thread,constpthread_attr_t*attr,void*(*start_routine)(void*),void*arg);看起来参数多拆解一下thread输出参数保存新线程的 IDattr线程属性NULL 表示默认start_routine线程入口函数必须是void* func(void* arg)签名arg传给入口函数的参数编译时需要链接 pthread 库gcc-oapp main.c-lpthread基础示例#includestdio.h#includepthread.h#includeunistd.hvoid*sensor_task(void*arg){intid*(int*)arg;for(inti0;i5;i){printf([传感器%d] 第%d次采样\n,id,i1);sleep(1);}printf([传感器%d] 采集结束\n,id);returnNULL;}intmain(void){pthread_ttid1,tid2;intid11,id22;pthread_create(tid1,NULL,sensor_task,id1);pthread_create(tid2,NULL,sensor_task,id2);// 主线程等待两个子线程结束pthread_join(tid1,NULL);pthread_join(tid2,NULL);printf(所有传感器采集完成\n);return0;}pthread_join会阻塞当前线程直到目标线程结束——类似于进程中的waitpid。四、互斥锁保护共享数据多线程同时访问同一变量时会出现竞态条件Race Condition。想象两个线程同时对counter操作线程A: 读 counter(0) → 加1(1) → 写 counter(1) 线程B: 读 counter(0) → 加1(1) → 写 counter(1)本应是 2结果却是 1——这就是数据竞争。解决方式是互斥锁Mutex。#includepthread.hpthread_mutex_tlockPTHREAD_MUTEX_INITIALIZER;intshared_counter0;void*worker(void*arg){for(inti0;i100000;i){pthread_mutex_lock(lock);// 加锁shared_counter;// 临界区pthread_mutex_unlock(lock);// 解锁}returnNULL;}互斥锁像厕所的锁——一个人进去了就锁门别人在外面等着。出来解锁后下一个人才能进去。互斥锁的四种操作函数行为pthread_mutex_lock阻塞等待直到拿到锁pthread_mutex_trylock立即返回拿不到锁返回 EBUSYpthread_mutex_unlock释放锁pthread_mutex_destroy销毁锁用动态方式创建的静态初始化用PTHREAD_MUTEX_INITIALIZER动态初始化用pthread_mutex_init。五、死锁当两把锁互相等待这是多线程编程中最让人头疼的问题。看这段代码pthread_mutex_tlockAPTHREAD_MUTEX_INITIALIZER;pthread_mutex_tlockBPTHREAD_MUTEX_INITIALIZER;// 线程1void*thread1(void*arg){pthread_mutex_lock(lockA);// 拿到 Asleep(1);// 给线程2时间去拿 Bpthread_mutex_lock(lockB);// 等待 B...// ...}// 线程2void*thread2(void*arg){pthread_mutex_lock(lockB);// 拿到 Bsleep(1);// 给线程1时间去拿 Apthread_mutex_lock(lockA);// 等待 A...// ...}结果线程1 持有 A 等 B线程2 持有 B 等 A——谁也等不到谁死锁。避免死锁的黄金法则固定加锁顺序所有线程必须按相同顺序获取多把锁限制锁粒度锁保护的代码越少越好使用pthread_mutex_trylock拿不到就放弃稍后重试超时机制部分 pthread 实现支持pthread_mutex_timedlock固定加锁顺序举例// 无论哪个线程都先锁 lockA 再锁 lockBpthread_mutex_lock(lockA);pthread_mutex_lock(lockB);// 临界区...pthread_mutex_unlock(lockB);pthread_mutex_unlock(lockA);六、实战传感器采集 线程池模型下面是一个简化版的多线程传感器采集架构#includestdio.h#includestdlib.h#includepthread.h#includeunistd.h#defineSENSOR_COUNT3pthread_mutex_tdata_lockPTHREAD_MUTEX_INITIALIZER;// 共享数据缓冲区typedefstruct{floattemperature;floathumidity;floatpressure;intupdated;}SensorData;SensorData g_data{0};void*temp_sensor(void*arg){(void)arg;while(1){pthread_mutex_lock(data_lock);g_data.temperature25.0(rand()%100)/10.0;g_data.updated1;pthread_mutex_unlock(data_lock);sleep(2);}returnNULL;}void*report_thread(void*arg){(void)arg;while(1){pthread_mutex_lock(data_lock);if(g_data.updated){printf([上报] 温度%.1f°C\n,g_data.temperature);g_data.updated0;}pthread_mutex_unlock(data_lock);sleep(3);}returnNULL;}intmain(void){pthread_tt1,t2;pthread_create(t1,NULL,temp_sensor,NULL);pthread_create(t2,NULL,report_thread,NULL);pthread_join(t1,NULL);pthread_join(t2,NULL);return0;}这个架构很简单但实用采集线程定时更新共享数据上报线程定时读取并上报靠互斥锁保证数据一致性。七、总结多线程编程的核心就三件事创建与回收pthread_create/pthread_join数据保护互斥锁pthread_mutex_lock/unlock死锁避免固定加锁顺序、减小锁粒度、用 trylock在嵌入式 Linux 中线程是并行处理的主力。掌握互斥锁你的程序才能在高并发下稳如磐石。