package EjerciciosConSemaforos;

import static es.urjc.etsii.code.concurrency.SimpleConcurrent.*;
import es.urjc.etsii.code.concurrency.SimpleSemaphore;

public class Ejercicio14SincronizaciondeBarrera {

    private static SimpleSemaphore semaphore = new SimpleSemaphore(5);
    static volatile int contadorBarrera = 0;
    static final int T_BUFFER = 5;

    public static void escribir() {

        sleep(1000);
        sleepRandom(500);
        print("A");

        semaphore.acquire();
        contadorBarrera++;
        while (contadorBarrera < 5);
        semaphore.release();

        print("B");

    }

    public static void main(String[] args) {

        createThreads(T_BUFFER, "escribir");

        startThreadsAndWait();
    }

}