当前位置： 首页 > news >正文

C语言多线程编程详解：从入门到实战

news 2025/10/20 1:41:30

C语言多线程编程详解：从入门到实战

本文将全面介绍C语言中的多线程编程技术，重点讲解pthread库的核心函数接口及使用方法，并通过实例演示多线程的实际应用。

一、多线程编程基础

1.1 什么是线程

线程是操作系统能够进行运算调度的最小单位，被包含在进程之中，是进程中的实际运作单位。一个进程可以包含多个线程，这些线程共享进程的资源（如内存空间、文件描述符等），但拥有各自的栈空间和寄存器状态。

1.2 多线程的优势

  • 提高响应性：主线程保持响应，后台线程处理耗时任务
  • 提高资源利用率：充分利用多核CPU的计算能力
  • 经济高效：创建线程比创建进程开销小
  • 简化复杂任务：将复杂任务分解为多个线程协同处理

1.3 pthread库简介

POSIX线程（pthread）是C/C++中实现多线程的标准API，在Linux/Unix系统中广泛使用。使用时需包含头文件<pthread.h>，编译时需添加-pthread选项。

gcc program.c -o program -pthread

二、核心线程管理函数

2.1 创建线程 - pthread_create

int pthread_create(pthread_t *thread, const pthread_attr_t *attr,void *(*start_routine)(void *), void *arg);

参数说明：

  • thread：指向线程标识符的指针
  • attr：设置线程属性，通常设为NULL
  • start_routine：线程运行的函数指针
  • arg：传递给线程函数的参数

返回值： 成功返回0，失败返回错误码

示例代码：

#include <pthread.h>
#include <stdio.h>void* print_message(void *msg) {char *message = (char*)msg;printf("%s\n", message);return NULL;
}int main() {pthread_t thread1, thread2;char *msg1 = "Thread 1";char *msg2 = "Thread 2";pthread_create(&thread1, NULL, print_message, (void*)msg1);pthread_create(&thread2, NULL, print_message, (void*)msg2);pthread_join(thread1, NULL);pthread_join(thread2, NULL);return 0;
}

2.2 等待线程结束 - pthread_join

int pthread_join(pthread_t thread, void **retval);

参数说明：

  • thread：要等待的线程ID
  • retval：存储线程返回值的指针，可为NULL

返回值： 成功返回0，失败返回错误码

注意事项：

  • 调用线程将阻塞，直到目标线程结束
  • 每个线程只能被一个线程join一次
  • 未join的线程会产生"僵尸线程"，浪费系统资源

2.3 分离线程 - pthread_detach

int pthread_detach(pthread_t thread);

功能： 将线程设置为分离状态，线程结束后自动回收资源

使用场景： 不需要获取线程返回值，也不关心线程何时结束时使用

注意事项：

  • 分离状态的线程不能被join
  • 如果线程已结束，分离操作可能失败
  • 主线程退出后，分离线程也会终止

2.4 线程终止 - pthread_exit

void pthread_exit(void *retval);

功能： 显式终止当前线程，并返回一个值

注意事项：

  • 主线程调用pthread_exit不会导致进程退出
  • 线程函数执行return语句也会隐式调用pthread_exit

三、线程同步机制

3.1 互斥锁（Mutex）

初始化与销毁

// 静态初始化
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;// 动态初始化
int pthread_mutex_init(pthread_mutex_t *mutex, const pthread_mutexattr_t *attr);// 销毁互斥锁
int pthread_mutex_destroy(pthread_mutex_t *mutex);

加锁与解锁

int pthread_mutex_lock(pthread_mutex_t *mutex);   // 阻塞加锁
int pthread_mutex_trylock(pthread_mutex_t *mutex); // 非阻塞加锁
int pthread_mutex_unlock(pthread_mutex_t *mutex);  // 解锁

互斥锁示例：线程安全计数器

#include <pthread.h>int counter = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;void* increment(void *arg) {for (int i = 0; i < 100000; i++) {pthread_mutex_lock(&mutex);counter++;pthread_mutex_unlock(&mutex);}return NULL;
}int main() {pthread_t t1, t2;pthread_create(&t1, NULL, increment, NULL);pthread_create(&t2, NULL, increment, NULL);pthread_join(t1, NULL);pthread_join(t2, NULL);printf("Final counter value: %d\n", counter);return 0;
}

