QNX多執行緒同步之Barrier 屏障

之前和大家介紹過qnx上的執行緒同步方法metux和semophore，通過這兩種方法可以對乙個或者幾個資源進行加鎖，避免資源使用上的衝突。在另一種情況下，某個執行緒需要在其它執行緒完成工作後才繼續執行，這時就需要使用到執行緒同步方法barrier。

舉個現實的例子，假設有三個士兵在操作一門高炮，乙個負責裝填炮彈，乙個負責調整高炮左右方向，乙個負責調整高炮角度。很明顯高炮需要在三名士兵完成任務後才能發射，否則要麼打不准，要麼炮彈根本打不出去。

一種解決方法是給高炮設定三個按鈕，只有三個按鈕都按下了高炮才發射，這樣不管哪個士兵完成任務了，他只需要按下自己負責的按鈕，一旦三個按鈕都按下，說明三個士兵的工作都完成了，就發射炮彈。

這個有三個按鈕的裝置就可以說是乙個屏障，保證高炮可以正常工作。

下面就以這個例子做乙個barrier測試。

首先需要引入標頭檔案，包括：

#include

其中pthread.h和sync.h是關鍵，乙個用於執行緒建立，乙個用於barrier。

然後定義乙個pthread_barrier_t全域性變數：

pthread_barrier_t barrier;

接著在main函式裡初始化barrier:

pthread_barrier_init(&barrier, null, 3);

其中第乙個引數就是barrier變數，第三個引數是屏障需要等待的數量，本例就是等待3個士兵完成任務，所以設定成3.

然後啟動三個士兵的執行緒，每個士兵執行緒負責完成一件工作，完成之前有乙個delay的迴圈，表示完成工作需要的時間，不同士兵執行緒delay的時間不同，表示完成不同工作需要不同的時間。

所有士兵執行緒完成工作後都呼叫pthread_barrier_wait方法，通知barrier工作以完成，並開始等待，呼叫方法如下，唯一的引數就是初始化好的barrier變數：

pthread_barrier_wait(&barrier);

一旦 pthread_barrier_wait執行完成，表示所用工作都完成了，就發射炮彈，通過列印「fire!」表示。

printf("soldierx:::::::::: fire! \n");

另外，主線程啟動三個士兵執行緒後進入乙個迴圈等待，同時輸出一些時間資訊。

程式執行結果如下：

entering barrier test

creating the barrier

creating the threads

soldier1:::::::::: adjusting angle

soldier2:::::::::: adjusting direction

soldier3:::::::::: filling bullet

timer in main thread:0

timer in main thread:1

timer in main thread:2

timer in main thread:3

timer in main thread:4

soldier1:::::::::: angle ready!

timer in main thread:5

soldier2:::::::::: direction ready!

timer in main thread:6

timer in main thread:7

soldier3:::::::::: bullet ready!

soldier3:::::::::: fire!

soldier1:::::::::: fire!

soldier2:::::::::: fire!

timer in main thread:8

timer in main thread:9

end of main thread

可以看到，只有三個執行緒都完成相應任務後他們才繼續往下執行，保證了大炮可以成功發射。

完整**如下：

#include #include #include #include #include #include pthread_barrier_t barrier; void soldier1() printf("soldier1:::::::::: angle ready!\n"); pthread_barrier_wait(&barrier); printf("soldier1:::::::::: fire! \n"); } void soldier2() printf("soldier2:::::::::: direction ready!\n"); pthread_barrier_wait(&barrier); printf("soldier2:::::::::: fire! \n"); } void soldier3() printf("soldier3:::::::::: bullet ready!\n"); pthread_barrier_wait(&barrier); printf("soldier3:::::::::: fire! \n"); } int main(int argc, char *argv) printf("end of main thread\n"); pthread_barrier_destroy(&barrier); return exit_success; }

QNX多執行緒同步之Barrier 屏障

QNX多執行緒同步之Barrier 屏障

QNX多執行緒同步之Barrier 屏障

多執行緒同步之synchronized

相關推薦