當前位置:編程學習大全網 - 編程語言 - 請用技術語言介紹下線程同步,並發操作怎麽控制

請用技術語言介紹下線程同步,並發操作怎麽控制

現在流行的進程線程同步互斥的控制機制,其實是由最原始最基本的4種方法實現的。由這4種方法組合優化就有了.Net和Java下靈活多變的,編程簡便的線程進程控制手段。

這4種方法具體定義如下 在《操作系統教程》ISBN 7-5053-6193-7 壹書中可以找到更加詳細的解釋

1、臨界區:通過對多線程的串行化來訪問公***資源或壹段代碼,速度快,適合控制數據訪問。

2、互斥量:為協調***同對壹個***享資源的單獨訪問而設計的。

3、信號量:為控制壹個具有有限數量用戶資源而設計。

4、事 件:用來通知線程有壹些事件已發生,從而啟動後繼任務的開始。

臨界區(Critical Section)

保證在某壹時刻只有壹個線程能訪問數據的簡便辦法。在任意時刻只允許壹個線程對***享資源進行訪問。如果有多個線程試圖同時訪問臨界區,那麽在有壹個線程進入後其他所有試圖訪問此臨界區的線程將被掛起,並壹直持續到進入臨界區的線程離開。臨界區在被釋放後,其他線程可以繼續搶占,並以此達到用原子方式操作***享資源的目的。

臨界區包含兩個操作原語:

EnterCriticalSection() 進入臨界區

 LeaveCriticalSection() 離開臨界區

EnterCriticalSection()語句執行後代碼將進入臨界區以後無論發生什麽,必須確保與之匹配的LeaveCriticalSection()都能夠被執行到。否則臨界區保護的***享資源將永遠不會被釋放。雖然臨界區同步速度很快,但卻只能用來同步本進程內的線程,而不可用來同步多個進程中的線程。

MFC提供了很多功能完備的類,我用MFC實現了臨界區。MFC為臨界區提供有壹個CCriticalSection類,使用該類進行線程同步處理是非常簡單的。只需在線程函數中用CCriticalSection類成員函數Lock()和UnLock()標定出被保護代碼片段即可。Lock()後代碼用到的資源自動被視為臨界區內的資源被保護。UnLock後別的線程才能訪問這些資源。

//CriticalSection

CCriticalSection global_CriticalSection;

// ***享資源

char global_Array[256];

//初始化***享資源

void InitializeArray()

{

for(int i = 0;i<256;i++)

{

global_Array[i]=I;

}

}

//寫線程

UINT Global_ThreadWrite(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

//進入臨界區

global_CriticalSection.Lock();

for(int i = 0;i<256;i++)

{

global_Array[i]=W;

ptr->SetWindowText(global_Array);

Sleep(10);

}

//離開臨界區

global_CriticalSection.Unlock();

return 0;

}

//刪除線程

UINT Global_ThreadDelete(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

//進入臨界區

global_CriticalSection.Lock();

for(int i = 0;i<256;i++)

{

global_Array[i]=D;

ptr->SetWindowText(global_Array);

Sleep(10);

}

//離開臨界區

global_CriticalSection.Unlock();

return 0;

}

//創建線程並啟動線程

void CCriticalSectionsDlg::OnBnClickedButtonLock()

{

//Start the first Thread

CWinThread *ptrWrite = AfxBeginThread(Global_ThreadWrite,

&m_Write,

THREAD_PRIORITY_NORMAL,

0,

CREATE_SUSPENDED);

ptrWrite->ResumeThread();

//Start the second Thread

CWinThread *ptrDelete = AfxBeginThread(Global_ThreadDelete,

&m_Delete,

THREAD_PRIORITY_NORMAL,

0,

CREATE_SUSPENDED);

ptrDelete->ResumeThread();

}

在測試程序中,Lock UnLock兩個按鈕分別實現,在有臨界區保護***享資源的執行狀態,和沒有臨界區保護***享資源的執行狀態。

程序運行結果

互斥量(Mutex)

