【原创】手把手教你Linux下的多线程设计--Linux下多线程编程详解(三)

简介: 本文可任意转载,但必须注明作者和出处。【原创】手把手教你Linux下的多线程设计(三)                                      --Linux下多线程编程详解 原创作者:Frozen_socker(冰棍)    E_mail:dlskyfly@163.com线程互斥 互斥操作,就是对某段代码或某个变量修改的时候只能有一个线程在执行这段代码,其他线程不能同时进入这段代码或同时修改该变量。

本文可任意转载,但必须注明作者和出处。

【原创】手把手教你Linux下的多线程设计(三)
                                      --Linux下多线程编程详解
 
原创作者:Frozen_socker(冰棍)  
 E_mail:dlskyfly@163.com

线程互斥

 

互斥操作,就是对某段代码或某个变量修改的时候只能有一个线程在执行这段代码,其他线程不能同时进入这段代码或同时修改该变量。这个代码或变量称为临界资源。

 

 

例如:有两个线程A和B,临界资源为X,首先线程A进入,将X置为加锁状态,在A将锁打开之前的这段时间里,如果此时恰巧线程B也欲获得X,但它发现X处于加锁状态,说明有其它线程正在执行互斥部分,于是,线程B将自身阻塞。。。线程A处理完毕,在退出前,将X解锁,并将其它线程唤醒,于是线程B开始对X进行加锁操作了。通过这种方式,实现了两个不同线程的交替操作。

 

 

 记住一个互斥体永远不可能同时属于两个线程。或者处于锁定状态;或者空闲中,不属于任何一个线程。

 

 

 

 代码如下:

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

void * pthread_func_test(void *  arg);

pthread_mutex_t mu;

int
 main()
...
{
    
int
 i;
    pthread_t pt;
    
    pthread_mutex_init(
&mu,NULL);        //声明mu使用默认属性,此行可以不写

    pthread_create(&pt,NULL,pthread_func_test,NULL);
    
for(i = 0; i < 3; i++
)
    
...
{
        pthread_mutex_lock(
&
mu);
        printf(
"主线程ID是:%lu  ",pthread_self());        //pthread_self函数作用:获得当前线程的id

        pthread_mutex_unlock(&mu);
        sleep(
1
);
    }
    
}


void * pthread_func_test(void *  arg)
...
{
    
int
 j;
    
for(j = 0; j < 3; j++
)
    
...
{
        pthread_mutex_lock(
&
mu);
        printf(
"新线程ID是:%lu  "
,pthread_self());
        pthread_mutex_unlock(
&
mu);
        sleep(
1
);
    }

}

 

 

 

终端输出结果:

主线程ID是 : 3086493376
新线程ID是 : 
3086490512

主线程ID是 : 
3086493376
新线程ID是 : 
3086490512

主线程ID是 : 
3086493376
新线程ID是 : 
3086490512

 

注:在你机器上运行的结果很可能与这里显示的不一样。

 

 

   

pthread_mutex_lock声明开始用互斥锁上锁,此后的代码直至调用pthread_mutex_unlock为止,都处于加锁状态中,即同一时间只能被一个线程调用执行。当另一个线程执行到pthread_mutex_lock处时,如果该锁此时被其它线程使用,那么该线程被阻塞,即程序将等待到其它线程释放此互斥锁。

 

 

 

上述例子中,涉及到了几个函数:pthread_mutex_init/pthread_mutex_lock/pthread_mutex_unlock/pthread_mutex_destroy/pthread_self

 

 

  函数原型:

int pthread_mutex_init(pthread_mutex_t * restrict mutex,
                                                
const pthread_mutexattr_t *restrict attr);

 

函数作用:

初始化互斥体类型变量mutex,变量的属性由attr进行指定。attr设为NULL,即采用默认属性,这种方式与pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER的方式等价。

 

 

函数原型: 

int pthread_mutex_lock(pthread_mutex_t *mutex);

 

函数作用:

用来锁住互斥体变量。如果参数mutex所指的互斥体已经被锁住了,那么发出调用的线程将被阻塞直到其他线程对mutex解锁为止。

 

 

 

函数原型:

int pthread_mutex_unlock(pthread_mutex_t *mutex);

 

函数作用:

如果当前的线程拥有参数mutex所指定的互斥体,那么该函数调用将该互斥体解锁。

 

 

 

函数原型:

int pthread_mutex_destroy(pthread_mutex_t *mutex);

 

函数作用:

用来释放互斥体所占用的资源。

 

 

 

函数原型:

pthread_t pthread_self( void );

函数作用:获得线程自身的ID。前面我们已经提到过,pthread_t的类型为unsigned long int,所以在打印的时候要使用%lu方式,否则将产生奇怪的结果。

  

 

 

但是上面的代码并不完善,假设将循环次数修改得足够的长,打印后的结果可能并不是我们所希望看到的交替打印,可能象下面这样:

