Bariera – jeden z najpowszechniejszych rodzajów synchronizacji wątków (procesów) w przetwarzaniu równoległym.
Istnieją gotowe biblioteki implementujące bariery np. pthread.h w standarzie POSIX. Barierę można także zaimplementować ręczenie za pomocą muteksów.
Przykład Przykład kodu w języku C, używający pthread.h do synchronizacji wątków za pomocą bariery,
#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;