一、基础概念进程与线程1.1 什么是进程进程是操作系统进行资源分配和调度的基本单位是一个正在运行的程序实例。1.2 什么是线程线程是操作系统进行CPU调度的基本单位是进程内部的一条执行路径轻量级进程。1.3 经典类比进程 一间房子独立空间、水电线程 房子里的多个工人共享房间环境各自干活1.4 进程与线程的核心区别对比项进程线程资源分配单位✅ 是❌ 否CPU调度单位❌ 否✅ 是内存空间独立共享进程资源创建/切换开销大小通信方式IPC复杂共享变量简单需同步崩溃影响不影响其他进程导致整个进程崩溃二、核心概念同步、异步与互斥2.1 同步Synchronization定义一个任务发起操作后必须等待该操作完成才能继续执行。特点阻塞、顺序、可控。例子线程A调用read()读取文件文件未读完前线程A被挂起。风险若操作耗时会导致任务卡死。2.2 异步Asynchronous定义一个任务发起操作后无需等待操作完成立即继续执行后续代码。特点非阻塞、并发、效率高。例子Node.js异步I/O发起网络请求后立刻执行下一行代码。风险逻辑复杂回调地狱、状态管理难。2.3 互斥Mutual Exclusion定义防止多个任务同时访问同一共享资源保证资源的完整性。特点一次只允许一个任务进入临界区。例子两个线程同时修改全局变量通过加锁防止数据错乱。2.4 同步 vs 互斥 —— 一句话区分维度同步互斥核心问题“能不能走”协调顺序“能不能进”保护资源典型场景生产者没生产完消费者不能取两个线程同时修改全局变量类比接力棒跑完第一棒才能跑第二棒厕所门锁一次进一个人注意在并发编程中“同步”还有另一层含义——指控制多个任务对共享资源的访问顺序即互斥同步的总称。这与“同步操作 vs 异步操作”中的“同步”含义不同需根据上下文区分。三、通用OS中的同步与异步通用OSWindows、Linux、macOS、Android/iOS等强调功能全面和用户体验。3.1 同步机制通用OS机制说明典型API互斥量保护共享资源防止并发访问pthread_mutex_lock/unlock信号量控制资源访问数量或任务同步sem_wait/sem_post条件变量等待某个条件满足后再继续pthread_cond_wait/signal读写锁允许多读单写pthread_rwlock_rdlock/wrlock3.2 异步机制通用OS机制说明典型API信号进程间异步通知signal(),kill()AIO异步I/O操作aio_read,aio_errorepoll/IOCP事件驱动不轮询epoll_create,epoll_waitstd::asyncC异步任务std::async,future.get()四、RTOS中的同步与异步RTOS实时操作系统如FreeRTOS强调确定性和时间约束。4.1 RTOS中的同步机制RTOS中的同步指任务与任务之间或任务与中断之间的协调机制。机制用途关键特点二值信号量任务等待中断无优先级继承适合同步计数信号量多资源管理/生产消费可计数事件标志组等待多个事件与/或支持复杂触发条件消息队列任务间传递数据带阻塞超时典型同步示例任务A调用xSemaphoreTake()阻塞等待传感器数据中断ISR采集完数据调用xSemaphoreGiveFromISR()释放信号量任务A立即解除阻塞处理数据4.2 RTOS中的异步机制RTOS核心API大多是同步阻塞型如xQueueSend可设置超时。异步行为通常通过中断信号量/队列模拟异步场景实现方式中断异步通知ISR释放信号量后立即返回不等待任务处理任务异步消息任务A发送消息后继续执行不等待接收方处理定时器回调软件定时器回调在任务上下文中异步执行4.3 RTOS中的“同步”与“互斥”区分对比项同步互斥推荐工具二值信号量互斥量优先级继承❌ 不需要✅ 必须防优先级翻转是否可在中断中使用✅ 可以GiveFromISR❌ 不可以典型场景任务等待中断保护共享资源五、同步、异步、互斥三者的关系概念核心问题典型工具通用OS典型工具RTOS同步顺序协调能不能走条件变量、信号量二值信号量、事件标志组异步不等待结果epoll、AIO、信号中断信号量/队列互斥资源保护能不能进互斥量、读写锁互斥量优先级继承三者可以共存一个典型的生产者-消费者模型中互斥保护缓冲区防止同时修改同步协调生产者和消费者缓冲区空时消费者等待异步生产者生产后不等待消费者处理立即继续生产六、验证方法6.1 通用OS验证方法同步机制验证示例互斥量int counter 0; pthread_mutex_t mutex; void* thread(void* arg) { for(int i0; i10000; i) { pthread_mutex_lock(mutex); counter; pthread_mutex_unlock(mutex); } } // 验证加锁后结果正确20000不加锁结果错乱异步机制验证示例epollint epfd epoll_create(1); while(1) { int nfds epoll_wait(epfd, events, 10, -1); // 阻塞等待事件 // 验证只有socket有数据时才返回CPU空转为0% for(...) handle_event(); }6.2 RTOS验证方法同步机制验证示例响应延迟测量volatile uint32_t enter_time, exit_time; void ISR() { enter_time DWT_CYCCNT; // 读CPU周期计数器 xSemaphoreGiveFromISR(sem, woken); portYIELD_FROM_ISR(woken); } void Task() { xSemaphoreTake(sem, portMAX_DELAY); exit_time DWT_CYCCNT; uint32_t latency_us (exit_time - enter_time) / CPU_MHZ; // 验证延迟应在微秒级且基本恒定 }异步机制验证示例ISR不等待任务void ISR() { xSemaphoreGiveFromISR(sem, NULL); // 立即返回不等待 // 逻辑分析仪测量ISR出口到Task入口的时间差 } void Task() { xSemaphoreTake(sem, portMAX_DELAY); GPIO_Toggle(LED); // 示波器测量此引脚 }6.3 通用OS vs RTOS验证对比验证维度通用OSRTOS主要目标正确性无竞争、死锁正确性 实时性延迟确定核心工具软件分析工具硬件仪器逻辑分析仪关键指标吞吐量、锁等待时间中断延迟、响应时间、抖动七、总结核心概念一句话总结进程资源分配的基本单位拥有独立内存空间线程CPU调度的基本单位共享进程资源同步等待结果再继续阻塞异步不等待结果回头通知非阻塞互斥保护共享资源防止同时访问同步 vs 互斥同步问“能不能走”互质问“能不能进”通用OS重点公平性、吞吐量、功能丰富RTOS重点确定性、实时性、可预测延迟八、生产者-消费者模型多线程编程#include stdio.h #include stdlib.h #include pthread.h #include unistd.h // --- 配置参数 --- #define BUFFER_SIZE 5 // 缓冲区大小 #define NUM_ITEMS 10 // 每个生产者生产的总数量 #define PRODUCER_NUM 1 // 生产者线程数 #define CONSUMER_NUM 2 // 消费者线程数 // --- 共享资源 --- int buffer[BUFFER_SIZE]; // 环形缓冲区 int count 0; // 缓冲区当前元素个数 int in 0; // 生产者放入数据的索引 int out 0; // 消费者取出数据的索引 // --- 同步原语 --- pthread_mutex_t mutex; // 互斥锁 pthread_cond_t not_full; // 缓冲区未满条件变量 pthread_cond_t not_empty; // 缓冲区非空条件变量 // --- 生产者线程函数 --- void *producer(void *arg) { int id *(int *)arg; int item; for (int i 0; i NUM_ITEMS; i) { item rand() % 100; // 生产一个随机数据 // 1. 加锁 pthread_mutex_lock(mutex); // 2. 如果缓冲区满等待 while (count BUFFER_SIZE) { pthread_cond_wait(not_full, mutex); } // 3. 生产数据放入缓冲区 buffer[in] item; in (in 1) % BUFFER_SIZE; // 环形索引 count; printf(生产者 %d 生产了: %d (当前库存: %d)\n, id, item, count); // 4. 解锁 pthread_mutex_unlock(mutex); // 5. 通知消费者缓冲区不空了 pthread_cond_signal(not_empty); usleep(rand() % 100000); // 模拟生产耗时 } return NULL; } // --- 消费者线程函数 --- void *consumer(void *arg) { int id *(int *)arg; int item; // 消费者一直运行直到手动停止或根据逻辑退出 // 这里为了演示简单设定一个循环次数实际中通常由特定信号退出 int consumed_count 0; while (consumed_count NUM_ITEMS * PRODUCER_NUM / CONSUMER_NUM 5) { // 1. 加锁 pthread_mutex_lock(mutex); // 2. 如果缓冲区空等待 while (count 0) { pthread_cond_wait(not_empty, mutex); } // 3. 消费数据从缓冲区取出 item buffer[out]; out (out 1) % BUFFER_SIZE; count--; printf( 消费者 %d 消费了: %d (当前库存: %d)\n, id, item, count); // 4. 解锁 pthread_mutex_unlock(mutex); // 5. 通知生产者缓冲区不满 pthread_cond_signal(not_full); consumed_count; usleep(rand() % 150000); // 模拟消费耗时 } return NULL; } int main() { pthread_t pro_threads[PRODUCER_NUM]; pthread_t con_threads[CONSUMER_NUM]; int pro_ids[PRODUCER_NUM]; int con_ids[CONSUMER_NUM]; // 初始化互斥锁和条件变量 pthread_mutex_init(mutex, NULL); pthread_cond_init(not_full, NULL); pthread_cond_init(not_empty, NULL); // 创建生产者线程 for (int i 0; i PRODUCER_NUM; i) { pro_ids[i] i 1; pthread_create(pro_threads[i], NULL, producer, pro_ids[i]); } // 创建消费者线程 for (int i 0; i CONSUMER_NUM; i) { con_ids[i] i 1; pthread_create(con_threads[i], NULL, consumer, con_ids[i]); } // 等待所有生产者结束 for (int i 0; i PRODUCER_NUM; i) { pthread_join(pro_threads[i], NULL); } // 等待消费者结束这里简单等待一下实际场景可能需要更复杂的退出机制 sleep(2); // 销毁同步对象 pthread_mutex_destroy(mutex); pthread_cond_destroy(not_full); pthread_cond_destroy(not_empty); printf(主线程结束。\n); return 0; }在 Linux 或 macOS 终端中使用gcc编译并链接 pthread 库gcc producer_consumer.c -o pc_demo -lpthread ./pc_demo