正文

C语言中的线程同步：掌握互斥锁、条件变量与信号量，避免数据竞争与死锁陷阱

/0 浏览量
1015

在多线程编程中，线程同步是确保数据一致性和程序正确性的关键。C语言作为一种广泛使用的编程语言，提供了多种机制来帮助开发者实现线程同步。本文将详细介绍互斥锁、条件变量与信号量，并探讨如何避免数据竞争与死锁陷阱。

互斥锁（Mutex）

互斥锁是一种基本的同步机制，用于确保同一时间只有一个线程可以访问共享资源。在C语言中，互斥锁通常通过POSIX线程库（pthread）实现。

互斥锁的基本使用

以下是一个使用互斥锁的简单示例：

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

pthread_mutex_t lock;

void *thread_function(void *arg) {
    pthread_mutex_lock(&lock);
    // 临界区代码
    printf("Thread %d is running\n", *(int *)arg);
    pthread_mutex_unlock(&lock);
    return NULL;
}

int main() {
    pthread_t threads[2];
    int args[2] = {0, 1};

    pthread_mutex_init(&lock, NULL);

    for (int i = 0; i < 2; i++) {
        pthread_create(&threads[i], NULL, thread_function, &args[i]);
    }

    for (int i = 0; i < 2; i++) {
        pthread_join(threads[i], NULL);
    }

    pthread_mutex_destroy(&lock);
    return 0;
}

避免死锁

在使用互斥锁时，需要注意死锁问题。以下是一些避免死锁的建议：

  • 尽量减少持有锁的时间。
  • 遵循“先来先服务”的原则，确保所有线程以相同的顺序获取锁。
  • 使用锁顺序图来分析可能的死锁情况。

条件变量（Condition Variable）

条件变量用于在线程之间进行同步，允许一个或多个线程等待某个条件成立。在C语言中，条件变量同样通过pthread库实现。

条件变量的基本使用

以下是一个使用条件变量的示例：

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

pthread_mutex_t lock;
pthread_cond_t cond;

void *producer(void *arg) {
    pthread_mutex_lock(&lock);
    // 生产数据
    printf("Producer produced data\n");
    pthread_cond_signal(&cond);
    pthread_mutex_unlock(&lock);
    return NULL;
}

void *consumer(void *arg) {
    pthread_mutex_lock(&lock);
    pthread_cond_wait(&cond, &lock);
    // 消费数据
    printf("Consumer consumed data\n");
    pthread_mutex_unlock(&lock);
    return NULL;
}

int main() {
    pthread_t prod, cons;

    pthread_mutex_init(&lock, NULL);
    pthread_cond_init(&cond, NULL);

    pthread_create(&prod, NULL, producer, NULL);
    pthread_create(&cons, NULL, consumer, NULL);

    pthread_join(prod, NULL);
    pthread_join(cons, NULL);

    pthread_mutex_destroy(&lock);
    pthread_cond_destroy(&cond);
    return 0;
}

避免竞态条件

在使用条件变量时，需要注意竞态条件。以下是一些避免竞态条件的建议：

  • 在条件变量上使用互斥锁，确保临界区代码的原子性。
  • 在条件变量上使用pthread_cond_broadcast代替pthread_cond_signal，以唤醒所有等待的线程。

信号量（Semaphore）

信号量是一种更通用的同步机制，可以表示资源数量。在C语言中，信号量同样通过pthread库实现。

信号量的基本使用

以下是一个使用信号量的示例：

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

pthread_sem_t sem;

void *thread_function(void *arg) {
    pthread_sem_wait(&sem);
    // 使用资源
    printf("Thread %d is running\n", *(int *)arg);
    pthread_sem_post(&sem);
    return NULL;
}

int main() {
    pthread_t threads[2];
    int args[2] = {0, 1};

    pthread_sem_init(&sem, 1, 1);

    for (int i = 0; i < 2; i++) {
        pthread_create(&threads[i], NULL, thread_function, &args[i]);
    }

    for (int i = 0; i < 2; i++) {
        pthread_join(threads[i], NULL);
    }

    pthread_sem_destroy(&sem);
    return 0;
}

避免死锁

在使用信号量时，同样需要注意死锁问题。以下是一些避免死锁的建议：

  • 使用信号量组，确保信号量的顺序。
  • 使用pthread_sem_timedwait代替pthread_sem_wait，以避免无限等待。

总结

掌握互斥锁、条件变量与信号量是C语言多线程编程中的关键技能。通过合理使用这些同步机制，可以避免数据竞争与死锁陷阱，确保程序的正确性和稳定性。在实际开发中，应根据具体需求选择合适的同步机制，并注意避免常见问题。

-- 展开阅读全文 --