1. Linux多线程编程基础在Unix/Linux系统中进程创建fork是传统的并发处理方式但这种方式存在明显的性能瓶颈。每次fork调用都需要复制父进程的内存映像、文件描述符等资源即使现代系统采用写时拷贝Copy-On-Write技术优化进程创建和销毁的开销仍然很高。此外进程间通信IPC机制复杂数据共享效率低下。线程Thread作为轻量级进程Lightweight Process应运而生创建速度比进程快10-100倍。在Linux中线程遵循POSIX标准称为Pthreads所有相关函数都以pthread_开头需要包含pthread.h头文件并链接libpthread库。注意编译Pthreads程序时需添加-lpthread参数例如gcc program.c -o program -lpthread1.1 线程与进程的关键区别同一进程内的所有线程共享以下资源全局变量进程指令和大多数数据打开的文件描述符信号处理程序和信号处置当前工作目录用户ID和组ID而每个线程独立拥有线程IDpthread_t类型寄存器集合包括程序计数器和栈指针局部变量栈errno变量信号掩码优先级// 获取当前线程ID的示例 pthread_t tid pthread_self(); printf(Current thread ID: %lu\n, (unsigned long)tid);2. 线程生命周期管理2.1 线程创建与终止创建线程使用pthread_create函数int pthread_create(pthread_t *thread, const pthread_attr_t *attr, void *(*start_routine) (void *), void *arg);参数说明thread输出参数返回新线程的IDattr线程属性NULL表示默认属性start_routine线程入口函数格式为void* func(void*)arg传递给线程函数的参数线程终止的三种方式线程函数中执行return被其他线程调用pthread_cancel取消线程自身调用pthread_exit// 线程退出示例 void* thread_func(void* arg) { if(/* error condition */) { pthread_exit((void*)-1); // 带错误码退出 } return (void*)0; // 正常退出 }2.2 线程同步与回收pthread_join用于等待线程结束并获取其返回值int pthread_join(pthread_t thread, void **retval);典型使用模式pthread_t tid; void* thread_result; pthread_create(tid, NULL, worker_thread, NULL); // ...其他工作... pthread_join(tid, thread_result); // 阻塞直到线程结束 printf(Thread exited with status: %p\n, thread_result);重要提示如果不关心线程返回值必须调用pthread_detach避免资源泄漏。已detach的线程无法被join。3. 线程同步机制3.1 互斥锁Mutex互斥锁用于保护临界区确保同一时间只有一个线程访问共享资源。pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER; void safe_increment(int* counter) { pthread_mutex_lock(mutex); (*counter); pthread_mutex_unlock(mutex); }常见问题及解决方案问题类型现象解决方案死锁多个线程互相等待对方释放锁1. 固定加锁顺序 2. 使用pthread_mutex_trylock忘记解锁资源永久被锁使用RAII模式或确保所有路径都解锁锁粒度太大性能低下减小临界区范围只保护必要操作3.2 条件变量Condition Variable条件变量用于线程间的状态通知必须与互斥锁配合使用。典型生产者-消费者模型pthread_mutex_t mutex PTHREAD_MUTEX_INITIALIZER; pthread_cond_t cond PTHREAD_COND_INITIALIZER; int item_available 0; // 生产者 void* producer(void* arg) { pthread_mutex_lock(mutex); // 生产物品... item_available 1; pthread_cond_signal(cond); // 通知消费者 pthread_mutex_unlock(mutex); return NULL; } // 消费者 void* consumer(void* arg) { pthread_mutex_lock(mutex); while(!item_available) { pthread_cond_wait(cond, mutex); // 自动释放锁并等待 } // 消费物品... item_available 0; pthread_mutex_unlock(mutex); return NULL; }关键点pthread_cond_wait必须放在while循环中避免虚假唤醒spurious wakeup3.3 读写锁Reader-Writer Lock读写锁允许多个读操作并发但写操作独占适合读多写少的场景。pthread_rwlock_t rwlock PTHREAD_RWLOCK_INITIALIZER; // 读者 void reader() { pthread_rwlock_rdlock(rwlock); // 读取共享数据... pthread_rwlock_unlock(rwlock); } // 写者 void writer() { pthread_rwlock_wrlock(rwlock); // 修改共享数据... pthread_rwlock_unlock(rwlock); }4. 高级线程控制4.1 线程属性定制通过pthread_attr_t可以设置线程的多种属性pthread_attr_t attr; pthread_attr_init(attr); // 设置栈大小单位字节 size_t stack_size 2 * 1024 * 1024; // 2MB pthread_attr_setstacksize(attr, stack_size); // 设置分离状态避免需要join pthread_attr_setdetachstate(attr, PTHREAD_CREATE_DETACHED); // 创建带有自定义属性的线程 pthread_t tid; pthread_create(tid, attr, thread_func, NULL); pthread_attr_destroy(attr); // 不再需要属性对象时销毁4.2 线程局部存储Thread-Local Storage每个线程拥有独立的变量副本__thread int thread_specific_var; // GCC扩展语法 // 或使用POSIX标准接口 pthread_key_t key; void init_key() { pthread_key_create(key, NULL); } void* thread_func(void* arg) { int* data malloc(sizeof(int)); *data 42; pthread_setspecific(key, data); // ... free(pthread_getspecific(key)); return NULL; }5. 实战经验与性能优化5.1 线程池实现要点任务队列设计使用链表或环形缓冲区必须保证线程安全的入队/出队操作合理设置队列大小避免内存耗尽工作者线程管理动态调整线程数量根据负载优雅退出机制异常处理策略// 简化的线程池结构 typedef struct { pthread_t* threads; int thread_count; pthread_mutex_t queue_lock; pthread_cond_t queue_cond; task_queue_t* task_queue; } thread_pool_t;5.2 性能调优技巧锁优化减小临界区范围使用读写锁替代互斥锁尝试无锁数据结构如原子操作CPU亲和性cpu_set_t cpuset; CPU_ZERO(cpuset); CPU_SET(core_id, cpuset); pthread_setaffinity_np(thread, sizeof(cpu_set_t), cpuset);避免优先级反转使用优先级继承协议PTHREAD_PRIO_INHERIT合理设置线程优先级5.3 常见陷阱与解决方案信号处理多线程中信号处理复杂建议专门用一个线程处理所有信号sigset_t set; sigfillset(set); pthread_sigmask(SIG_BLOCK, set, NULL); // 其他线程屏蔽所有信号资源清理使用pthread_cleanup_push/pop确保资源释放void cleanup_handler(void* arg) { free(arg); } void* thread_func(void* arg) { char* buffer malloc(1024); pthread_cleanup_push(cleanup_handler, buffer); // 使用buffer... pthread_cleanup_pop(1); // 执行清理 return NULL; }线程安全函数使用_r后缀的线程安全版本如rand_r替代rand避免使用非线程安全的库函数在实际项目中我曾遇到一个因未正确处理线程退出导致的资源泄漏问题。某个服务进程运行几天后就会因为打开文件过多而崩溃。通过valgrind检查发现大量线程退出时没有关闭它们打开的文件描述符。解决方案是使用pthread_cleanup_push注册清理函数确保所有资源都能正确释放。这个教训让我深刻认识到多线程编程中资源管理的重要性。