互斥对象 可以避免脏读
2015-06-25 09:53
357 查看
#include "stdafx.h"
#include <Windows.h>
#include <iostream>
#include <conio.h>
using namespace std;
DWORD WINAPI m_fun1(LPVOID lpParameter);
DWORD WINAPI m_fun2(LPVOID lpParameter);
int tickets=30;
HANDLE hMutex;
int _tmain(int argc, _TCHAR* argv[])
{
HANDLE hthread1;
HANDLE hthread2;
::hMutex=::CreateMutexA(NULL,FALSE,NULL);
//创建互斥对象
//如果参数为 TRUE 此互斥对象将被main线程所拥有
//创建线程
hthread1=::CreateThread(NULL,0,::m_fun1,NULL,0,NULL);
hthread2=::CreateThread(NULL,0,::m_fun2,NULL,0,NULL);
::CloseHandle(hthread1);
::CloseHandle(hthread2);
::Sleep(4000);
_getch();
return 0;
}
DWORD WINAPI m_fun1(LPVOID lpParameter)
{
while(1)
{
::WaitForSingleObject(::hMutex,INFINITE);
//请求互斥对象的所有权
//互斥对象可以被线程同时多次拥有 对应则需要多次释放
::Sleep(100);
if(tickets>0)
{
::Sleep(1);
cout<<"线程1出票"<<tickets--<<endl;
}
else
{
break;
}
::ReleaseMutex(::hMutex);
//释放互斥对象的所有权
//谁拥有了互斥对象 谁才有权释放
}
return 0;
//一旦线程结束,系统将自动释放其互斥对象的拥有权
}
DWORD WINAPI m_fun2(LPVOID lpParameter)
{
while(1)
{
::WaitForSingleObject(::hMutex,INFINITE);
::Sleep(50);
if(tickets>0)
{
::Sleep(1);
cout<<"线程2出票"<<tickets--<<endl;
}
else
{
break;
}
::ReleaseMutex(::hMutex);
}
return 0;
}
#include <Windows.h>
#include <iostream>
#include <conio.h>
using namespace std;
DWORD WINAPI m_fun1(LPVOID lpParameter);
DWORD WINAPI m_fun2(LPVOID lpParameter);
int tickets=30;
HANDLE hMutex;
int _tmain(int argc, _TCHAR* argv[])
{
HANDLE hthread1;
HANDLE hthread2;
::hMutex=::CreateMutexA(NULL,FALSE,NULL);
//创建互斥对象
//如果参数为 TRUE 此互斥对象将被main线程所拥有
//创建线程
hthread1=::CreateThread(NULL,0,::m_fun1,NULL,0,NULL);
hthread2=::CreateThread(NULL,0,::m_fun2,NULL,0,NULL);
::CloseHandle(hthread1);
::CloseHandle(hthread2);
::Sleep(4000);
_getch();
return 0;
}
DWORD WINAPI m_fun1(LPVOID lpParameter)
{
while(1)
{
::WaitForSingleObject(::hMutex,INFINITE);
//请求互斥对象的所有权
//互斥对象可以被线程同时多次拥有 对应则需要多次释放
::Sleep(100);
if(tickets>0)
{
::Sleep(1);
cout<<"线程1出票"<<tickets--<<endl;
}
else
{
break;
}
::ReleaseMutex(::hMutex);
//释放互斥对象的所有权
//谁拥有了互斥对象 谁才有权释放
}
return 0;
//一旦线程结束,系统将自动释放其互斥对象的拥有权
}
DWORD WINAPI m_fun2(LPVOID lpParameter)
{
while(1)
{
::WaitForSingleObject(::hMutex,INFINITE);
::Sleep(50);
if(tickets>0)
{
::Sleep(1);
cout<<"线程2出票"<<tickets--<<endl;
}
else
{
break;
}
::ReleaseMutex(::hMutex);
}
return 0;
}
相关文章推荐
- 实现计算机重启
- 变换符号
- JavaSE_集合_LinkedList、ArrayList类
- MySQL中修改表结构时需要注意的一些地方
- 写一个随机洗牌函数——概率题
- LeetCode Next Permutation
- Qt QScrollBar qss 美化样例
- Xshell常用命令备忘
- jquery分页组件(每页显示多少条)
- gulp入门~
- CXF和Spring整合
- qt 获取 xml
- 网络联调
- js如何实现继承
- Java实现ftp上传文件、文件夹
- django+uwsgi报错libgcc_s.so.1 must be installed for pthread_cancel to work
- JVM GC日志和内存DUMP参数配置
- springmvc中以一个页面作为响应返回给ajax
- DateFormat
- Dijkstra(优先队列)