一、主要函數應用
1. 函數原型:初始化和回收
int pthread_barrier_init(pthread *barrier, const pthread_barrier_t *attr, unsigned int count);
int pthread_barrier_destroy(pthread_barrier_t *barrier);
分析:
- 初始化屏障時,可以使用count參數指定,在允許所有線程運行之前,必須到達屏障的線程數目。?
?
2.?函數原型
#include <pthread.h>
int pthread_barrier_wait(pthread_barrier_t *barrier);
分析:
- 每一個線程調用等待函數,barrier 計數都會加 1,直到計數值等于初始化函數中的參數 count。當最后一個線程讓 barrier 計數值達到了 count,所有等待的線程都會被喚醒。
- 所有線程中,只有一個線程會讓 pthread_barrier_wait 返回?
PTHREAD_BARRIER_SERIAL_THREAD
,而其它線程調用此函數會返回 0.
?
1. 測試代碼
【題目】程序 barrier 一共有 11 個線程,包含主線程。所有線程會先打印一遍 “hello, I’m thread xx” 然后調用 pthread_barrier_wait 等待,直到 barrier 計數達到了 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;
}
輸出結果:
?
參考資料
1. 88-屏障 barrier