线程同步 互斥量(mutex) Linux函数
线程同步:
线程的同步需要用到互斥量(mutex)用pthread_mutex_t类型表示。
互斥量(mutex)是一种简单的加锁的方法来控制对关心资源的访问。在同一时间只有一个线程掌握某个互斥上的锁,拥有锁的线程可以对共享资源进行访问。如其它线程希望上锁一个已经被上了的互斥锁的资源。则该线程被挂起,知道拥有这把锁的线程释放锁为止。
用到的函数
#include <pthread.h>
int pthread_mutex_init(pthread_mutex_t*restrict mutex,
const pthread_mutexattr_t*restrict attr);
pthread_mutex_t mutex =PTHREAD_MUTEX_INITIALIZER;//和调用pthread_mutex_init()函数初始化锁是一样的。
功能:初始化锁
返回值:成功返回0
参数:
mutex:线程锁变量的地址
attr:线程锁变量的属性,要用默认的属性初始化锁就可以把它设为NULL
#include<pthread.h>
intpthread_mutex_destroy(pthread_mutex_t *mutex);
功能:销毁线程锁
返回值:成功返回0
参数:线程锁的地址
#include<pthread.h>
Int thread_mutex_lock(pthread_mutex_t*mutex);
功能:上锁(访问资源),如果互斥量已经上锁则线程将阻塞上互斥量解锁
返回值:成功返回0
#include<pthread.h>
Int thread_mutex_unlock(pthread_mutex_t*mutex);
功能:释放锁(释放资源)
返回值:成功返回0
参数:线程锁的地址
#include<pthread.h>
Int thread_mutex_trylock(pthread_mutex_t *mutex);
功能:如果线程不希望阻塞,它就可以用此函数尝试对互斥量加锁,如果互斥量未处于加锁状态,那么Int thread_mutex_trylock(pthread_mutex_t*mutex);将锁住互斥量,不会出现阻塞并返回0.,否则就会失败,不能锁住互斥量。
返回值:成功返回0
参数:线程锁的地址
例子:
#include<stdio.h>
#include<stdlib.h>
#include<fcntl.h>
#include<sys/stat.h>
#include<sys/types.h>
#include<pthread.h>
#define FILENAME "testfile"
int fd;
//pthread_mutex_tmutex_lock1,mutex_lock2
pthread_mutex_t mutex_lock1 = PTHREAD_MUTEX_INITIALIZER;
pthread_mutex_t mutex_lock2 = PTHREAD_MUTEX_INITIALIZER;
void *pthfun(void *arg)
{
int i=0;
while(i++<5)
{
pthread_mutex_lock(&mutex_lock1);
write(fd,"1",sizeof(char));
pthread_mutex_unlock(&mutex_lock2);
}
pthread_exit(((void *) 0));
// return ((void *) 10);
}
int main()
{
int i=0;
void * ret;
//pthread_mutex_init函数初始化锁。
//pthread_mutex_init(&mutex_lock1,NULL);
//pthread_mutex_init(&mutex_lock2,NULL);
pthread_ttid;
fd=open(FILENAME,O_RDWR|O_CREAT| O_APPEND | O_TRUNC,0666);
//O_TRUNC 将文件的长度截为0,(清空文件)
// O_APPEND 追加到文件尾 pthread_create(&tid,NULL,pthfun,NULL);
while(i++<5)
{
pthread_mutex_lock(&mutex_lock2);
write(fd,"1",sizeof(char));
pthread_mutex_unlock(&mutex_lock1);
}
pthread_join(tid,&ret);
printf("ret=%d\n", (int)ret);
close(fd);
pthread_mutex_destroy(&mutex_lock1);
pthread_mutex_destroy(&mutex_lock2);
return 0;
}
运行结果为:
看一个例子:
#include<stdio.h>
#include<stdlib.h>
#include<pthread.h>
pthread_mutex_t mutex_lock1 ,mutex_lock2;
int value=0;
void *pthfun(void *arg)
{
int i=0;
while(i++<5)
{
pthread_mutex_lock(&mutex_lock1);
value+=1;
printf("value+=1\n");
pthread_mutex_unlock(&mutex_lock2);
}
pthread_exit(((void*) 10));
}
int main()
{
int i=0;
void * ret;
pthread_mutex_init(&mutex_lock1,NULL);
pthread_mutex_init(&mutex_lock2,NULL);
pthread_t tid;
pthread_create(&tid,NULL,pthfun,NULL);
while(i++<5)
{
pthread_mutex_lock(&mutex_lock2);
value+=2;
printf("value+=2\n");
pthread_mutex_unlock(&mutex_lock1);
}
pthread_join(tid,&ret);
printf("ret=%d\n",(int)ret);
pthread_mutex_destroy(&mutex_lock1);
pthread_mutex_destroy(&mutex_lock2);
return 0;
}
运行结果:
线程同步 互斥量(mutex) Linux函数相关推荐
- 秒杀多线程第七篇 经典线程同步 互斥量Mutex
阅读本篇之前推荐阅读以下姊妹篇: <秒杀多线程第四篇一个经典的多线程同步问题> <秒杀多线程第五篇经典线程同步关键段CS> <秒杀多线程第六篇经典线程同步事件Event& ...
- 经典线程同步 互斥量Mutex的使用分析
互斥量(mutex)内核对象用来确保一个线程独占对一个资源的访问. 互斥量对象包含一个使用计数.线程ID以及一个递归计数. 互斥量与关键段的行为完全相同.但是,互斥量是内核对象,而关键段是用户模式下的 ...
- c++ linux 线程等待与唤醒_Linux线程同步(互斥量、信号量、条件变量、生产消费者模型)...
为什么要线程同步? 线程间有很多共享资源,都对一个共享数据读写操作,线程操作共享资源的先后顺序不确定,可能会造成数据的冲突 看一个例子 两个线程屏行对全局变量count++ (采用一个val值作为中间 ...
- 判断sem信号量为零_Linux线程同步(互斥量、信号量、条件变量、生产消费者模型)...
为什么要线程同步? 线程间有很多共享资源,都对一个共享数据读写操作,线程操作共享资源的先后顺序不确定,可能会造成数据的冲突 看一个例子 两个线程屏行对全局变量count++ (采用一个val值作为中间 ...
- windows 多线程(五) 互斥量(Mutex)
参考:http://blog.csdn.net/morewindows/article/details/7470936 互斥量也是一个内核对象,它用来确保一个线程独占一个资源的访问.互斥量与关键段的行 ...
- android 线程互斥锁,线程锁(互斥锁Mutex)及递归锁
一.线程锁(互斥锁) 在一个程序内,主进程可以启动很多个线程,这些线程都可以访问主进程的内存空间,在Python中虽然有了GIL,同一时间只有一个线程在运行,可是这些线程的调度都归系统,操作系统有自身 ...
- Linux系统编程----16(线程同步,互斥量 mutex,互斥锁的相关函数,死锁,读写锁)
同步概念 所谓同步,即同时起步,协调一致.不同的对象,对"同步"的理解方式略有不同.如,设备同步,是指在两 个设备之间规定一个共同的时间参考:数据库同步,是指让两个或多个数据库内容 ...
- [一个经典的多线程同步问题]解决方案三:互斥量Mutex
本篇通过互斥量来解决线程的同步,学习其中的一些知识. 互斥量也是一个内核对象,它用来确保一个线程独占一个资源的访问.互斥量与关键段的行为非常相似,并且互斥量可以用于不同进程中的线程互斥访问资源.使用互 ...
- 线程同步(互斥锁、条件、读写锁、信号量)
参考:(四十三)线程--线程同步(互斥锁.读写锁.条件变量.信号量) 作者:FadeFarAway 发布时间:2017-01-17 21:25:28 网址:https://blog.csdn.net/ ...
最新文章
- python ffmpeg pipe_ffmpeg-python通过pipe与librosa进行数据流交互
- JS三大对象中常用方法集锦
- 从JDK源码角度看Long
- Eclipse 的 Tomcat 插件
- linux关闭开发者模式的命今,CentOS防火墙用命令行方式关闭的方式
- signature=18441de5a4bb8df92eb5cf5dcca47d1e,Heroísmo y los medios de comunicación (Capítulo 5A 5B)...
- OCA第1部分中的Java难题
- Python判断一个集合族是否为σ代数
- Servlet基础:容器
- Magick.NET图片处理:解决png转jpg背景色为黑色的问题(设置背景色)
- 计算机为什么启动不起来的,电脑启动不起来怎么办?
- 如何开启Windows远程桌面服务
- JAVA UTC时区时间相互转换
- 相忘于江湖:《监控》
- isFinite()的使用
- 系统部署在服务器,如何把系统部署在云服务器
- 阿里内网最新发布“M8”级Java面试笔记,助力金九银十
- 口语语汇单词篇(10)
- 如何恢复 Linux 分区下误删的文件?
- 用php写的亲亲鲜花网站_PHP最新鲜花礼品商城网站整站源码(自适应手机端) 鲜花商城dedecms模板源码...