2013-12-13 233 views
0

我试图通过使用互斥锁来保护一段代码。由于代码崩溃,我创建了一个简单的测试代码,在其下面执行相同的操作。崩溃不一定每次都在同一行代码中,但始终围绕“WaitForSingleObject”或“Sleep”调用。WaitForSingleObject崩溃

任何援助将不胜感激。

#include <thread> 
#include <windows.h> 
#include <process.h> 

static HANDLE myMutex; 

//The function we want to make the thread run. 
void task1() 
{ 

    WaitForSingleObject(myMutex, INFINITE); 

    for (int i = 0; i < 20; i++) 
    { 
     Sleep(500); 
    } 

    ReleaseMutex(myMutex); 
} 

void task2() 
{ 

    Sleep(10); 
    WaitForSingleObject(myMutex, INFINITE); 

    for (int i = 0; i < 20; i++) 
    { 
     Sleep(10); 
    } 

    ReleaseMutex(myMutex); 
} 

int main(int argc, char **argv) 
{ 

    myMutex = CreateMutex(0, FALSE, 0); 

    std::thread t1(task1); 

    std::thread t2(task2); 
} 

回答

4

的问题是,你不等待线程您main方法退出之前退出。 thread对象上的析构函数正在被调用而没有线程退出。您需要拨打join才能让您的主要方法等待。尝试:

int main(int argc, char **argv) 
{ 

    myMutex = CreateMutex(0, FALSE, 0); 

    std::thread t1(task1); 

    std::thread t2(task2); 
    if(t1.joinable()) 
     t1.join(); 

    if(t2.joinable()) 
     t2.join(); 

} 

根据std::thread destructor文档:

销毁线程对象。如果*仍然有一个关联的运行线程(即joinable()== true),则调用std :: terminate()。