package lab;

/*
 * To change this license header, choose License Headers in Project Properties.
 * To change this template file, choose Tools | Templates
 * and open the template in the editor.
 */

import java.util.concurrent.Semaphore;
/**
 *
 * @author ZTI
 */
/********************************
* Zadanie polega na zsynchronizowaniu wątków P1, P2, P3 oraz P4
* tak aby suma zmiennych A, B i C wyświetlana w wątku P4 osiągnęła
* określoną wartość (same zmienne mogą mieć wartości dowolne, ale sumujące się do zadanej).
* UWAGA: Wykonanie kodu klasy nie powinno się kończyć blokadą tzn.
* wszystkie wątki powinny zakończyć swoje działanie,
* nawet jeśli watek P4 zakończy się wcześniej.
* Powyższe zachowanie należy zapewnić używając jak najmniejszej liczby semaforów.
* Zestawy zadań (zawierają dwie wartości sumy):^
1) 16, 60
2) 21, 56
3) 22, 46
4) 26, 40
5) 30, 36
6) 36, 30
7) 40, 22
8) 46, 26
9) 56, 16
10) 60, 21
11) 16, 46
12) 21, 40
13) 22, 36
14) 26, 30
15) 30, 60
16) 36, 56
17) 40, 16
18) 46, 21
19) 56, 22
20) 60, 26
**********************************/
public class Zad_EP {

    private static int A = 0;
    private static int B = 0;
    private static int C = 3;

    private static final Semaphore P1 = new Semaphore(1, true);
    private static final Semaphore P2 = new Semaphore(0, true);
    private static final Semaphore P3 = new Semaphore(0, true);
    private static final Semaphore P4 = new Semaphore(0, true);

    public static void main(String[] args) {
        new P1().start();
        new P2().start();
        new P3().start();
        new P4().start();
    }

    private static final class P1 extends Thread {

        @Override
        public void run() {
            try {
                P1.acquire();
                A = 10;
                P3.release();
                P1.acquire();
                P2.release();
                B = B + 5;
                C = C + A;


                Thread.sleep(0);
                System.out.println("Thread P1 is done...");

            } catch (InterruptedException ex) {
                System.out.println("Ooops...");
                Thread.currentThread().interrupt();
                throw new RuntimeException(ex);
            }
        }
    }

    private static final class P2 extends Thread {

        @Override
        public void run() {
            try {
                P2.acquire();
                P3.release();
                B = B + C;

                A = A + B;
                Thread.sleep(0);

                System.out.println("Thread P2 is done...");

            } catch (InterruptedException ex) {
                System.out.println("Ooops...");
                Thread.currentThread().interrupt();
                throw new RuntimeException(ex);
            }
        }
    }

    private static final class P3 extends Thread {

        @Override
        public void run() {
            try {
                P3.acquire();
                C = B + 10;

                A = 2 * A;
                P4.release();
                P3.acquire();
                B = B + A;




                Thread.sleep(0);
                System.out.println("Thread P3 is done...");

            } catch (InterruptedException ex) {
                System.out.println("Ooops...");
                Thread.currentThread().interrupt();
                throw new RuntimeException(ex);
            }
        }
    }

    private static final class P4 extends Thread {

        @Override
        public void run() {
            try {
                P4.acquire();
                System.out.println("Sum result: " + A + " + " + B + " + " + C + " = " + (A + B + C));
                P1.release();
                Thread.sleep(0);
                System.out.println("Thread P4 is done...");

            } catch (InterruptedException ex) {
                System.out.println("Ooops...");
                Thread.currentThread().interrupt();
                throw new RuntimeException(ex);
            }
        }
    }


}