互斥量跟臨界區很相似,只有擁有互斥對象的線程才具有訪問資源的權限,由於互斥對象只有壹個,因此就決定了任何情況下此***享資源都不會同時被多個線程所訪問。當前占據資源的線程在任務處理完後應將擁有的互斥對象交出,以便其他線程在獲得後得以訪問資源。互斥量比臨界區復雜。因為使用互斥不僅僅能夠在同壹應用程序不同線程中實現資源的安全***享,而且可以在不同應用程序的線程之間實現對資源的安全***享。

互斥量包含的幾個操作原語:

CreateMutex() 創建壹個互斥量

OpenMutex() 打開壹個互斥量

ReleaseMutex() 釋放互斥量

WaitForMultipleObjects() 等待互斥量對象

同樣MFC為互斥量提供有壹個CMutex類。使用CMutex類實現互斥量操作非常簡單,但是要特別註意對CMutex的構造函數的調用

 CMutex( BOOL bInitiallyOwn = FALSE, LPCTSTR lpszName = NULL, LPSECURITY_ATTRIBUTES lpsaAttribute = NULL)

 不用的參數不能亂填,亂填會出現壹些意想不到的運行結果。

//創建互斥量

CMutex global_Mutex(0,0,0);

// ***享資源

char global_Array[256];

void InitializeArray()

{

for(int i = 0;i<256;i++)

{

global_Array[i]=I;

}

}

UINT Global_ThreadWrite(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

global_Mutex.Lock();

for(int i = 0;i<256;i++)

{

global_Array[i]=W;

ptr->SetWindowText(global_Array);

Sleep(10);

}

global_Mutex.Unlock();

return 0;

}

UINT Global_ThreadDelete(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

global_Mutex.Lock();

for(int i = 0;i<256;i++)

{

global_Array[i]=D;

ptr->SetWindowText(global_Array);

Sleep(10);

}

global_Mutex.Unlock();

return 0;

}

同樣在測試程序中,Lock UnLock兩個按鈕分別實現,在有互斥量保護***享資源的執行狀態,和沒有互斥量保護***享資源的執行狀態。

程序運行結果

信號量(Semaphores)

信號量對象對線程的同步方式與前面幾種方法不同,信號允許多個線程同時使用***享資源,這與操作系統中的PV操作相同。它指出了同時訪問***享資源的線程最大數目。它允許多個線程在同壹時刻訪問同壹資源,但是需要限制在同壹時刻訪問此資源的最大線程數目。在用CreateSemaphore()創建信號量時即要同時指出允許的最大資源計數和當前可用資源計數。壹般是將當前可用資源計數設置為最大資源計數,每增加壹個線程對***享資源的訪問,當前可用資源計數就會減1,只要當前可用資源計數是大於0的,就可以發出信號量信號。但是當前可用計數減小到0時則說明當前占用資源的線程數已經達到了所允許的最大數目,不能在允許其他線程的進入,此時的信號量信號將無法發出。線程在處理完***享資源後,應在離開的同時通過ReleaseSemaphore()函數將當前可用資源計數加1。在任何時候當前可用資源計數決不可能大於最大資源計數。

PV操作及信號量的概念都是由荷蘭科學家E.W.Dijkstra提出的。信號量S是壹個整數,S大於等於零時代表可供並發進程使用的資源實體數,但S小於零時則表示正在等待使用***享資源的進程數。

P操作 申請資源:

 (1)S減1;

 (2)若S減1後仍大於等於零,則進程繼續執行;

 (3)若S減1後小於零,則該進程被阻塞後進入與該信號相對應的隊列中,然後轉入進程調度。

V操作 釋放資源:

 (1)S加1;

 (2)若相加結果大於零,則進程繼續執行;

 (3)若相加結果小於等於零,則從該信號的等待隊列中喚醒壹個等待進程,然後再返回原進程繼續執行或轉入進程調度。

信號量包含的幾個操作原語:

 CreateSemaphore() 創建壹個信號量

 OpenSemaphore() 打開壹個信號量

 ReleaseSemaphore() 釋放信號量

 WaitForSingleObject() 等待信號量

//信號量句柄

HANDLE global_Semephore;

// ***享資源

char global_Array[256];

void InitializeArray()

{

for(int i = 0;i<256;i++)

{

global_Array[i]=I;

}

}

//線程1

