为什么本人加了互斥量,输出结果还是没有同步呢。
#include "stdafx.h" #include <windows.h> #include <iostream> using namespace std; #define NAME_LINE 40 //定义线程函数传入参数的结构体 typedef struct __THREAD_DATA { int nMaxNum; char strThreadName[NAME_LINE]; __THREAD_DATA() : nMaxNum(0) { memset(strThreadName, 0, NAME_LINE * sizeof(char)); } }THREAD_DATA; HANDLE g_hMutex = NULL; //互斥量 //线程函数 DWORD WINAPI ThreadProc(LPVOID lpParameter) { THREAD_DATA* pThreadData = (THREAD_DATA*)lpParameter; for (int i = 0; i < pThreadData->nMaxNum; ++ i) { //请求获得一个互斥量锁 WaitForSingleObject(g_hMutex, INFINITE); cout << pThreadData->strThreadName << " -- " << i << endl; Sleep(100); //释放互斥量锁 ReleaseMutex(g_hMutex); return 0L; } } int main() { //创建一个互斥量 g_hMutex = CreateMutex(NULL, FALSE, NULL); //初始化线程数据 THREAD_DATA threadData1, threadData2; threadData1.nMaxNum = 5; strcpy(threadData1.strThreadName, "线程1"); threadData2.nMaxNum = 10; strcpy(threadData2.strThreadName, "线程2"); //创建第一个子线程 HANDLE hThread1 = CreateThread(NULL, 0, ThreadProc, &threadData1, 0, NULL); //创建第二个子线程 HANDLE hThread2 = CreateThread(NULL, 0, ThreadProc, &threadData2, 0, NULL); //关闭线程句柄 CloseHandle(hThread1); CloseHandle(hThread2); //主线程的执行路径 for (int i = 0; i < 5; ++ i) { //请求获得一个互斥量锁 WaitForSingleObject(g_hMutex, INFINITE); cout << "主线程 === " << i << endl; Sleep(100); //释放互斥量锁 ReleaseMutex(g_hMutex); } system("pause"); return
期待输出:
主线程 === 0
线程1 — 0
线程2 — 0
主线程 === 1
线程1 — 1
线程2 — 1
主线程 === 2
线程1 — 2
线程2 — 2
主线程 === 3
线程1 — 3
线程2 — 3
主线程 === 4
线程1 — 4
线程2 — 4
线程2 — 5
线程2 — 6
线程2 — 7
线程2 — 8
线程2 — 9
—
但是结果输出:
发现主线程把线程1,线程2都抢了。他们两个线程后面都没有机会运行了。怎么回事呢。
主线程 == 0
线程2 –0
线程1 –0
主线程 ===1
主线程 ===2
主线程 ===3
主线程 ===4
解决方案
50
跑了一遍。
问题在你的ThreadProc中,return放在for循环里,自然跑了一次就结束线程了;要放在for外面
问题在你的ThreadProc中,return放在for循环里,自然跑了一次就结束线程了;要放在for外面
20
for (int i = 0; i < pThreadData->nMaxNum; ++ i)
{ //请求获得一个互斥量锁
WaitForSingleObject(g_hMutex, INFINITE);
cout << pThreadData->strThreadName << " -- " << i << endl;
Sleep(100); //释放互斥量锁
ReleaseMutex(g_hMutex); return 0L;
}
10
你的程序很容易产生死锁的…………
20
互斥锁通常用于变量在线程间同步,所以接触时间要尽量短,即避免长时间占用互斥锁,特别是sleep,IO