一个简单例子了解使用互斥量线程同步

 在刚开始学习学习线程同步时总是认为两个线程或是多个线程共同运行,但是那样是做的。

同步就是协同步调,按预定的先后次序进行运行。如:你说完,我再说。 “同”字从字面上容易理解为一起动作。 其实不是,“同”字应是指协同、协助、互相配合。 如进程、线程同步,可理解为进程或线程A和B一块配合,A执行到一定程度时要依靠B的某个结果,于是停下来,示意B运行;B依言执行,再将结果给A;A再继续操作。 所谓同步,就是在发出一个功能调用时,在没有得到结果之前,该调用就不返回,同时其它线程也不能调用这个方法。

接下来用一个简单的例子演示通过互斥量进行的线程的同步,演示的思想为一个线程对数据操作,另一个数据输出结果。

代码如下:

#include <stdio.h>

#include <stdlib.h>

#include <unistd.h>

#include <pthread.h>

#include <errno.h>

pthread_mutex_t mutex = PTHREAD_MUTEX_INITIALIZER;//定义互斥变量并初始化

int lock_var;

time_t end_time;

void pthread1(void *arg);

void pthread2(void *arg);

int main(int argc, char *argv[])

{

pthread_t id1,id2;

pthread_t mon_th_id;

int ret;

end_time = time(NULL)+10;

/*互斥锁初始化*/

pthread_mutex_init(&mutex,NULL);

/*创建两个线程*/

ret=pthread_create(&id1,NULL,(void *)pthread1, NULL);

if(ret!=0)

perror("pthread cread1");

ret=pthread_create(&id2,NULL,(void *)pthread2, NULL);

if(ret!=0)

perror("pthread cread2");

pthread_join(id1,NULL);

pthread_join(id2,NULL);

exit(0);

}

void pthread1(void *arg)

{

int i;

while(time(NULL) < end_time)

{ /*互斥锁上锁*/

if(pthread_mutex_lock(&mutex)!=0)

{

perror("pthread_mutex_lock");

}

else

printf("pthread1:pthread1 lock the variable\n");

for(i=0;i<2;i++)

{

sleep(1);

lock_var++;

}

/*互斥锁接锁*/

if(pthread_mutex_unlock(&mutex)!=0)

{

perror("pthread_mutex_unlock");

}

else

printf("pthread1:pthread1 unlock the variable\n");

sleep(1);

}

}

void pthread2(void *arg)

{

int nolock=0;

int ret;

while(time(NULL) < end_time)

{ /*测试互斥锁*/

ret=pthread_mutex_trylock(&mutex);

if(ret==EBUSY)

printf("pthread2:the variable is locked by pthread1\n");

else

{

if(ret!=0)

{

perror("pthread_mutex_trylock");

exit(1);

}

else

printf("pthread2:pthread2 got lock.The variable is %d\n",lock_var); /*互斥锁接锁*/

if(pthread_mutex_unlock(&mutex)!=0)

{

perror("pthread_mutex_unlock");

}

else

printf("pthread2:pthread2 unlock the variable\n");

}

sleep(3);

printf("++++++++++++++++++++++\n");

}

}

时间: 2025-01-06 16:27:38

一个简单例子了解使用互斥量线程同步的相关文章

【Linux】Mutex互斥量线程同步的例子

0.互斥量  Windows下的互斥量 是个内核对象,每次WaitForSingleObject和ReleaseMutex时都会检查当前线程ID和占有互斥量的线程ID是否一致. 当多次Wait**时就要对应多次ReleaseMutex, 当ReleaseMutex过多次数时如果发现当前占有互斥量的线程ID和当前调用ReleaseMutex的线程ID不一致时仅仅返回FLASE,GetLastError返回ERROR_NOT_OWNER,没有其他副作用. 当占有mutex的线程在Release之前退

C语言多线程的一个简单例子

多线程的一个简单例子: #include <stdio.h> #include <stdlib.h> #include <string.h> #include <unistd.h> #include <pthread.h> void * print_a(void *); void * print_b(void *); int main(){ pthread_t t0; pthread_t t1; // 创建线程A if(pthread_creat

从一个简单例子来理解js引用类型指针的工作方式

? 1 2 3 4 5 6 7 <script> var a = {n:1};  var b = a;   a.x = a = {n:2};  console.log(a.x);// --> undefined  console.log(b.x);// --> [object Object]  </script> 上面的例子看似简单,但结果并不好了解,很容易把人们给想绕了--"a.x不是指向对象a了么?为啥log(a.x)是undefined?".&

生产者与消费者的一个简单例子

生产者 #include<fstream> #include<iostream> #include<Windows.h> using namespace std; int main(void) { ofstream out; const char ch = '*'; long long k = 0; DWORD64 time = GetTickCount64(); while (true) { if (GetTickCount64() - time > 5000)

学习pthreads,使用互斥量进行同步

在进行多线程编程时,我们总会遇到全局变量和数据结构的问题,这是多线程之间进行通信的问题.如果多个线程同时读写一个全局变量,那么会造成竞争或者出错.为了解决这一问题,我们需要对全局数据进行,使用互斥量实现锁的机制,当某个线程在某个操作前进行了加锁,那么某个操作只能在这个线程进行,直至将锁去除,相当于在这里将多线程的并行变成了串行.本文重点学习如何使用互斥量进行全局数据的同步,分为三个部分,第一部分给出代码示例,第二部分对代码进行讲解,第三部分给出运行结果. 一.代码示例 该程序使用4个线程实现两个

PyQt安装与一个简单例子

PyQt在Windows+Visual Studio下安装所需文件如下: python-2.7.3.msi (www.python.org/download) sip-4.14.2.zip (www.riverbankcomputing.co.uk/software/sip/download) PyQt-Py2.7-x86-gpl-4.9.6-1.exe(www.riverbankcomputing.co.uk/software/pyqt/download) 安装方法: 首先安装python2.

词法分析程序 LEX和VC6整合使用的一个简单例子

词法分析的理论知识不少,包括了正规式.正规文法.它们之间的转换以及确定的有穷自动机和不确定的有穷自动机等等... 要自己写一个词法分析器也不会很难,只要给出了最简的有穷自动机,就能很方便实现了,用if.switch-case来写一通所谓的状态转换就可以,我近期会写一个简单的词法分析程序来作为例子... 现在已经有人发明了一个叫LEX的工具让你去应用,那我们就省了不少力气,毕竟没到万不得已的时候,我们都没必要重新发明轮子,从另一个角度来说,使用工具是我们人类知识继承的一种方法,也是我们比其他动物优

netsh interface portproxy的一个简单例子

netsh interface portproxy的微软帮助文档地址: https://technet.microsoft.com/zh-cn/library/cc776297(WS.10).aspx#BKMK_1 下面是一个简单的例子: //显示所有 portproxy 参数,包括 v4tov4.v4tov6.v6tov4 和 v6tov6 的端口/地址对. C:\>netsh interface portproxy show all //因为没有配置过它,所以没有东西可以显示. //添加配置

Spring MVC:使用SimpleUrlHandlerMapping的一个简单例子

实现一个控制器ShirdrnController,如下所示: package org.shirdrn.spring.mvc; import java.util.Date; import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse; import org.apache.commons.logging.Log;import org.apache.commons.logging.