AtomiciPisciCitaoci

package djolepokusavaatomike;

import java.util.concurrent.atomic.AtomicInteger;

import os.simulation.Application;
import os.simulation.AutoCreate;
import os.simulation.Container;
import os.simulation.Item;
import os.simulation.Operation;
import os.simulation.Thread;

/*
 * Data je zajednicka baza podataka. Vise procesa zeli da istovremeno pristupa
 * ovoj bazi kako bi citali ili upisivali podatke u nju. Kako bi korektno
 * realizovali ove istovremene pristupe bez rizika da dodje do problema,
 * procesi moraju da postuju sledeca pravila: istovremena citanja su dozvoljena
 * posto citaoci ne smetaju jedan drugom, istovremeno citanje i pisanje nije
 * dozvoljeno jer se moze desiti da citalac procita pogresne podatke (do pola
 * upisane), istovremena pisanja takodje nisu dozvoljena jer mogu prouzrokovati
 * ostecenje podataka.
 *
 * Implementirati sinhronizaciju procesa pisaca i procesa citalaca tako da se
 * postuju opisana pravila.
 */
public class PristupAtomici extends Application{

    public class Pristup{

        private AtomicInteger brP = new AtomicInteger(0);
        private AtomicInteger brC = new AtomicInteger(0);

        private final int MAX  = 5;

        private void zapocniPisanje() {

            boolean ok;
            do {
                int oldValue = brP.get();

                ok = oldValue  == 0;
                if(ok) {
                    ok = brP.compareAndSet(oldValue, 1);
                }

            }while(!ok);

        }
        private void zavrsiPisanje() {
            boolean ok;
            do {
                int oldValue =  brP.get();
                    ok = brP.compareAndSet(oldValue, 0);
            }while(!ok);
        }

        private void zapocniCitanje() {

            boolean ok;
            do {
                int oldValue = brP.get();

                ok = oldValue == 0 || oldValue ==2;
                if(ok) {
                    ok = brP.compareAndSet(oldValue, 2);
                }

            }while(!ok);

            do {
                int oldValue = brC.get();
                int newValue = oldValue + 1;
                ok = newValue <= MAX;
                if(ok) {
                    ok = brC.compareAndSet(oldValue, newValue);
                }
            }while(!ok);
        }

        private void zavrsiCitanje() {
            boolean poslednji = false ;
            boolean ok;
            do {
                int oldValue = brC.get();
                int newValue = oldValue - 1;
                ok = newValue >= 0;
                if(ok) {
                    ok = brC.compareAndSet(oldValue, newValue);
                    if(newValue==0)
                        poslednji = true;
                }

            }while(!ok);

            if(poslednji)
                brP.set(0);
        }


    }

    private Pristup pristup = new Pristup();

    @AutoCreate(2)
    protected class Pisac extends Thread {

        @Override
        protected void step() {
            radiNestoDrugo();
            pristup.zapocniPisanje();
            pise();
            pristup.zavrsiPisanje();
        }
    }

    @AutoCreate(5)
    protected class Citalac extends Thread {

        @Override
        protected void step() {
            radiNestoDrugo();
            pristup.zapocniCitanje();
            cita();
            pristup.zavrsiCitanje();
        }
    }

    // ------------------- //
    //    Sistemski deo    //
    // ------------------- //
    // Ne dirati kod ispod //
    // ------------------- //

    protected final Container pisci   = box("Писци").color(MAROON);
    protected final Container citaoci = box("Читаоци").color(NAVY);
    protected final Container resurs  = box("База").color(ROYAL);
    protected final Container main    = column(row(pisci, citaoci), resurs);
    protected final Operation pisac   = init().name("Писац %d").color(ROSE).container(pisci);
    protected final Operation citalac = init().name("Читалац %d").color(AZURE).container(citaoci);
    protected final Operation pisanje = duration("4±2").text("Пише").container(resurs).textAfter("Завршио").update(this::azuriraj);;
    protected final Operation citanje = duration("2±2").text("Чита").container(resurs).textAfter("Завршио").update(this::azuriraj);;
    protected final Operation posao   = duration("3±2").text("Ради").textAfter("Чека");

    protected void pise() {
        pisanje.performUninterruptibly();
    }

    protected void cita() {
        citanje.performUninterruptibly();
    }

    protected void radiNestoDrugo() {
        posao.performUninterruptibly();
    }

    protected void azuriraj(Item item) {
        long brP = resurs.stream(Pisac.class).count();
        long brC = resurs.stream(Citalac.class).count();
        resurs.setText(String.format("%d : %d", brP, brC));
        if (brP == 0 && brC == 0) {
            resurs.setColor(NEUTRAL_GRAY);
        } else if (brP > 0 && brC == 0) {
            resurs.setColor(MAROON);
        } else if (brP == 0 && brC > 0) {
            resurs.setColor(NAVY);
        } else {
            resurs.setColor(ROYAL);
        }
    }

    @Override
    protected void initialize() {
        azuriraj(null);
    }

    public static void main(String[] arguments) {
        launch("Писци и читаоци");
    }
}