线程同步——互斥锁
目录
一、互斥锁的概念
二、互斥锁的原理
三、互斥锁基本函数
3.1 pthread_mutex_init() 初始化互斥锁
3.2 pthread_mutex_lock() 加锁
3.3 pthread_mutex_unlock() 解锁
3.4 pthread_mutex_destroy() 销毁互斥锁
四、代码实现
一、互斥锁的概念
互斥锁(Mutex)是一种用于保护临界区(Critical Section)的同步机制,用于在多线程环境下防止多个线程同时访问共享资源。互斥锁能够确保在同一时间只有一个线程能够进入临界区,其他线程必须等待这个线程退出临界区后才能进入。
当一个线程希望进入临界区时,它会尝试获取互斥锁。如果锁已经被其他线程持有,则这个线程会被阻塞,直到锁被释放。一旦线程进入临界区后,它会执行完需要保护的操作,然后释放互斥锁,让其他线程能够进入。
互斥锁是实现线程同步的重要工具之一,能够有效避免多个线程同时访问共享资源导致的竞态条件(Race Condition)问题。在使用互斥锁时,需要注意避免死锁(Deadlock)等问题,确保锁的获取和释放都能顺利进行。
二、互斥锁的原理
互斥锁是一种用于保护共享资源,防止多个线程同时访问的同步机制。其原理可以简单描述为:
- 当一个线程需要访问共享资源时,首先尝试获取互斥锁。
- 如果互斥锁当前未被其他线程持有,则该线程成功获取互斥锁,可以执行临界区代码。
- 如果互斥锁已经被其他线程持有,则当前线程被阻塞,直到互斥锁被释放。
- 当线程执行完临界区代码后,释放互斥锁,使得其他线程可以继续获取互斥锁并访问共享资源。
互斥锁的实现可以通过硬件支持或操作系统提供的原子操作来实现,确保在多线程环境下的线程安全性。通过互斥锁可以有效地避免多个线程同时访问共享资源而导致的数据竞争和不确定性结果。
三、互斥锁基本函数
3.1 pthread_mutex_init() 初始化互斥锁
此函数的作用是初始化一个互斥锁对象,并将其属性设置为指定的属性值。
参数说明:
- mutex: 指向pthread_mutex_t类型的指针,用于指定要初始化的互斥锁对象。
- attr: 指向pthread_mutexattr_t类型的指针,用于指定互斥锁的属性。可以为NULL,表示使用默认属性。
返回值:
- 如果函数执行成功,则返回0;若出现错误,则返回对应的错误码。
3.2 pthread_mutex_lock() 加锁
此函数的作用是尝试对指定的互斥锁对象进行加锁操作。如果当前的互斥锁对象已经被其他线程锁住,则调用线程会被阻塞,直到获得锁为止。
参数说明:
- mutex: 指向pthread_mutex_t类型的指针,用于指定要加锁的互斥锁对象。
返回值:
- 如果函数执行成功,则返回0;若出现错误,则返回对应的错误码。
3.3 pthread_mutex_unlock() 解锁
此函数的作用是对指定的互斥锁对象进行解锁操作,使其他线程可以获得该互斥锁并访问共享资源。
参数说明:
- mutex: 指向pthread_mutex_t类型的指针,用于指定要解锁的互斥锁对象。
返回值:
- 如果函数执行成功,则返回0;若出现错误,则返回对应的错误码。
3.4 pthread_mutex_destroy() 销毁互斥锁
此函数的作用是销毁指定的互斥锁对象,释放相关资源并将其设置为未初始化状态。
参数说明:
- mutex: 指向pthread_mutex_t类型的指针,用于指定要销毁的互斥锁对象。
返回值:
- 如果函数执行成功,则返回0;若出现错误,则返回对应的错误码。
四、代码实现
#include<stdio.h>
#include<stdlib.h>
#include<string.h>
#include<unistd.h>
#include<pthread.h>
#include <semaphore.h>pthread_mutex_t mutex;//定义锁变量int g_val=1;void* fun(void* arg)
{for(int i=0;i<1000;i++){//ppthread_mutex_lock(&mutex);//进入临界区,加锁printf("g_val=%d\n",g_val++);pthread_mutex_unlock(&mutex);//出临界区,解锁//v}
}
int main()
{pthread_t id[5];pthread_mutex_init(&mutex,NULL);//初始化锁int i=0;for(;i<5;i++){pthread_create(&id[i],NULL,fun,NULL);}for(i=0;i<5;i++){pthread_join(id[i],NULL);}pthread_mutex_destroy(&mutex);//销毁互斥锁exit(0);
}
运行结果: