linux多线程学习(四)——互斥锁线程控制

在前面的文章中提及到，一个进程中的多个线程是共享同一段资源的，由于线程对资源的竞争引出了锁。其中mutex是一种简单的加锁方法，这个互斥锁只有两种状态，那就是上锁和解锁，可以把互斥锁看作是某种意义上的全局变量。在某一时刻，只能有一个线程取得这个互斥上的锁，拥有上锁状态的线程可以对共享资源进行操作，而其他线程在该线程未解锁之前，够会被挂起，直到上锁的线程解开锁。可以这么说，互斥锁使得共享资源按序的在各个线程上操作。

互斥锁的操作主要包括互斥锁初始化、上锁、判断上锁、解锁、摧毁互斥锁。其中互斥锁可以分为快速互斥锁、递归互斥锁这检错互斥锁。这三种锁的区别主要在于其他未占有互斥锁的线程在希望得到互斥锁时是否需要等待挂起。快速锁是指调用线程会阻塞直到线程锁得到解锁为止。递归锁能够成功地返回并且增加调用线程在互斥上的加锁次数，比如一个链表在进行插入的操作时，可以进行查找的操作。检错锁则为快速互斥锁的非阻塞版本，它会立即返回并返回一个错误的信息。

1、函数简义。

（1）pthread_mutex_init

头文件： <pthread.h>

函数原型： int pthread_mutex_init (pthread_mutex_t* mutex,

const pthread_mutexattr_t* mutexattr);

函数传入值： mutex:互斥锁。

mutexattr:PTHREAD_MUTEX_INITIALIZER:创建快速互斥锁。

PTHREAD_RECURSIVE_MUTEX_INITIALIZER_NP:创建递归互斥锁。

PTHREAD_ERRORCHECK_MUTEX_INITIALIZER_NP:创建检错互斥锁。

函数返回值：成功：0

出错：-1

（2）上锁函数：

int pthread_mutex_lock(pthread_mutex_t* mutex);

int pthread_mutex_trylock (pthread_mutex_t* mutex);

int pthread_mutex_unlock (pthread_mutex_t* mutex);

int pthread_mutex_destroy (pthread_mutex_t* mutex);

函数传入值： mutex:互斥锁。

函数返回值：同上。

2、互斥锁实现。

[cpp] view plaincopy

include <stdio.h>
#include <stdlib.h>
#include <pthread.h>
#include <errno.h>
#include <unistd.h>
#define return_if_fail(p) /
if((p) == 0){printf("[%s]:func error!/n",__func__);return;}
typedef struct _PrivInfo
{
pthread_mutex_t mutex;
int lock_var;
time_t end_time;
}PrivInfo;
static void info_init (PrivInfo* thiz);
static void* pthread_func_1 (PrivInfo* thiz);
static void* pthread_func_2 (PrivInfo* thiz);
int main (int argc, char** argv)
{
pthread_t pt_1 = 0;
pthread_t pt_2 = 0;
int ret = 0;
PrivInfo* thiz = NULL;
thiz = (PrivInfo*)malloc (sizeof (PrivInfo));
if (thiz == NULL)
{
return -1;
}
info_init(thiz);
ret = pthread_create (&pt_1, NULL, (void*)pthread_func_1, thiz);
if (ret != 0)
{
perror ("pthread_1_create:");
}
ret = pthread_create (&pt_2, NULL, (void*)pthread_func_2, thiz);
{
perror ("pthread_2_create:");
}
pthread_join (pt_1, NULL);
pthread_join (pt_2, NULL);
pthread_mutex_destroy (&thiz->mutex);
free (thiz);
thiz = NULL;
return 0;
}
static void info_init (PrivInfo* thiz)
{
return_if_fail (thiz != NULL);
thiz->lock_var = 0;
thiz->end_time = time (NULL) + 10;
pthread_mutex_init (&thiz->mutex, NULL);
return;
}
static void* pthread_func_1 (PrivInfo* thiz)
{
return_if_fail (thiz != NULL);
int i = 0;
int ret = 0;
while (time (NULL) < thiz->end_time)
{
ret = pthread_mutex_lock (&thiz->mutex);
if (ret != 0)
{
perror ("[%s]pthread_mutex_lock");
}
else
{
printf ("pthread1:pthread1 lock the variable!/n");
}
for (i = 0; i < 2; i++)
{
sleep (1);
thiz->lock_var ++;
}
ret = pthread_mutex_unlock (&thiz->mutex);
if (ret != 0)
{
perror ("[%s]pthread_mutex_unlock");
}
else
{
printf ("pthread1: pthread1 unlock the variable./n");
}
}
return;
}
static void* pthread_func_2 (PrivInfo* thiz)
{
return_if_fail (thiz != NULL);
int ret = 0;
while (time (NULL) < thiz->end_time)
{
ret = pthread_mutex_trylock (&thiz->mutex);
if (ret == EBUSY)
{
printf ("pthread2:the variable is locked by thread1./n");
}
else
{
if (ret != 0)
{
perror ("[%s]pthread2_mutex_trylock");
}
else
{
printf ("pthread2: pthread2 lock the variable./n");
}
ret = pthread_mutex_unlock (&thiz->mutex);
if (ret != 0)
{
perror ("[%s]pthread_mutex_lock");
}
sleep (3);
}
}
}

