C语言多线程编程：实战优化与疑难解答

C 语言多线程编程：实战优化与疑难解答

在现代计算机系统中，多线程编程已成为提高应用程序性能的必备技术。本文将探讨 C 语言中的多线程编程，包括优化技巧和常见疑难解答，并提供实战案例以加深理解。

优化技巧

• 使用互斥锁保护共享数据：使用互斥锁可以防止多个线程同时访问共享数据，避免竞争条件和数据损坏。
• 优化锁粒度：使用细粒度的锁（只锁住真正需要的资源）可以提高性能。
• 利用并发原语：使用条件变量、信号量和栅栏等并发原语可以提高代码的可读性和可靠性。
• 减少线程创建和销毁：创建和销毁线程需要耗费资源，尽量重用线程可以提高效率。

疑难解答

• 死锁：当两个或多个线程都在等待对方释放锁时，就会发生死锁。避免死锁的一种方法是遵循一种锁定的顺序。
• 竞态条件：当多个线程同时访问共享数据时，就会发生竞态条件。使用互斥锁或原子操作可以解决此问题。
• 数据损坏：当多个线程同时修改共享数据时，可能会导致数据损坏。使用保护机制（例如互斥锁）可以防止这种情况发生。

实战案例

让我们考虑一个计算素数的程序。我们可以使用多线程来并行计算不同范围的素数：

#include <pthread.h>
#include <stdio.h>
#include <stdlib.h>

// 线程参数结构体
typedef struct {
    int start;
    int end;
} thread_args_t;

// 素数计算线程函数
void* prime_thread(void* arg) {
    thread_args_t* args = (thread_args_t*)arg;
    int num_primes = 0;
    
    // 在指定的范围内查找素数
    for (int i = args->start; i < args->end; i++) {
        // 判断 i 是否是素数
        int is_prime = 1;
        for (int j = 2; j * j <= i; j++) {
            if (i % j == 0) {
                is_prime = 0;
                break;
            }
        }
        
        if (is_prime) {
            num_primes++;
        }
    }
    
    // 将结果传递回主线程
    return (void*)num_primes;
}

int main(int argc, char** argv) {
    int num_threads = 4;   // 线程数量
    int num_ranges = 5;     // 素数计算范围数量
    int start_ranges[num_ranges];  // 每个范围的起始值
    int end_ranges[num_ranges];    // 每个范围的结束值
    
    // 初始化范围
    int per_range = 100000 / num_ranges; // 每个范围的大小
    for (int i = 0; i < num_ranges; i++) {
        start_ranges[i] = per_range * i;
        end_ranges[i] = per_range * (i + 1);
    }
    
    // 创建互斥锁
    pthread_mutex_t mutex;
    pthread_mutex_init(&mutex, NULL);
    
    // 创建线程
    pthread_t threads[num_threads];
    thread_args_t thread_args[num_threads];
    
    int total_primes = 0;
    for (int i = 0; i < num_threads; i++) {
        // 设置线程参数
        thread_args[i].start = start_ranges[i];
        thread_args[i].end = end_ranges[i];
        
        // 创建线程
        pthread_create(&threads[i], NULL, &prime_thread, &thread_args[i]);
    }
    
    // 等待所有线程完成
    for (int i = 0; i < num_threads; i++) {
        void* result;
        pthread_join(threads[i], &result);
        
        // 使用互斥锁保护对 total_primes 的访问
        pthread_mutex_lock(&mutex);
        total_primes += (int)result;
        pthread_mutex_unlock(&mutex);
    }
    
    // 打印结果
    printf("Total primes: %dn", total_primes);
    
    // 销毁互斥锁
    pthread_mutex_destroy(&mutex);
    return 0;
}