UINT Global_ThreadOne(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

//等待對***享資源請求被通過 等於 P操作

WaitForSingleObject(global_Semephore, INFINITE);

for(int i = 0;i<256;i++)

{

global_Array[i]=O;

ptr->SetWindowText(global_Array);

Sleep(10);

}

//釋放***享資源 等於 V操作

ReleaseSemaphore(global_Semephore, 1, NULL);

return 0;

}

UINT Global_ThreadTwo(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

WaitForSingleObject(global_Semephore, INFINITE);

for(int i = 0;i<256;i++)

{

global_Array[i]=T;

ptr->SetWindowText(global_Array);

Sleep(10);

}

ReleaseSemaphore(global_Semephore, 1, NULL);

return 0;

}

UINT Global_ThreadThree(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

WaitForSingleObject(global_Semephore, INFINITE);

for(int i = 0;i<256;i++)

{

global_Array[i]=H;

ptr->SetWindowText(global_Array);

Sleep(10);

}

ReleaseSemaphore(global_Semephore, 1, NULL);

return 0;

}

void CSemaphoreDlg::OnBnClickedButtonOne()

{

//設置信號量 1 個資源 1同時只可以有壹個線程訪問

global_Semephore= CreateSemaphore(NULL, 1, 1, NULL);

this->StartThread();

// TODO: Add your control notification handler code here

}

void CSemaphoreDlg::OnBnClickedButtonTwo()

{

//設置信號量 2 個資源 2 同時只可以有兩個線程訪問

global_Semephore= CreateSemaphore(NULL, 2, 2, NULL);

this->StartThread();

// TODO: Add your control notification handler code here

}

void CSemaphoreDlg::OnBnClickedButtonThree()

{

//設置信號量 3 個資源 3 同時只可以有三個線程訪問

global_Semephore= CreateSemaphore(NULL, 3, 3, NULL);

this->StartThread();

// TODO: Add your control notification handler code here

}

信號量的使用特點使其更適用於對Socket(套接字)程序中線程的同步。例如,網絡上的HTTP服務器要對同壹時間內訪問同壹頁面的用戶數加以限制,這時可以為每壹個用戶對服務器的頁面請求設置壹個線程,而頁面則是待保護的***享資源,通過使用信號量對線程的同步作用可以確保在任壹時刻無論有多少用戶對某壹頁面進行訪問,只有不大於設定的最大用戶數目的線程能夠進行訪問,而其他的訪問企圖則被掛起,只有在有用戶退出對此頁面的訪問後才有可能進入。

程序運行結果

事件(Event)

事件對象也可以通過通知操作的方式來保持線程的同步。並且可以實現不同進程中的線程同步操作。

信號量包含的幾個操作原語:

 CreateEvent() 創建壹個信號量

 OpenEvent() 打開壹個事件

 SetEvent() 回置事件

 WaitForSingleObject() 等待壹個事件

 WaitForMultipleObjects()         等待多個事件

WaitForMultipleObjects 函數原型:

 WaitForMultipleObjects(

 IN DWORD nCount, // 等待句柄數

 IN CONST HANDLE *lpHandles, //指向句柄數組

 IN BOOL bWaitAll, //是否完全等待標誌

 IN DWORD dwMilliseconds //等待時間

 )

參數nCount指定了要等待的內核對象的數目,存放這些內核對象的數組由lpHandles來指向。fWaitAll對指定的這nCount個內核對象的兩種等待方式進行了指定,為TRUE時當所有對象都被通知時函數才會返回,為FALSE則只要其中任何壹個得到通知就可以返回。dwMilliseconds在這裏的作用與在WaitForSingleObject()中的作用是完全壹致的。如果等待超時,函數將返回WAIT_TIMEOUT。

//事件數組

HANDLE global_Events[2];

// ***享資源

char global_Array[256];

void InitializeArray()

{

for(int i = 0;i<256;i++)

{

global_Ar

ray[i]=I;

}

}

UINT Global_ThreadOne(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

for(int i = 0;i<256;i++)

{

global_Array[i]=O;

ptr->SetWindowText(global_Array);

Sleep(10);

}

//回置事件

SetEvent(global_Events[0]);

return 0;

}