在上例的中，是对变量lock_var的读写进行加锁，线程一是对其进行写，在写的时候，线程二不能对其进行读。直到线程一解锁，线程二得到互斥锁，才能进行读。同样，在线程二进行读的时候，线程一不能进行写。

今天讲述到这里，下一篇文章将讲述怎样通过信号量来达到互斥锁的效果。

linux多线程学习(四)——互斥锁线程控制相关推荐

艾伟：C#多线程学习(六) 互斥对象
本系列文章导航 C#多线程学习(一) 多线程的相关概念 C#多线程学习(二) 如何操纵一个线程 C#多线程学习(三) 生产者和消费者 C#多线程学习(四) 多线程的自动管理(线程池) C#多线程学习( ...
C#多线程学习(六) 互斥对象
C#多线程学习(六) 互斥对象原文链接:http://kb.cnblogs.com/page/42533/ 本系列文章导航 C#多线程学习(一) 多线程的相关概念 C#多线程学习(二) 如何操纵一个 ...
C#多线程学习(四) 多线程的自动管理(线程池) (转载系列)——继续搜索引擎研究...
在多线程的程序中,经常会出现两种情况: 一种情况: 应用程序中,线程把大部分的时间花费在等待状态,等待某个事件发生,然后才能给予响应这一般使用ThreadPo ...
linux多线程学习(五)——信号量线程控制
在上一篇文章中,讲述了线程中互斥锁的使用,达到对共享资源互斥使用.除了使用互斥锁,信号量,也就是操作系统中所提到的PV原语,能达到互斥和同步的效果,这就是今天我们所要讲述的信号量线程控制. PV原语是 ...
Linux与Shell学习--shell系列11--流程控制4（until循环）
until循环和while循环整体概念是一样的,只不过while循环的循环前提是满足while判断时进入子模块中,当不满足while判断条件时跳出循环,如果while判断条件一直满足就一直进行循环:u ...
C#多线程学习6——互斥对象
如何控制好多个线程相互之间的联系,不产生冲突和重复,这需要用到互斥对象,即:System.Threading 命名空间中的 Mutex 类. 我们可以把Mutex看作一个出租车,乘客看作线程.乘客首先 ...
Linux 多线程同步机制:互斥量、信号量、条件变量
互斥量:互斥量提供对共享资源的保护访问,它的两种状态:lock和unlock,用来保证某段时间内只有一个线程使用共享资源,互斥量的数据类型是pthread_mutex_t 主要涉及函数:pthread ...
day 34 守护线程守护进程互斥锁线程信号量生产者消费者
今日内容 1.守护进程vs 守护线程(*) 2.互斥锁(**) 3.信号量(**) 4.生产者消费者模型(*****) 5.GIL(什么时候用进程,什么时候用线程)(*****) 一.守护进程和守护线 ...
linux多线程编程之互斥锁
多线程并行运行,共享同一种互斥资源时,需要上互斥锁来运行,主要是用到pthread_mutex_lock函数和pthread_mutex_unlock函数对线程进行上锁和解锁下面是一个例子: #in ...

linux多线程学习(四)——互斥锁线程控制

linux多线程学习(四)——互斥锁线程控制相关推荐

最新文章

热门文章