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); } } }