我有一个DLL,其中有一个基于CWinThread的类,称为CWork。我使用AfxBeginThread创建它。
在这个类中,我定义了一个过程,它将无限循环并执行某个任务。这个过程将自己作为一个线程使用。我也使用AfxBeginThread创建它。现在,当我的DLL退出时,我想结束线程。这是因为我在退出时崩溃了,我想这就是原因。
此外,还有
伪代码示例:
类CmainCmain::Cmain(){
pMyThread = AfxBeginThread(CWork - a CWinThread based Class);
}
UINT HandleNextVTSConnectionCommandProc(LPVOID pParam);
class CWork
CWork:CWork(){
AfxBeginThread(HandleNextVTSConnectionCommandProc, this);
}
UINT HandleNextVTSConnectionCommandProc(LPVOID pParam){
while(true){
dosomething();
sleep(2000);
}
}
我的问题是,结束这两个线程的正确方法是什么?
谢谢!
一般来说,结束线程的正确方法是要求它完成,然后等待它完成。因此,在Windows上,你可能会发出一个事件信号,要求线程完成,然后等待线程HANDLE。强制终止一个线程几乎总是一个错误的想法,它会回来困扰你。
创建一个调用CreateEvent的事件,该事件最初是无信号的。当你的应用程序终止时,通知这个事件(SetEvent)并等待线程终止(线程句柄上的WaitForSingleObject)。
在你的线程函数HandleNextVTSConnectionCommandProc
中,用
while(true)
循环while(WaitForSingleObject(hEvent, 0) != WAIT_OBJECT_0)
执行上述操作允许您从应用程序中通知线程终止。当线程从线程进程返回时,线程终止。
设置一个标志,而不是使用while(true)来告诉线程何时应该结束。你也可以使用事件。
你还应该在退出之前等待线程完成,所以你应该使用(在主代码中,一旦你发出线程结束的信号):
WaitForSingleObject(thread_handle)
像这样的东西应该让你开始:
HANDLE g_hThreadExitRequest = NULL;
UINT __cdecl ThreadFunction(LPVOID pParam)
{
AllocConsole();
HANDLE hCon = GetStdHandle(STD_OUTPUT_HANDLE);
for (int i=1; true; ++i)
{
CStringA count;
count.Format("%dn", i);
WriteFile(hCon, (LPCSTR)count, count.GetLength(), NULL, NULL);
if (WaitForSingleObject(g_hThreadExitRequest, 1000) == WAIT_OBJECT_0)
break;
}
// We can do any thread specific cleanup here.
FreeConsole();
return 0;
}
void Go()
{
// Create the event we use the request the thread exit.
g_hThreadExitRequest = CreateEvent(
NULL, // LPSECURITY_ATTRIBUTES lpEventAttributes
TRUE, // BOOL bManualReset
FALSE, // BOOL bInitialState
NULL // LPCTSTR lpName
);
// We create the thread suspended so we can mess with the returned CWinThread without
// MFC auto deleting it when the thread finishes.
CWinThread *pThread = AfxBeginThread(
&ThreadFunction, // AFX_THREADPROC pfnThreadProc
NULL, // LPVOID pParam
THREAD_PRIORITY_NORMAL, // int nPriority
0, // UINT nStackSize
CREATE_SUSPENDED , // DWORD dwCreateFlags
NULL // LPSECURITY_ATTRIBUTES lpSecurityAttrs
);
// Turn off MFC's auto delete "feature".
pThread->m_bAutoDelete = FALSE;
// Start the thread running.
pThread->ResumeThread();
// Wait 30 seconds.
Sleep(30*1000);
// Signal the thread to exit and wait for it to do so.
SetEvent(g_hThreadExitRequest);
WaitForSingleObject(pThread->m_hThread, INFINITE);
// Delete the CWinTread object since we turned off auto delete.
delete pThread;
// We're finished with the event.
CloseHandle(g_hThreadExitRequest);
g_hThreadExitRequest = NULL;
}