windows C++ 用信号量控制线程
2011-10-24 15:57
621 查看
windows C++ 用信号量控制线程
2010-08-11 09:09
很好的控制线程,让线程互斥,互相协调工作,共享数据,这个问题有很多种解决办法,不过我个人觉得使用信号量控制线程特别方便。会想到用多线程控制程序,是由于上学期我们要做一个控制电机转速的课程设计,开始编写的程序都是一个线程控制的。后来课程设计结束了,一次在看多线程的演示程序的时候突然想到,原来的那个电机控制程序完全可以写成多线程,可是由于课程设计结束了,没有硬件供你调试,就自己写了个多线程的练习程序。
控制信号量几个主要的函数:
Cpp代码
WaitForSingleObject();//等待信号量有效
CreatSemaphore();//申请信号量
OpenSemaphore();//打开信号量
ReleaseSemaphore();//释放信号量
下面来看看控制多线程要用到的东西:
Cpp代码
HANDLE ptrSpdUpDown;
HANDLE ptrUpDownDraw;
HANDLE ptrDrawSpd;
//申请指向信号量的句柄
ptrSpdUpDown = ::CreateSemaphore(NULL, 0, 1, NULL);
ptrUpDownDraw = ::CreateSemaphore(NULL, 0, 1, NULL);
ptrDrawSpd = ::CreateSemaphore(NULL, 1, 1, NULL);//实例化三个信号量
bOnOff=true;//线程状态控制量 开启三个线程
m_tWriteSpeed=AfxBeginThread(WriteSpeed,
&m_sWriteSpeed,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tWriteSpeed->ResumeThread();
m_tWriteUpDown=AfxBeginThread(WriteUpDown,
&m_sWriteUpDown,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tWriteUpDown->ResumeThread();
m_tDrawWindow=AfxBeginThread(DrawWindow,
&m_sDrawWindow,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tDrawWindow->ResumeThread();
//三个线程函数
UINT WriteSpeed(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrDrawSpd,INFINITE);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iSpeed=iUp+iDown+rand();
ReleaseSemaphore(ptrSpdUpDown,1,NULL);
sTr.Format("%d",iNo);
sMe.Format("%d",iSpeed);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe);
iNo++;
}
return 0;
}
UINT WriteUpDown(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrSpdUpDown,INFINITE);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iUp=iSpeed-rand();
iDown=iSpeed+rand();
ReleaseSemaphore(ptrUpDownDraw,1,NULL);
sTr.Format("%d",iNo);
sMe.Format("%d",iUp);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe);
iNo++;
}
return 0;
}
UINT DrawWindow(LPVOID p)
{
int iNo=1;
CString sTr;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrUpDownDraw,INFINITE);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr+"已经接到信号");
::Sleep(1000);
sTr.Format("%d",iNo);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr);
iNo++;
ReleaseSemaphore(ptrDrawSpd,1,NULL);
}
return 0;
}
上面的方法是先申请信号量的句柄然后再实例化信号量 下面这种方法是直接申请信号量 两种方法基本相同
Cpp代码
CSemaphore ptrSpdUpDown(0, 1);
CSemaphore ptrUpDownDraw(0, 1);
CSemaphore ptrDrawSpd(1, 1);//#include <atlsync.h>注意在stdafx.h手动包含这个文件
在各个线程函数中不用WaitForSingleObject了要使用Lock()UnLock();
下面是使用CSemaphore后在各个线程函数中使用Lock()UnLock()替换掉WaitForSingleObject的结果
Cpp代码
UINT WriteSpeed(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrDrawSpd.Lock();</STRONG>
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iSpeed=iUp+iDown+rand();
ReleaseSemaphore(ptrSpdUpDown,1,NULL);
<STRONG>ptrSpdUpDown.Unlock();</STRONG>
sTr.Format("%d",iNo);
sMe.Format("%d",iSpeed);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe);
iNo++;
}
return 0;
}
UINT WriteUpDown(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrSpdUpDown.Lock();</STRONG>
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iUp=iSpeed-rand();
iDown=iSpeed+rand();
ReleaseSemaphore(ptrUpDownDraw,1,NULL);
<STRONG>ptrUpDownDraw.Unlock();</STRONG>
sTr.Format("%d",iNo);
sMe.Format("%d",iUp);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe);
iNo++;
}
return 0;
}
UINT DrawWindow(LPVOID p)
{
int iNo=1;
CString sTr;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrUpDownDraw.Lock();</STRONG>
ptr->SetWindowText("线程DrawWindow正在运行"+sTr+"已经接到信号");
::Sleep(1000);
sTr.Format("%d",iNo);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr);
iNo++;
ReleaseSemaphore(ptrDrawSpd,1,NULL);
<STRONG>ptrDrawSpd.Unlock();</STRONG>
}
return 0;
}
推荐使用第一种方法,第一种方法只声明了句柄,当信号量实例化的时候句柄才指向三个信号量。所以更加支持多态。
2010-08-11 09:09
很好的控制线程,让线程互斥,互相协调工作,共享数据,这个问题有很多种解决办法,不过我个人觉得使用信号量控制线程特别方便。会想到用多线程控制程序,是由于上学期我们要做一个控制电机转速的课程设计,开始编写的程序都是一个线程控制的。后来课程设计结束了,一次在看多线程的演示程序的时候突然想到,原来的那个电机控制程序完全可以写成多线程,可是由于课程设计结束了,没有硬件供你调试,就自己写了个多线程的练习程序。
控制信号量几个主要的函数:
Cpp代码
WaitForSingleObject();//等待信号量有效
CreatSemaphore();//申请信号量
OpenSemaphore();//打开信号量
ReleaseSemaphore();//释放信号量
下面来看看控制多线程要用到的东西:
Cpp代码
HANDLE ptrSpdUpDown;
HANDLE ptrUpDownDraw;
HANDLE ptrDrawSpd;
//申请指向信号量的句柄
ptrSpdUpDown = ::CreateSemaphore(NULL, 0, 1, NULL);
ptrUpDownDraw = ::CreateSemaphore(NULL, 0, 1, NULL);
ptrDrawSpd = ::CreateSemaphore(NULL, 1, 1, NULL);//实例化三个信号量
bOnOff=true;//线程状态控制量 开启三个线程
m_tWriteSpeed=AfxBeginThread(WriteSpeed,
&m_sWriteSpeed,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tWriteSpeed->ResumeThread();
m_tWriteUpDown=AfxBeginThread(WriteUpDown,
&m_sWriteUpDown,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tWriteUpDown->ResumeThread();
m_tDrawWindow=AfxBeginThread(DrawWindow,
&m_sDrawWindow,
THREAD_PRIORITY_NORMAL,
0,
CREATE_SUSPENDED);
m_tDrawWindow->ResumeThread();
//三个线程函数
UINT WriteSpeed(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrDrawSpd,INFINITE);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iSpeed=iUp+iDown+rand();
ReleaseSemaphore(ptrSpdUpDown,1,NULL);
sTr.Format("%d",iNo);
sMe.Format("%d",iSpeed);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe);
iNo++;
}
return 0;
}
UINT WriteUpDown(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrSpdUpDown,INFINITE);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iUp=iSpeed-rand();
iDown=iSpeed+rand();
ReleaseSemaphore(ptrUpDownDraw,1,NULL);
sTr.Format("%d",iNo);
sMe.Format("%d",iUp);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe);
iNo++;
}
return 0;
}
UINT DrawWindow(LPVOID p)
{
int iNo=1;
CString sTr;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
WaitForSingleObject(ptrUpDownDraw,INFINITE);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr+"已经接到信号");
::Sleep(1000);
sTr.Format("%d",iNo);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr);
iNo++;
ReleaseSemaphore(ptrDrawSpd,1,NULL);
}
return 0;
}
上面的方法是先申请信号量的句柄然后再实例化信号量 下面这种方法是直接申请信号量 两种方法基本相同
Cpp代码
CSemaphore ptrSpdUpDown(0, 1);
CSemaphore ptrUpDownDraw(0, 1);
CSemaphore ptrDrawSpd(1, 1);//#include <atlsync.h>注意在stdafx.h手动包含这个文件
在各个线程函数中不用WaitForSingleObject了要使用Lock()UnLock();
下面是使用CSemaphore后在各个线程函数中使用Lock()UnLock()替换掉WaitForSingleObject的结果
Cpp代码
UINT WriteSpeed(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrDrawSpd.Lock();</STRONG>
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iSpeed=iUp+iDown+rand();
ReleaseSemaphore(ptrSpdUpDown,1,NULL);
<STRONG>ptrSpdUpDown.Unlock();</STRONG>
sTr.Format("%d",iNo);
sMe.Format("%d",iSpeed);
ptr->SetWindowText("线程WriteSpeed正在运行"+sTr+"---Speed:"+sMe);
iNo++;
}
return 0;
}
UINT WriteUpDown(LPVOID p)
{
int iNo=1;
CString sTr;
CString sMe;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrSpdUpDown.Lock();</STRONG>
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe+"已经接到信号");
::Sleep(1000);
srand((int)time(0));//种种子数
iUp=iSpeed-rand();
iDown=iSpeed+rand();
ReleaseSemaphore(ptrUpDownDraw,1,NULL);
<STRONG>ptrUpDownDraw.Unlock();</STRONG>
sTr.Format("%d",iNo);
sMe.Format("%d",iUp);
ptr->SetWindowText("线程WriteUpDown正在运行"+sTr+"---Up:"+sMe);
iNo++;
}
return 0;
}
UINT DrawWindow(LPVOID p)
{
int iNo=1;
CString sTr;
CEdit *ptr=(CEdit *)p;
while(bOnOff)
{
<STRONG>ptrUpDownDraw.Lock();</STRONG>
ptr->SetWindowText("线程DrawWindow正在运行"+sTr+"已经接到信号");
::Sleep(1000);
sTr.Format("%d",iNo);
ptr->SetWindowText("线程DrawWindow正在运行"+sTr);
iNo++;
ReleaseSemaphore(ptrDrawSpd,1,NULL);
<STRONG>ptrDrawSpd.Unlock();</STRONG>
}
return 0;
}
推荐使用第一种方法,第一种方法只声明了句柄,当信号量实例化的时候句柄才指向三个信号量。所以更加支持多态。
相关文章推荐
- windows C++ 用信号量控制线程
- windows c++ 使用锁来控制线程访问
- 线程的同步控制---信号量、互斥锁、条件变量
- 一个Windows C++的线程类实现
- SEM 信号量线程控制
- C++ windows多线程 线程描述了进程内代码的执行路径。进程中同时可以有多个线程在执行,为了使他们能够同时运行,操作系统为每个线程轮流分配CPU时间片,为了充分地利用CPU提高软件产品的性能,一
- Windows Via C/C++:线程实现细节
- Windows via C/C++:线程调度——概述
- 【Windows】线程漫谈——线程同步之信号量和互斥量
- 一个Windows C++的线程类实现
- linux多线程学习(五)——信号量线程控制
- 用C++封装Win32信号量,同步线程
- C++windows内核编程笔记day13 进程、线程与信号量
- c#中跨线程调用windows窗体控件 .我们在做winform应用的时候,大部分情况下都会碰到使用多线程控制界面上控件信息的问题。然而我们并不能用传统方法来做这个问题,下面我将详细的介绍。
- Windows via C/C++ 学习(15)线程调度、线程优先级和亲缘性
- Windows中线程的基础知识和简单应用----信号量(Semaphore)
- c++的进程和线程【windows】
- Windows Via C/C++:线程的睡眠和切换
- windows C++ 获得一个进程的线程数目
- 《Windows via C/C++》学习笔记 —— 线程的执行时间