跳到主要内容

C 语言POSIX线程

在现代计算机系统中，多线程编程是提高程序性能和响应能力的重要手段。POSIX线程（也称为pthread）是C语言中实现多线程编程的标准库。通过使用pthread，开发者可以创建、管理和同步多个线程，从而充分利用多核处理器的计算能力。

什么是POSIX线程？​

POSIX线程（pthread）是遵循POSIX标准的多线程编程接口。它允许程序在同一进程中创建多个线程，每个线程可以独立执行任务。线程是轻量级的执行单元，共享同一进程的内存空间，但拥有独立的栈空间。

为什么使用多线程？​

  • 提高性能：多线程可以并行执行任务，充分利用多核CPU的计算能力。
  • 提高响应能力：在图形界面或网络应用中，多线程可以避免阻塞主线程，提高用户体验。
  • 资源共享：线程共享进程的内存空间，可以方便地共享数据和资源。

创建线程​

在C语言中，使用 pthread_create 函数创建线程。以下是一个简单的示例：

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

void* thread_function(void* arg) {
    printf("Hello from thread!\n");
    return NULL;
}

int main() {
    pthread_t thread_id;
    pthread_create(&thread_id, NULL, thread_function, NULL);
    pthread_join(thread_id, NULL);
    printf("Thread has finished execution.\n");
    return 0;
}

代码解释​

  • pthread_create：创建一个新线程，第一个参数是线程标识符，第二个参数是线程属性（通常为NULL），第三个参数是线程执行的函数，第四个参数是传递给线程函数的参数。
  • pthread_join：等待指定线程结束，确保主线程在子线程完成后继续执行。

输出​

Hello from thread!
Thread has finished execution.

线程同步​

当多个线程访问共享资源时，可能会出现竞争条件（race condition）。为了避免这种情况，可以使用互斥锁（mutex）来同步线程。

使用互斥锁​

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

int counter = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;

void* increment_counter(void* arg) {
    for (int i = 0; i < 100000; i++) {
        pthread_mutex_lock(&mutex);
        counter++;
        pthread_mutex_unlock(&mutex);
    }
    return NULL;
}

int main() {
    pthread_t thread1, thread2;
    pthread_create(&thread1, NULL, increment_counter, NULL);
    pthread_create(&thread2, NULL, increment_counter, NULL);
    pthread_join(thread1, NULL);
    pthread_join(thread2, NULL);
    printf("Final counter value: %d\n", counter);
    return 0;
}

代码解释​

  • pthread_mutex_lock：锁定互斥锁，确保只有一个线程可以访问共享资源。
  • pthread_mutex_unlock：解锁互斥锁，允许其他线程访问共享资源。

输出​

Final counter value: 200000
备注

如果没有使用互斥锁，counter 的最终值可能会小于200000，因为多个线程可能会同时修改 counter，导致数据不一致。

线程通信​

线程之间可以通过共享内存进行通信，但为了避免竞争条件，通常需要使用条件变量（condition variable）来同步线程的执行。

使用条件变量​

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

int data_ready = 0;
pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;
pthread_cond_t cond = PTHREAD_COND_INITIALIZER;

void* producer(void* arg) {
    pthread_mutex_lock(&mutex);
    data_ready = 1;
    pthread_cond_signal(&cond);
    pthread_mutex_unlock(&mutex);
    return NULL;
}

void* consumer(void* arg) {
    pthread_mutex_lock(&mutex);
    while (!data_ready) {
        pthread_cond_wait(&cond, &mutex);
    }
    printf("Data is ready!\n");
    pthread_mutex_unlock(&mutex);
    return NULL;
}

int main() {
    pthread_t producer_thread, consumer_thread;
    pthread_create(&producer_thread, NULL, producer, NULL);
    pthread_create(&consumer_thread, NULL, consumer, NULL);
    pthread_join(producer_thread, NULL);
    pthread_join(consumer_thread, NULL);
    return 0;
}

代码解释​

  • pthread_cond_signal：唤醒等待条件变量的线程。
  • pthread_cond_wait：使线程等待条件变量，并释放互斥锁。

输出​

Data is ready!

实际应用场景​

多线程编程在许多实际应用中都有广泛的应用，例如：

  • Web服务器：每个客户端请求可以由一个独立的线程处理，提高服务器的并发处理能力。
  • 图形界面：主线程负责界面渲染，后台线程处理计算任务，避免界面卡顿。
  • 数据处理：将大数据集分割成多个部分，由多个线程并行处理，提高处理速度。

总结​

POSIX线程为C语言提供了强大的多线程编程能力。通过创建、同步和通信线程，开发者可以编写高效、并发的程序。掌握pthread的基本用法是学习多线程编程的重要一步。

附加资源​

练习​

  1. 修改第一个示例，创建两个线程，分别打印不同的消息。
  2. 使用互斥锁和条件变量实现一个生产者-消费者模型，确保生产者和消费者线程正确同步。
  3. 编写一个多线程程序，计算一个大数组的和，并将数组分割成多个部分由不同线程处理。

通过完成这些练习，你将更深入地理解POSIX线程的使用。