一、主要函數(shù)應(yīng)用

1. 函數(shù)原型：初始化和回收

int pthread_barrier_init(pthread *barrier, const pthread_barrier_t *attr, unsigned int count); int pthread_barrier_destroy(pthread_barrier_t *barrier);

分析：

• 初始化屏障時，可以使用count參數(shù)指定，在允許所有線程運行之前，必須到達屏障的線程數(shù)目。?

?

2.?函數(shù)原型

#include <pthread.h> int pthread_barrier_wait(pthread_barrier_t *barrier);

分析：

• 每一個線程調(diào)用等待函數(shù)，barrier 計數(shù)都會加 1，直到計數(shù)值等于初始化函數(shù)中的參數(shù) count。當最后一個線程讓 barrier 計數(shù)值達到了 count，所有等待的線程都會被喚醒。
• 所有線程中，只有一個線程會讓 pthread_barrier_wait 返回?PTHREAD_BARRIER_SERIAL_THREAD，而其它線程調(diào)用此函數(shù)會返回 0.

?

1. 測試代碼

【題目】程序 barrier 一共有 11 個線程，包含主線程。所有線程會先打印一遍 “hello, I’m thread xx” 然后調(diào)用 pthread_barrier_wait 等待，直到 barrier 計數(shù)達到了 11 才返回。一旦返回了，就會打印 thread xx returning xx.

#include <unistd.h> #include <stdio.h> #include <pthread.h>pthread_barrier_t b;void* th_fn(void *arg) {int id = (int)arg;int res = 0;printf("hello, I'm thread [%d]\n", id);res = pthread_barrier_wait(&b);printf("thread [%d] returning [%d]\n", id, res);return NULL; }int main() {int i, res = 0;pthread_t tid[10];printf("PTHREAD_BARRIER_SERIAL_THREAD = %d\n", PTHREAD_BARRIER_SERIAL_THREAD);pthread_barrier_init(&b, NULL, 11);for (i = 0; i < 10; ++i) {pthread_create(&tid[i], NULL, th_fn, (void*)i);}res = pthread_barrier_wait(&b);printf("thread [main] returning [%d]\n", res);for (i = 0; i < 10; ++i) {pthread_join(tid[i], NULL);}pthread_barrier_destroy(&b);return 0; }

輸出結(jié)果：

?

參考資料

1. 88-屏障 barrier

總結(jié)

以上是生活随笔為你收集整理的【线程】屏障的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。