首页
Web开发
Windows程序
编程语言
数据库
移动开发
系统相关
微信
其他好文
会员
首页
>
编程语言
> 详细
线程同步
时间:
2015-08-08 16:39:52
阅读:
124
评论:
0
收藏:
0
[点我收藏+]
标签:
线程
线程同步:
一:互斥同步
1.原子访问是windows只有的线程同步
InterlockedExchange 改变值
InterlockedIncrement ++
InterlockedDecrement --
InterlockedExchangeAdd +=
实现旋转锁:锁一段代码
void CThreadOurDlg::OnBnClickedButton1()
{
AfxBeginThread(&CThreadOurDlg::ThreadA,this);
AfxBeginThread(&CThreadOurDlg::ThreadB,this);
}
long int g_x=0;
BOOL flag=FALSE;
long int a=100;
long int b=200;
UINT _cdecl CThreadOurDlg::ThreadA(LPVOID lpvoid)
{
while(InterlockedExchange((LONG*)&flag,TRUE)==TRUE)
Sleep(0);
a=a+b;
TRACE("--------------------------------\n");
TRACE("%d\n",a);
TRACE("--------------------------------\n");
InterlockedExchange((LONG*)&flag,FALSE);
return 0;
}
UINT _cdecl CThreadOurDlg::ThreadB(LPVOID lpvoid)
{
while(InterlockedExchange((LONG*)&flag,TRUE)==TRUE)
Sleep(0);
a=a+b;
TRACE("++++++++++++++++++++++++++++++++\n");
TRACE("%d\n",a);
TRACE("++++++++++++++++++++++++++++++++\n");
InterlockedExchange((LONG*)&flag,FALSE);
return 0;
}
旋转锁实现卖票:
long nTicket = 1000;
BOOL nFlag=FALSE;
UINT _cdecl CThreadOurDlg::ThreadFun(LPVOID lpvoid)
{
int i=(int)lpvoid;
while(1)
{
if(nTicket<=0)
{
break;
}
if(nTicket>0)
{
//------------------------------------------------------------枷锁----------------------------------------
while(InterlockedExchange((LONG*)&nFlag,TRUE)==TRUE)
Sleep(0);
CString str;
str.Format(_T("第%d窗口卖出第%d张票"),i,nTicket);
TRACE("第%d窗口卖出第%d张票\n",i,nTicket);
InterlockedDecrement(&nTicket);
//---------------------------------------------------------解锁----------------------------------------------
InterlockedExchange((LONG*)&nFlag,FALSE);
}
Sleep(20);
}
TRACE("第%d窗口没有票了\n",i);
return 0;
}
void CThreadOurDlg::OnBnClickedButton2()
{
//创建10个工作者线程
for(int i=0;i<10;i++)
{
AfxBeginThread(&CThreadOurDlg::ThreadFun,(LPVOID)i);
}
}
2.临界区
2.1 Windows的函数
CRITICAL_SECTION cs;
::InitializeCriticalSection(&cs);初始化临界区
::InitializeCriticalSectionAndSpinCount(&cs,4000);包含旋转锁
::DeleteCriticalSection(&cs);销毁
::TryEnterCriticalSection尝试进入临界区
::EnterCriticalSection(&((CThreadOurDlg*)AfxGetApp()->m_pMainWnd)->cs);进入
::LeaveCriticalSection(&((CThreadOurDlg*)AfxGetApp()->m_pMainWnd)->cs);退出
2.2 MFC的函数
CCriticalSection o_cs;
o_cs.Lock();
o_cs.Unlock();
3.互斥量 内核模式 有系统管理
3.1 MFC的类
void CThreadOurDlg::OnBnClickedButton2()
{
//创建10个工作者线程
for(int i=0;i<10;i++)
{
AfxBeginThread(&CThreadOurDlg::ThreadFun,(LPVOID)i);
}
//释放互斥量
::ReleaseMutex(mx.m_hObject);
}
UINT _cdecl CThreadOurDlg::ThreadFun(LPVOID lpvoid)
{
int i=(int)lpvoid;
while(1)
{
if(nTicket<=0)
{
break;
}
//----------------------------------等待互斥量信号------------------------------------
::WaitForSingleObject(((CThreadOurDlg*)AfxGetApp()->m_pMainWnd)->mx.m_hObject,INFINITE);
if(nTicket>0)
{
CString str;
str.Format(_T("第%d窗口卖出第%d张票"),i,nTicket);
TRACE("第%d窗口卖出第%d张票\n",i,nTicket);
((CThreadOurDlg*)AfxGetApp()->m_pMainWnd)->m_listBox.AddString(str);
InterlockedDecrement(&nTicket);
}
//释放互斥量
::ReleaseMutex(((CThreadOurDlg*)AfxGetApp()->m_pMainWnd)->mx.m_hObject);
Sleep(20);
}
TRACE("第%d窗口没有票了\n",i);
return 0;
}
3.2 HANDLE m_hMutex ;
//创建一个互斥量
m_hMutex=CreateMutex(NULL,FALSE,NULL);
CloseHandle(m_hMutex);
m_hMutex=NULL;
版权声明:本文为博主原创文章,未经博主允许不得转载。
线程同步
标签:
线程
原文地址:http://blog.csdn.net/ingnight/article/details/47358319
踩
(
0
)
赞
(
0
)
举报
评论
一句话评论(
0
)
登录后才能评论!
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
更多
Spring Cloud 从入门到精通(一)Nacos 服务中心初探
2021-07-29
基础的排序算法
2021-07-29
SpringBoot|常用配置介绍
2021-07-29
关于 .NET 与 JAVA 在 JIT 编译上的一些差异
2021-07-29
C语言常用函数-toupper()将字符转换为大写英文字母函数
2021-07-29
《手把手教你》系列技巧篇(十)-java+ selenium自动化测试-元素定位大法之By class name(详细教程)
2021-07-28
4-1 YAML配置文件 注入 JavaBean中
2021-07-28
【python】 用来将对象持久化的 pickle 模块
2021-07-28
马拉车算法
2021-07-28
用Python进行冒泡排序
2021-07-28
友情链接
兰亭集智
国之画
百度统计
站长统计
阿里云
chrome插件
新版天听网
关于我们
-
联系我们
-
留言反馈
© 2014
mamicode.com
版权所有 联系我们:gaon5@hotmail.com
迷上了代码!