logo

Introduction to barriers (pthread_barrier)

#include <pthread.h> #include <stdio.h> #include <stdlib.h> #include <unistd.h> #include <string.h> pthread_barrier_t barrier; void* routine(void* args) { while (1) { printf("Waiting at the barrier...\n"); sleep(1); pthread_barrier_wait(&barrier); printf("We passed the barrier\n"); sleep(1); } } int main(int argc, char *argv[]) { pthread_t th[10]; int i; pthread_barrier_init(&barrier, NULL, 10); for (i = 0; i < 10; i++) { if (pthread_create(&th[i], NULL, &routine, NULL) != 0) { perror("Failed to create thread"); } } for (i = 0; i < 10; i++) { if (pthread_join(th[i], NULL) != 0) { perror("Failed to join thread"); } } pthread_barrier_destroy(&barrier); return 0; }
Course thumb

The C programming language made simple

Courses with this lesson