多线程方法:
#include <afxmt.h> // ①=======》多线程头文件
…………………………………………
CMutex mutex; //互斥量对象(全局)
static HANDLE thr1;//②=======》定义线程句柄
static HANDLE thr2;//
…………………………………………………………
UINT ThreadProcWrite(LPVOID param) //void *pi
{
srand(time(NULL)); //③=========>线程1 回调函数
CWnd *wn=(CWnd *)param;
CDC *dc=wn->GetDC();
int xx,yy;
RECT rec;
wn->GetClientRect(&rec);
while(true)
{
CSingleLock singleLock(&mutex);//单线程锁定变量
// singleLock.Lock();
xx=rand()%rec.right;
yy=rand()%rec.bottom;
dc->Ellipse(xx-20,yy-20,xx+20,yy+20);
dc->MoveTo(xx,yy);
dc->LineTo(xx,yy-40);
dc->MoveTo(xx,yy);
dc->LineTo(xx,yy+40);
dc->MoveTo(xx,yy);
dc->LineTo(xx-40,yy);
dc->MoveTo(xx,yy);
dc->LineTo(xx+40,yy);
//Sleep(300); //阻塞线程一定时间
// singleLock.Unlock(); //互斥量解锁
}
wn->ReleaseDC(dc);
return 0;
}
UINT ThreadProcRead(LPVOID param)//=========>线程2 回调函数
{
srand(time(NULL));
CWnd *wn=(CWnd *)param;
CDC *dc=wn->GetDC();
int xx,yy;
RECT rec;
wn->GetClientRect(&rec);
while(true)
{
CSingleLock singleLock(&mutex);
// singleLock.Lock();
xx=rand()%rec.right;
yy=rand()%rec.bottom;
dc->Rectangle(xx-20,yy-20,xx+20,yy+20);
dc->MoveTo(xx-20,yy-20);
dc->LineTo(xx+20,yy+20);
dc->MoveTo(xx-20,yy+20);
dc->LineTo(xx+20,yy-20);
//Sleep(300); //阻塞线程一定时间
//singleLock.Unlock(); //互斥量解锁
}
wn->ReleaseDC(dc);
return 0;
}
………………………………………………………………
void Ca002View::OnThread1()//④==========>开启线程1
{
// TODO: 在此添加命令处理程序代码
CWinThread* pThread;//MFC
pThread = AfxBeginThread(ThreadProcWrite, this,THREAD_PRIORITY_LOWEST,0,CREATE_SUSPENDED);//开始写线程
thr1 = pThread->m_hThread;//获取线程1句柄,用于结束该线程
//SetThreadPriority(g_WriteHnd,THREAD_PRIORITY_LOWEST);
pThread->ResumeThread();
}
void Ca002View::OnThread2()//④========>开启线程2
{
// TODO: 在此添加命令处理程序代码
CWinThread* pThread;
pThread = AfxBeginThread(ThreadProcRead, this);
thr2 = pThread->m_hThread;//获取线程2句柄,用于结束该线程
}
void Ca002View::OnEnd1()// ⑤END========》结束线程1
{
// TODO: 在此添加命令处理程序代码
TerminateThread(thr1, 0);//结束线程1
}
void Ca002View::OnEnd2()// ⑤END========》结束线程2
{
// TODO: 在此添加命令处理程序代码
TerminateThread(thr2, 0);//结束线程2
}
………………………………………………………………………………………………
|