主线程ID是 : 3086493376
新线程ID是 : 
3086490512
 
主线程ID是 : 
3086493376
新线程ID是 : 
3086490512

新线程ID是 : 
3086490512
主线程ID是 : 
3086493376

 

 

 

这是什么原因呢?因为Linux是分时操作系统,采用的是时间片轮转的方式,主线程和新线程可能因为其它因素的干扰,获得了非顺序的时间片。如果想要严格的做到“交替”方式,可以略施小计,即加入一个标志。

 

 

   

完整程序如下:

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

void * pthread_func_test(void *  arg);

pthread_mutex_t mu;
int flag = 0
;

int
 main()
...
{
    
int
 i;
    pthread_t pt;
    
    pthread_mutex_init(
&
mu,NULL);
    pthread_create(
&
pt,NULL,pthread_func_test,NULL);
    
for(i = 0; i < 3; i++
)
    
...
{
        pthread_mutex_lock(
&
mu);
        
if(flag == 0
)
                printf(
"主线程ID是:%lu  "
,pthread_self());    
        flag 
= 1
;        
        pthread_mutex_unlock(
&
mu);
        sleep(
1
);
    }

    pthread_join(pt, NULL);
    pthread_mutex_destroy(
&mu);    
}


void * pthread_func_test(void *  arg)
...
{
    
int
 j;
    
for(j = 0; j < 3; j++
)
    
...
{
        pthread_mutex_lock(
&
mu);
        
if(flag == 1
)
            printf(
"新线程ID是:%lu  "
,pthread_self());
        flag 
== 0
;
        pthread_mutex_unlock(
&
mu);
        sleep(
1
);
    }

}

 

 

在使用互斥锁的过程中很有可能会出现死锁:即两个线程试图同时占用两个资源,并按不同的次序锁定相应的互斥锁,例如两个线程都需要锁定互斥锁1和互斥锁2,A线程先锁定互斥锁1,B线程先锁定互斥锁2,这时就出现了死锁。此时我们可以使用函数pthread_mutex_trylock,该函数企图锁住一个互斥体,但不阻塞。

 

 

 

函数原型:

int pthread_mutex_trylock(pthread_mutex_t *mutex);

函数pthread_mutex_trylock()用来锁住参数mutex所指定的互斥体。如果参数mutex所指的互斥体已经被上锁,该调用不会阻塞等待互斥体的解锁,而会返回一个错误代码。通过对返回代码的判断,程序员就可以针对死锁做出相应的处理。所以在对多个互斥体编程中,尤其要注意这一点。

 

 

 

经过以上的讲解,我们就学习了Linux下关于多线程方面对互斥体变量的操作。下一节,将给大家讲解有关线程同步方面的知识点。

目录
相关文章
|
10天前
|
存储 Java 数据库连接
java多线程之线程通信
java多线程之线程通信
|
17天前
|
Linux C++
LInux下Posix的传统线程示例
LInux下Posix的传统线程示例
15 1
|
21天前
|
存储 缓存 NoSQL
Redis单线程已经很快了6.0引入多线程
Redis单线程已经很快了6.0引入多线程
31 3
|
24天前
|
消息中间件 安全 Linux
线程同步与IPC:单进程多线程环境下的选择与权衡
线程同步与IPC:单进程多线程环境下的选择与权衡
57 0
|
1月前
|
Java 调度 C#
C#学习系列相关之多线程(一)----常用多线程方法总结
C#学习系列相关之多线程(一)----常用多线程方法总结
|
24天前
|
算法 Unix Linux
Linux与Qt线程优先级的对应关系:一次全面解析
Linux与Qt线程优先级的对应关系:一次全面解析
21 0
|
1月前
|
数据采集 存储 Java
「多线程大杀器」Python并发编程利器:ThreadPoolExecutor,让你一次性轻松开启多个线程,秒杀大量任务!
「多线程大杀器」Python并发编程利器:ThreadPoolExecutor,让你一次性轻松开启多个线程,秒杀大量任务!
|
25天前
|
消息中间件 Linux 调度
【Linux 进程/线程状态 】深入理解Linux C++中的进程/线程状态:阻塞,休眠,僵死
【Linux 进程/线程状态 】深入理解Linux C++中的进程/线程状态:阻塞,休眠,僵死
65 0
|
1月前
|
资源调度 算法 Linux
Linux进程/线程的调度机制介绍:详细解析Linux系统中进程/线程的调度优先级规则
Linux进程/线程的调度机制介绍:详细解析Linux系统中进程/线程的调度优先级规则
51 0
|
1月前
|
存储 安全 数据管理
Linux系统编程教程之Linux线程函数的使用:讲解Linux线程函数
Linux系统编程教程之Linux线程函数的使用:讲解Linux线程函数
18 1