3.2 条件变量（Condition Variable）

初始化与销毁

// 静态初始化
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;// 动态初始化
int pthread_cond_init(pthread_cond_t *cond, const pthread_condattr_t *attr);// 销毁条件变量
int pthread_cond_destroy(pthread_cond_t *cond);

等待与通知

int pthread_cond_wait(pthread_cond_t *cond, pthread_mutex_t *mutex);int pthread_cond_signal(pthread_cond_t *cond);   // 唤醒一个等待线程
int pthread_cond_broadcast(pthread_cond_t *cond); // 唤醒所有等待线程

条件变量示例：生产者-消费者模型

#define BUFFER_SIZE 10int buffer[BUFFER_SIZE];
int count = 0;
int in = 0, out = 0;pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond_full = PTHREAD_COND_INITIALIZER;
pthread_cond_t cond_empty = PTHREAD_COND_INITIALIZER;void* producer(void *arg) {for (int i = 0; i < 20; i++) {pthread_mutex_lock(&mutex);while (count == BUFFER_SIZE) {pthread_cond_wait(&cond_empty, &mutex);}buffer[in] = i;in = (in + 1) % BUFFER_SIZE;count++;pthread_cond_signal(&cond_full);pthread_mutex_unlock(&mutex);}return NULL;
}void* consumer(void *arg) {for (int i = 0; i < 20; i++) {pthread_mutex_lock(&mutex);while (count == 0) {pthread_cond_wait(&cond_full, &mutex);}int item = buffer[out];out = (out + 1) % BUFFER_SIZE;count--;printf("Consumed: %d\n", item);pthread_cond_signal(&cond_empty);pthread_mutex_unlock(&mutex);}return NULL;
}

四、高级线程技术

4.1 线程属性设置

pthread_attr_t attr;
pthread_attr_init(&attr);// 设置分离状态
pthread_attr_setdetachstate(&attr, PTHREAD_CREATE_DETACHED);// 设置栈大小
size_t stack_size = 1024 * 1024; // 1MB
pthread_attr_setstacksize(&attr, stack_size);// 使用属性创建线程
pthread_t thread;
pthread_create(&thread, &attr, thread_function, NULL);// 销毁属性对象
pthread_attr_destroy(&attr);

4.2 线程局部存储（Thread-Local Storage）

#include <pthread.h>static __thread int tls_var;  // GCC扩展语法// POSIX标准方法
pthread_key_t key;void destructor(void *value) {free(value);
}void init_key() {pthread_key_create(&key, destructor);
}void* thread_func(void *arg) {int *data = malloc(sizeof(int));*data = pthread_self();pthread_setspecific(key, data);// 获取数据int *value = pthread_getspecific(key);printf("Thread %lu: value=%d\n", pthread_self(), *value);return NULL;
}

4.3 线程取消

int pthread_cancel(pthread_t thread);// 设置取消状态
int pthread_setcancelstate(int state, int *oldstate);
// state: PTHREAD_CANCEL_ENABLE, PTHREAD_CANCEL_DISABLE// 设置取消类型
int pthread_setcanceltype(int type, int *oldtype);
// type: PTHREAD_CANCEL_DEFERRED, PTHREAD_CANCEL_ASYNCHRONOUS// 设置取消点
void pthread_testcancel(void);

五、多线程编程最佳实践

  1. 避免竞态条件：始终使用同步机制保护共享资源
  2. 最小化锁的粒度：减少锁的持有时间，避免嵌套锁
  3. 防止死锁：按固定顺序获取锁，使用超时机制
  4. 优先使用读写锁：当读操作远多于写操作时
  5. 合理设置线程数：通常为CPU核心数的1-2倍
  6. 避免频繁创建销毁：使用线程池管理线程
  7. 检查返回值：所有pthread函数都应检查返回值

六、完整示例：多线程计算素数

