欢迎来到军工软件开发人才培养基地——学到牛牛

Linux线程间同步和互斥

时间:2024-05-06 07:01:10 来源:学到牛牛

在Linux系统中,线程是轻量级的进程,它们共享同一个地址空间和进程资源。由于多个线程可以同时访问共享资源,因此需要对线程进行同步和互斥操作,以避免数据竞争和死锁等问题。

 

1679014890021.jpg

 

线程同步的主要目的是确保多个线程按照预期的顺序执行。常用的线程同步机制包括信号量、互斥量、条件变量等。其中,互斥量和条件变量比较常用。

 

互斥量是一种用于保护共享资源的同步原语。它确保同一时间内只有一个线程可以访问共享资源。当一个线程想要访问共享资源时,它需要先获得互斥量的锁,然后才能访问共享资源。访问完成后,线程需要释放互斥量的锁,以便其他线程可以继续访问共享资源。

 

下面是一个互斥量的例子:

 

c复制代码#include <pthread.h>#include <stdio.h>int count = 0;pthread_mutex_t mutex;void* increment_count(void* arg) {    int i;    for (i = 0; i < 1000000; i++) {

        pthread_mutex_lock(&mutex);

        count++;

        pthread_mutex_unlock(&mutex);

    }

 

    pthread_exit(NULL);

}int main() {    pthread_t thread1, thread2;

 

    pthread_mutex_init(&mutex, NULL);

 

    pthread_create(&thread1, NULL, increment_count, NULL);

    pthread_create(&thread2, NULL, increment_count, NULL);

 

    pthread_join(thread1, NULL);

    pthread_join(thread2, NULL);

 

    pthread_mutex_destroy(&mutex);    printf("Count: %d ", count);    return 0;

}

在这个例子中,我们使用了一个互斥量来保护count变量,使得同时只有一个线程能够访问它。increment_count函数对count变量进行1000000次自增操作,每次自增操作之前需要获取互斥量的锁,自增操作完成后再释放互斥量的锁。

 

条件变量是一种用于控制线程运行顺序的同步原语。它使得线程可以等待某个条件成立才能继续执行。条件变量通常和互斥量一起使用,以保证在修改条件变量和等待条件变量之间不会发生竞态条件(race condition)。

 

下面是一个条件变量的例子:

 

c复制代码#include <pthread.h>#include <stdio.h>#define MAX_COUNT 10int count = 0;pthread_mutex_t mutex;pthread_cond_t cond;void* print_numbers(void* arg) {    int i;    for (i = 0; i < MAX_COUNT; i++) {

        pthread_mutex_lock(&mutex);        while (count % 2 != 0) {

            pthread_cond_wait(&cond, &mutex);

        }        printf("%d ", i);

        count++;

 

        pthread_mutex_unlock(&mutex);

        pthread_cond_signal(&cond);

    }

 

    pthread_exit(NULL);

}int main() {    pthread_t thread;

 

    pthread_mutex_init(&mutex, NULL);

    pthread_cond_init(&cond, NULL);

 

    pthread_create(&thread, NULL, print_numbers, NULL);    int i;    for (i = 0; i < MAX_COUNT; i++) {

        pthread_mutex_lock(&mutex);        while (count % 2 == 0) {

            pthread_cond_wait(&cond, &mutex);

        }        printf("%d ", i);

        count++;

 

        pthread_mutex_unlock(&mutex);

        pthread_cond_signal(&cond);

    }

 

    pthread_join(thread, NULL);

 

    pthread_mutex_destroy(&mutex);

    pthread_cond_destroy(&cond);    return 0;

}

在这个例子中,我们使用了一个条件变量和一个互斥量来实现两个线程交替打印数字。print_numbers函数会打印MAX_COUNT个数字,并且每次打印完一个数字之后都会发送一个信号给另外一个等待线程,以便让它继续执行。另外一个线程会等待条件变量的信号,并在接收到信号后打印数字。

 

需要注意的是,在使用条件变量时,需要先获取互斥量的锁。这是因为当一个线程在等待条件变量时,其他线程可能会修改共享资源。因此,在修改共享资源和等待条件变量之间需要使用互斥量来保护共享资源的一致性。

 

综上所述,Linux中的线程同步和互斥操作是非常重要的。通过使用不同的同步机制,可以有效地避免数据竞争和死锁等问题,保证多线程程序的正确性。在实际编程中,需要根据具体的需求选择合适的同步机制,并正确地使用它们。