package ops023_lab01_uppgift_jc3;
 
import java.awt.Point;
 
public class LabAlarm {
    //make sure that they have a common buffer AlarmBuffer to write and read data
 
    static AlarmBuffer ab = new AlarmBuffer();
    //
    static AlarmClient client1 = new AlarmClient("client1", new Point(600, 100));
    static AlarmClient client2 = new AlarmClient("client2", new Point(600, 200));
    static AlarmClient client3 = new AlarmClient("client3", new Point(600, 300));
    static AlarmClient client4 = new AlarmClient("client4", new Point(600, 400));
    //
    static AlarmProducer producer1 = new AlarmProducer("producer1", ab, client1);
    static AlarmProducer producer2 = new AlarmProducer("producer2", ab, client2);
    static AlarmProducer producer3 = new AlarmProducer("producer3", ab, client3);
    //version with more then one registered clients
    static AlarmProducer producer4 = new AlarmProducer("producer4", ab, client1, client2, client3, client4);
    //
    static AlarmConsumer consumer1 = new AlarmConsumer("consumer1", new Point(10, 0), ab);
    static AlarmConsumer consumer2 = new AlarmConsumer("consumer2", new Point(10, 400), ab);
 
    public LabAlarm() {
 
        Thread runnableProducer1 = new Thread(producer1);
        Thread runnableProducer2 = new Thread(producer2);
        Thread runnableProducer3 = new Thread(producer3);
        Thread runnableProducer4 = new Thread(producer4);
        //
        Thread runnableConsumer1 = new Thread(consumer1);
        Thread runnableConsumer2 = new Thread(consumer2);
 
        runnableConsumer1.start();
        runnableConsumer2.start();
        //
        runnableProducer1.start();
        runnableProducer2.start();
        runnableProducer3.start();
        runnableProducer4.start();
    }
 
    public static void main(String[] args) {
        new LabAlarm();
    }
}

package ops023_lab01_uppgift_jc3;
 
//class for a Buffer in the producer consumer problem
//look in lecture slides for hint on how to implement it
public class AlarmBuffer {
 
    private AlarmMessage message;
    private boolean empty;
 
    public void TheBuffer() {
        System.out.println("TheBuffer ");
        this.empty = true;
    }
 
    public synchronized void insert(AlarmMessage message) {
        System.out.println("i1");//for test
        while (!empty) {
            try {
                System.out.println("i2");
                wait();
                System.out.println("i3");
            } catch (InterruptedException e) {
            }
        }//end of while-loop
        this.message = message;
        this.empty = false;
        System.out.println("i4");
        notify();
        System.out.println("i5");
    }//end of insert-method
 
    // who uses this ?
    public synchronized AlarmMessage remove() {
        System.out.println("r1");
        while (empty) {
            try {
                System.out.println("r2");
                wait();
                System.out.println("r3");
            } catch (InterruptedException e) {
            }
 
        }//end of while-loop
        this.empty = true;
        System.out.println("r4");
        notify();
        System.out.println("r5");
        return message;
 
    }//end of remove-method
 
    //diagnostic
    public synchronized boolean isEmpty(String who) {//3.
        System.out.println(who + " ask-->AlarmBuffer: isEmpty() " + empty + "\n");
        return empty;
    }
 
    public synchronized boolean isEmpty() {
        return empty;
    }
}//end of class

package ops023_lab01_uppgift_jc3;
 
public class AlarmMessage {
 
    private String fromClient;
    private String message;
    private long alarmTime;
 
    AlarmMessage(String name, String messageText) {
        fromClient = name;
        message = messageText;
        alarmTime = System.currentTimeMillis();
    }
 
    @Override
    public String toString() {
        StringBuffer sb = new StringBuffer();
        sb.append("[fromClient: ");
        sb.append(fromClient);
        sb.append(",message: ");
        sb.append(message);
        sb.append(",alarmTime: ");
        sb.append(alarmTime);
        sb.append("]\n");
        return sb.toString();
    }
}