多線程方法:
#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
}
………………………………………………………………………………………………
|