多線程面試題系列(15):關鍵段,事件,互斥量,信號量的“遺棄”問題
一.什麽是“遺棄”問題
在第七篇講到了互斥量能處理“遺棄”問題,下面引用原文:
互斥量常用於多進程之間的線程互斥,所以它比關鍵段還多一個很有用的特性——“遺棄”情況的處理。比如有一個占用互斥量的線程在調用ReleaseMutex()觸發互斥量前就意外終止了(相當於該互斥量被“遺棄”了),那麽所有等待這個互斥量的線程是否會由於該互斥量無法被觸發而陷入一個無窮的等待過程中了?這顯然不合理。因為占用某個互斥量的線程既然終止了那足以證明它不再使用被該互斥量保護的資源,所以這些資源完全並且應當被其它線程來使用。因此在這種“遺棄”情況下,系統自動把該互斥量內部的線程ID設置為0,並將它的遞歸計數器復置為0,表示這個互斥量被觸發了。然後系統將“公平地”選定一個等待線程來完成調度(被選中的線程的WaitForSingleObject()會返回WAIT_ABANDONED_0)。
可見“遺棄”問題就是——占有某種資源的進程意外終止後,其它等待該資源的進程能否感知。
二.關鍵段的“遺棄”問題
關鍵段在這個問題上很簡單——由於關鍵段不能跨進程使用,所以關鍵段不需要處理“遺棄”問題。
三.事件,互斥量,信號量的“遺棄”問題
事件,互斥量,信號量都是內核對象,可以跨進程使用。一個進程在創建一個命名的事件後,其它進程可以調用OpenEvent()並傳入事件的名稱來獲得這個事件的句柄。因此事件,互斥量和信號量都會遇到“遺棄”問題。我們已經知道互斥量能夠處理“遺棄”問題,接下來就來看看事件和信號量是否能夠處理“遺棄”問題。類似於第七篇對互斥量所做的試驗,下面也對事件和信號量作同樣的試驗:
1. 創建二個進程。
2. 進程一創建一個初始為未觸發的事件,然後等待按鍵,按下y則觸發事件後結束進程,否則直接退出表示進程一已意外終止。
3. 進程二先獲得事件的句柄,然後調用WaitForSingleObject()等待這個事件10秒,在這10秒內如果事件已經觸發則輸出“已收到信號”,否則輸出“未在規定的時間內收到信號”。如果在等待的過程中進程一意外終止,則輸出“擁有事件的進程意外終止”。信號量的試驗方法類似。
為了加強對比效果,將互斥量的試驗結果先展示出來(代碼請參見第七篇)
可以看出在第一個進程在沒有觸發互斥量就直接退出的情況下,等待這個互斥量的第二個進程是能夠感知進程一所發生的意外終止的。
接下來就先完成事件的“遺棄”問題試驗代碼。
進程一:
[cpp] view plain copy- #include <stdio.h>
- #include <conio.h>
- #include <windows.h>
- const TCHAR STR_EVENT_NAME[] = TEXT("Event_MoreWindows");
- int main()
- {
- printf(" 經典線程同步 事件的遺棄處理 進程一\n");
- printf(" -- by MoreWindows( http://blog.csdn.net/MoreWindows ) --\n\n");
- HANDLE hEvent = CreateEvent(NULL, FALSE, FALSE, STR_EVENT_NAME);//自動置位 當前未觸發
- printf("事件已經創建,現在按y觸發事件,按其它鍵終止進程\n");
- char ch;
- scanf("%c", &ch);
- if (ch != ‘y‘)
- exit(0); //表示進程意外終止
- SetEvent(hEvent);
- printf("事件已經觸發\n");
- CloseHandle(hEvent);
- return 0;
- }
進程二:
[cpp] view plain copy- #include <stdio.h>
- #include <windows.h>
- const TCHAR STR_EVENT_NAME[] = TEXT("Event_MoreWindows");
- int main()
- {
- printf(" 經典線程同步 事件的遺棄處理 進程二\n");
- printf(" -- by MoreWindows( http://blog.csdn.net/MoreWindows ) --\n\n");
- HANDLE hEvent = OpenEvent(EVENT_ALL_ACCESS, TRUE, STR_EVENT_NAME); //打開事件
- if (hEvent == NULL)
- {
- printf("打開事件失敗\n");
- return 0;
- }
- printf(" 等待中....\n");
- DWORD dwResult = WaitForSingleObject(hEvent, 10 * 1000); //等待事件被觸發
- switch (dwResult)
- {
- case WAIT_ABANDONED:
- printf("擁有事件的進程意外終止\n");
- break;
- case WAIT_OBJECT_0:
- printf("已經收到信號\n");
- break;
- case WAIT_TIMEOUT:
- printf("未在規定的時間內收到信號\n");
- break;
- }
- CloseHandle(hEvent);
- return 0;
- }
事件Event試驗結果1-進程一觸發事件後正常結束:
事件Event試驗結果2-進程一意外終止:
可以看出進程二沒能感知進程一意外終止,說明事件不能處理“遺棄”問題。
下面再來試下信號量。
信號量的“遺棄”問題試驗代碼:
進程一:
[cpp] view plain copy- #include <stdio.h>
- #include <conio.h>
- #include <windows.h>
- const TCHAR STR_SEMAPHORE_NAME[] = TEXT("Semaphore_MoreWindows");
- int main()
- {
- printf(" 經典線程同步 信號量的遺棄處理 進程一\n");
- printf(" -- by MoreWindows( http://blog.csdn.net/MoreWindows ) --\n\n");
- HANDLE hSemaphore = CreateSemaphore(NULL, 0, 1, STR_SEMAPHORE_NAME);//當前0個資源,最大允許1個同時訪問
- printf("信號量已經創建,現在按y觸發信號量,按其它鍵終止進程\n");
- char ch;
- scanf("%c", &ch);
- if (ch != ‘y‘)
- exit(0); //表示進程意外終止
- ReleaseSemaphore(hSemaphore, 1, NULL);
- printf("信號量已經觸發\n");
- CloseHandle(hSemaphore);
- return 0;
- }
進程二:
[cpp] view plain copy- #include <stdio.h>
- #include <windows.h>
- const TCHAR STR_SEMAPHORE_NAME[] = TEXT("Semaphore_MoreWindows");
- int main()
- {
- printf(" 經典線程同步 信號量的遺棄處理 進程二\n");
- printf(" -- by MoreWindows( http://blog.csdn.net/MoreWindows ) --\n\n");
- HANDLE hSemaphore = OpenSemaphore (SEMAPHORE_ALL_ACCESS, TRUE, STR_SEMAPHORE_NAME); //打開信號量
- if (hSemaphore == NULL)
- {
- printf("打開信號量失敗\n");
- return 0;
- }
- printf(" 等待中....\n");
- DWORD dwResult = WaitForSingleObject(hSemaphore, 10 * 1000); //等待信號量被觸發
- switch (dwResult)
- {
- case WAIT_ABANDONED:
- printf("擁有信號量的進程意外終止\n");
- break;
- case WAIT_OBJECT_0:
- printf("已經收到信號\n");
- break;
- case WAIT_TIMEOUT:
- printf("未在規定的時間內收到信號\n");
- break;
- }
- CloseHandle(hSemaphore);
- return 0;
- }
信號量Semaphore試驗結果1-進程一觸發信號量後正常結束
信號量Semaphore試驗結果2-進程一意外終止
可以看出進程二沒能感知進程一意外終止,說明信號量與事件一樣都不能處理“遺棄”問題。
四.“遺棄”問題總結
由本文所做的試驗可知,互斥量能夠處理“遺棄”情況,事件與信號量都無法解決這一情況。
再思考下互斥量能處理“遺棄”問題的原因,其實正是因為它有“線程所有權”概念。在系統中一旦有線程結束後,系統會判斷是否有互斥量被這個線程占有,如果有,系統會將這互斥量對象內部的線程ID號將設置為NULL,遞歸計數設置為0,這表示該互斥量已經不為任何線程占用,處於觸發狀態。其它等待這個互斥量的線程就能順利執行下去了。至於線程如何獲取互斥量的“線程所有權”,MSDN上介紹為——A thread obtainsownership of a mutex either by creating it with the bInitialOwnerparameter set to TRUE or by specifying its handle in a call toone of the wait functions.
多線程面試題系列(15):關鍵段,事件,互斥量,信號量的“遺棄”問題