Bariera (informatyka) 📖 Wikipedia

#include <stdio.h>
#include <pthread.h>
#include <unistd.h>

#define LICZBA_WATKOW 3

// Deklaracja bariery
pthread_barrier_t bariera;

void* zadanie(void* id) {
    long numer = (long)id;

    printf("Wątek %ld: Rozpoczynam etap 1...\n", numer);
    sleep(numer); // Symulacja pracy o różnym czasie trwania

    printf("Wątek %ld: Dotarłem do bariery i czekam.\n", numer);
    
    // Punkt synchronizacji - wątek zatrzymuje się tutaj, 
    // dopóki wszystkie wątki nie wywołają tej funkcji.
    pthread_barrier_wait(&bariera);

    printf("Wątek %ld: Przekroczyłem barierę, zaczynam etap 2.\n", numer);

    return NULL;
}

int main() {
    pthread_t watki[LICZBA_WATKOW];

    // Inicjalizacja bariery dla określonej liczby wątków
    pthread_barrier_init(&bariera, NULL, LICZBA_WATKOW);

    // Tworzenie wątków
    for (long i = 0; i < LICZBA_WATKOW; i++) {
        pthread_create(&watki[i], NULL, zadanie, (void*)i);
    }

    // Oczekiwanie na zakończenie wątków
    for (int i = 0; i < LICZBA_WATKOW; i++) {
        pthread_join(watki[i], NULL);
    }

    // Zwolnienie zasobów bariery
    pthread_barrier_destroy(&bariera);

    printf("Wszystkie wątki zakończyły pracę.\n");
    return 0;
}