UINT Global_ThreadTwo(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

for(int i = 0;i<256;i++)

{

global_Array[i]=T;

ptr->SetWindowText(global_Array);

Sleep(10);

}

//回置事件

SetEvent(global_Events[1]);

return 0;

}

UINT Global_ThreadThree(LPVOID pParam)

{

CEdit *ptr=(CEdit *)pParam;

ptr->SetWindowText("");

//等待兩個事件都被回置

WaitForMultipleObjects(2, global_Events, true, INFINITE);

for(int i = 0;i<256;i++)

{

global_Array[i]=H;

ptr->SetWindowText(global_Array);

Sleep(10);

}

return 0;

}

void CEventDlg::OnBnClickedButtonStart()

{

for (int i = 0; i < 2; i++)

{

//實例化事件

global_Events[i]=CreateEvent(NULL,false,false,NULL);

}

CWinThread *ptrOne = AfxBeginThread(Global_ThreadOne,

&m_One,

THREAD_PRIORITY_NORMAL,

0,

CREATE_SUSPENDED);

ptrOne->ResumeThread();

//Start the second Thread

CWinThread *ptrTwo = AfxBeginThread(Global_ThreadTwo,

&m_Two,

THREAD_PRIORITY_NORMAL,

0,

CREATE_SUSPENDED);

ptrTwo->ResumeThread();

//Start the Third Thread

CWinThread *ptrThree = AfxBeginThread(Global_ThreadThree,

&m_Three,

THREAD_PRIORITY_NORMAL,

0,

CREATE_SUSPENDED);

ptrThree->ResumeThread();

// TODO: Add your control notification handler code here

}

事件可以實現不同進程中的線程同步操作,並且可以方便的實現多個線程的優先比較等待操作,例如寫多個WaitForSingleObject來代替WaitForMultipleObjects從而使編程更加靈活。

程序運行結果

總結:

1. 互斥量與臨界區的作用非常相似,但互斥量是可以命名的,也就是說它可以跨越進程使用。所以創建互斥量需要的資源更多,所以如果只為了在進程內部是用的話使用臨界區會帶來速度上的優勢並能夠減少資源占用量。因為互斥量是跨進程的互斥量壹旦被創建,就可以通過名字打開它。

2. 互斥量(Mutex),信號燈(Semaphore),事件(Event)都可以被跨越進程使用來進行同步數據操作,而其他的對象與數據同步操作無關,但對於進程和線程來講,如果進程和線程在運行狀態則為無信號狀態,在退出後為有信號狀態。所以可以使用WaitForSingleObject來等待進程和線程退出。

3. 通過互斥量可以指定資源被獨占的方式使用,但如果有下面壹種情況通過互斥量就無法處理,比如現在壹位用戶購買了壹份三個並發訪問許可的數據庫系統,可以根據用戶購買的訪問許可數量來決定有多少個線程/進程能同時進行數據庫操作,這時候如果利用互斥量就沒有辦法完成這個要求,信號燈對象可以說是壹種資源計數器。

疑問:

在 Linux 上,有兩類信號量。第壹類是由 semget/semop/semctl API 定義的信號量的 SVR4(System V Release 4)版本。第二類是由 sem_init/sem_wait/sem_post/interfaces 定義的 POSIX 接口。 它們具有相同的功能,但接口不同。 在2.4.x內核中,信號量數據結構定義為(include/asm/semaphore.h)。

但是在Linux中沒有對互斥量的具體提法,只是看到說互斥量是信號量的壹種特殊情況,當信號量的最大資源數=1同時可以訪問***享資源的線程數=1 就是互斥量了。臨界區的定義也比較模糊。沒有找到用事件處理線程/進程同步互斥的操作的相關資料。在Linux下用GCC/G++編譯標準C++代碼,信號量的操作幾乎和Windows下VC7的編程壹樣,不用改多少就順利移植了,可是互斥量,事件,臨界區的Linux移植沒有成功。

請采納。

  • 上一篇:急急急 誰能告訴我怎麽辦
  • 下一篇:數控等離子火焰兩用切割機切割鋼板時對身體的危害
  • copyright 2024編程學習大全網