#include <stdio.h>
#include <pthread.h>
#include <stdbool.h>#define NUM_THREADS 4
#define MAX_NUMBER 1000000typedef struct {int start;int end;int count;
} ThreadData;bool is_prime(int n) {if (n <= 1) return false;if (n == 2) return true;if (n % 2 == 0) return false;for (int i = 3; i * i <= n; i += 2) {if (n % i == 0) {return false;}}return true;
}void* count_primes(void *arg) {ThreadData *data = (ThreadData*)arg;data->count = 0;for (int i = data->start; i <= data->end; i++) {if (is_prime(i)) {data->count++;}}return NULL;
}int main() {pthread_t threads[NUM_THREADS];ThreadData data[NUM_THREADS];int range = MAX_NUMBER / NUM_THREADS;int total_primes = 0;// 创建线程for (int i = 0; i < NUM_THREADS; i++) {data[i].start = i * range + 1;data[i].end = (i == NUM_THREADS - 1) ? MAX_NUMBER : (i + 1) * range;pthread_create(&threads[i], NULL, count_primes, &data[i]);}// 等待线程完成并汇总结果for (int i = 0; i < NUM_THREADS; i++) {pthread_join(threads[i], NULL);total_primes += data[i].count;printf("Thread %d found %d primes in [%d, %d]\n", i, data[i].count, data[i].start, data[i].end);}printf("\nTotal primes between 1 and %d: %d\n", MAX_NUMBER, total_primes);return 0;
}

七、常见问题与调试技巧

  1. 段错误（Segmentation Fault）

    • 检查线程栈是否溢出
    • 确保共享数据访问受到保护
    • 避免返回局部变量的指针

  2. 死锁检测

    • 使用gdb调试：thread apply all bt
    • 使用helgrind工具检测数据竞争
    valgrind --tool=helgrind ./your_program

  3. 性能分析

    • 使用perf工具分析CPU使用情况
    • 使用pthread_mutex_timedlock检测锁争用

  4. 线程安全函数

    • 使用可重入函数（如rand_r替代rand）
    • 避免使用非线程安全的库函数

总结

C语言的多线程编程是高性能计算和并发处理的关键技术。掌握pthread库的核心函数、理解线程同步机制、遵循多线程最佳实践，能够帮助开发者构建高效可靠的并发程序。在实际开发中，应特别注意资源共享和线程安全的问题，合理使用同步原语避免竞态条件和死锁。

通过本文的学习，您应该已经掌握了：

  • 线程的创建、管理和终止
  • 互斥锁和条件变量的使用
  • 生产者-消费者等经典线程模型
  • 线程属性和高级线程技术
  • 多线程调试和优化方法

多线程编程需要大量的实践才能熟练掌握，建议从简单示例开始，逐步构建更复杂的并发应用。

http://www.sczhlp.com/news/2677/

相关文章：

  • Solon v3.4.2（Java 应用开发生态基座）
  • 图像ROI选择工具 (Image ROI Selector Tool)
  • 熵权法数据公式推导python代码实现熵权法综合评价、风险评分法
  • 第二十五天
  • Meterpreter reverse_tcp_x64 analysis
  • 111111
  • P1026 [NOIP 2001 提高组] 统计单词个数 题解
  • ModelGate 支持 Claude Code ，一键设置 AI 编程助手，开发效率极速提升！
  • day6_vue
  • 「反吸血」使用命令操作Windows防火墙以实现全自动/半自动的批量IP屏蔽
  • PDF + ZIP 合并器：把ZIP文件打包至PDF文件中
  • Project 2024 专业版安装教程详细图文教程（附安装包）
  • 数组动态初始化
  • [07.31学习笔记] Transformer部分结构学习 - Luna
  • (Solved) Cant Read Card Error Google Pay
  • lXml与XPath的使用
  • chapter6 express
  • 比特彗星常见问题-断网问题
  • 清华大学软件学院长聘副教授龙明盛：Timer 3.0 已经成为了“满血版”的时序大模型
  • request入门与使用
  • 7.31闲话
  • 7.30闲话
  • 关于c++的一些没有用的芝士 - AC-13
  • 搜维尔科技：Tesollo灵巧手推出新款机器人夹持器“DG-3F”
  • 【ESP8266】ESP8266 模块接入Deepseek大模型，实现AI女友的第一步
  • 图论题目总结
  • THUPC 2025 决赛 喜爱之钥
  • 408-OS之管程
  • java语法学习
  • 在 Ubuntu Server 上 使用 USB 无线网卡连接 Wifi