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: %d\n", total_primes);
    
    // 销毁互斥锁
    pthread_mutex_destroy(&mutex);
    return 0;
}