IamCostello · March 28, 2020 15:20 · Mar 28, 2020
diff --git a/Consumer.java b/Consumer.java
@@ -0,0 +1,15 @@
+package com.company;
+
+class Consumer{
+    private Repository repository;
+
+    public Consumer(Repository repository){
+        this.repository = repository;
+    }
+
+    public void consume(){
+        System.out.println("Consumed: ");
+        repository.getProducts().forEach(System.out::println);
+        repository.getProducts().clear();
+    }
+}
diff --git a/ConsumerObserver.java b/ConsumerObserver.java
@@ -0,0 +1,20 @@
+package com.company;
+
+import java.beans.PropertyChangeEvent;
+import java.beans.PropertyChangeListener;
+
+public class ConsumerObserver implements PropertyChangeListener {
+    private RepositoryObservable repository;
+
+    public ConsumerObserver(RepositoryObservable repository){
+        this.repository = repository;
+    }
+
+    public void propertyChange(PropertyChangeEvent propertyChangeEvent){
+        if(propertyChangeEvent.getPropertyName() == "hasProducts"){
+            System.out.println("Consumed: ");
+            repository.getProducts().forEach(System.out::println);
+            repository.getProducts().clear();
+        }
+    }
+}
diff --git a/Main.java b/Main.java
@@ -0,0 +1,25 @@
+package com.company;
+
+public class Main {
+
+    public static void main(String[] args) throws InterruptedException {
+	    Repository repository = new Repository();
+	    Manufacturer manufacturer = new Manufacturer(repository);
+	    Manufacturer manufacturer2 = new Manufacturer(repository);
+	    Consumer consumer = new Consumer(repository);
+
+	    repository.addManufacturer(manufacturer);
+	    repository.addManufacturer(manufacturer2);
+	    repository.addConsumer(consumer);
+
+        while(true){
+            if(repository.hasSpace()){
+                repository.notifyManufacturers();
+            }
+            if(repository.hasProducts()){
+                repository.notifyConsumers();
+            }
+            Thread.sleep(1000);
+        }
+    }
+}
diff --git a/Main2.java b/Main2.java
@@ -0,0 +1,25 @@
+package com.company;
+
+public class Main {
+
+    public static void main(String[] args) throws InterruptedException {
+        RepositoryObservable repository = new RepositoryObservable();
+        ManufacturerObserver manufacturer = new ManufacturerObserver(repository);
+        ManufacturerObserver manufacturer2 = new ManufacturerObserver(repository);
+        ConsumerObserver consumer = new ConsumerObserver(repository);
+
+        repository.addManufacturer(manufacturer);
+        repository.addManufacturer(manufacturer2);
+        repository.addConsumer(consumer);
+
+        repository.addPropertyChangeListener(manufacturer);
+        repository.addPropertyChangeListener(manufacturer2);
+        repository.addPropertyChangeListener(consumer);
+
+        while(true){
+            if(repository.hasSpace())
+            if(repository.hasProducts())
+            Thread.sleep(1000);
+        }
+    }
+}
diff --git a/Manufacturer.java b/Manufacturer.java
@@ -0,0 +1,16 @@
+package com.company;
+
+class Manufacturer {
+    static private int product = 0;
+    private Repository repository;
+
+    public Manufacturer(Repository repository){
+        this.repository = repository;
+    }
+
+    public void produce(){
+        System.out.println("Produced: " + product);
+        repository.addProduct(product);
+        product++;
+    }
+}
diff --git a/ManufacturerObserver.java b/ManufacturerObserver.java
@@ -0,0 +1,21 @@
+package com.company;
+
+import java.beans.PropertyChangeEvent;
+import java.beans.PropertyChangeListener;
+
+public class ManufacturerObserver implements PropertyChangeListener {
+    static private int product = 0;
+    private RepositoryObservable repository;
+
+    public ManufacturerObserver(RepositoryObservable repository){
+        this.repository = repository;
+    }
+
+    public void propertyChange(PropertyChangeEvent propertyChangeEvent){
+        if(propertyChangeEvent.getPropertyName() == "hasSpace"){
+            System.out.println("Produced: " + product);
+            repository.addProduct(product);
+            product++;
+        }
+    }
+}
diff --git a/Repository.java b/Repository.java
@@ -0,0 +1,48 @@
+package com.company;
+
+import java.util.ArrayList;
+import java.util.List;
+
+class Repository {
+    private List<Integer> products = new ArrayList<>(10);
+    private List<Consumer> consumers = new ArrayList<>();
+    private List<Manufacturer> manufacturers = new ArrayList<>();
+
+    public void addConsumer(Consumer consumer){
+        consumers.add(consumer);
+    }
+
+    public void addManufacturer(Manufacturer manufacturer){
+        manufacturers.add(manufacturer);
+    }
+
+    public List<Integer> getProducts() {
+        return products;
+    }
+
+    public void addProduct(int id){
+        if(hasSpace()){
+            products.add(id);
+        }
+    }
+
+    public boolean hasSpace(){
+        return products.size() < 10;
+    }
+
+    public boolean hasProducts(){
+        return !products.isEmpty();
+    }
+
+    public void notifyManufacturers(){
+        for(Manufacturer manufacturer: manufacturers){
+            manufacturer.produce();
+        }
+    }
+
+    public void notifyConsumers(){
+        for(Consumer consumer : consumers){
+            consumer.consume();
+        }
+    }
+}
diff --git a/RepositoryObservable.java b/RepositoryObservable.java
@@ -0,0 +1,52 @@
+package com.company;
+
+import java.beans.PropertyChangeListener;
+import java.beans.PropertyChangeSupport;
+import java.util.ArrayList;
+import java.util.List;
+
+public class RepositoryObservable {
+    private List<Integer> products = new ArrayList<>(10);
+    private List<ConsumerObserver> consumers = new ArrayList<>();
+    private List<ManufacturerObserver> manufacturers = new ArrayList<>();
+
+    private PropertyChangeSupport notify;
+
+    public RepositoryObservable(){
+        notify = new PropertyChangeSupport(this);
+    }
+
+    public void addPropertyChangeListener(PropertyChangeListener propertyChangeListener){
+        notify.addPropertyChangeListener(propertyChangeListener);
+    }
+
+    public void addConsumer(ConsumerObserver consumer){
+        consumers.add(consumer);
+    }
+
+    public void addManufacturer(ManufacturerObserver manufacturer){
+        manufacturers.add(manufacturer);
+    }
+
+    public List<Integer> getProducts() {
+        return products;
+    }
+
+    public void addProduct(int id){
+        if(products.size() < 10){
+            products.add(id);
+        }
+    }
+
+    public boolean hasSpace(){
+        boolean state = products.size() < 10;
+        notify.firePropertyChange("hasSpace", false, state);
+        return state;
+    }
+
+    public boolean hasProducts(){
+        boolean state = !products.isEmpty();
+        notify.firePropertyChange("hasProducts", false, state);
+        return state;
+    }
+}
No results found