pthread Barrier

Pthread Barrier:
https://langzi989.github.io/2018/07/05/pthread%E4%BD%BF%E7%94%A8barrier%E6%A0%85%E6%A0%8F%E6%96%B9%E5%BC%8F%E5%90%8C%E6%AD%A5/

1 2 3 4 5 6 7 8 9 10 11 12

#include <pthread.h> //初始化栅栏，栅栏需要等待到count个线程，才会全部一起放行。 int pthread_barrier_init(pthread_barrier_t *restrict, const pthread_barrierattr_t *restrict, unsigned count); //报道函数，当一个线程到达栅栏的时候，就报道。 //所有的线程都报道后，栅栏自然会放行。 int pthread_barrier_wait(pthread_barrier_t *barrier); 栅栏完成历史使命后，当然是功成身退。 int pthread_barrier_destroy(pthread_barrier_t *barrier);

使用示例

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41

#include <stdio.h> #include <time.h> #include <stdlib.h> #include <string.h> #include <pthread.h> #include <unistd.h> pthread_barrier_t barrier; void* initor(void* args) { printf("---------------thread init work(%d)--------------\n", time(NULL)); //模拟初始化工作。 sleep(10); //到达栅栏 pthread_barrier_wait(&barrier); printf("--------------thread start work(%d)--------------\n", time(NULL)); sleep(10); printf("--------------thread stop work(%d)--------------\n", time(NULL)); return NULL; } int main(int argc, char* argv[]) { //初始化栅栏，该栅栏等待两个线程到达时放行 pthread_barrier_init(&barrier, NULL, 2); printf("**************main thread barrier init done****************\n"); pthread_t pid; pthread_create(&pid, NULL, &initor, NULL); printf("**************main waiting(%d)********************\n", time(NULL)); //主线程到达，被阻塞，当初始化线程到达栅栏时才放行。 pthread_barrier_wait(&barrier); pthread_barrier_destroy(&barrier); printf("***************main start to work(%d)****************\n", time(NULL)); sleep(30); pthread_join(pid, NULL); printf("***************thread complete(%d)***************\n", time(NULL)); return 0; }