ボートでのマルチスレッド

public class Ship { private int count; private Size size; private Type type; public Ship(Size size, Type type) { this.size = size; this.type = type; } public void add(int count) { this.count += count; } public boolean countCheck() { if (count >= size.getValue()) { return false; } return true; } public int getCount() { return count; } public Type getType() { return type; } public Size getSize() { return size; } } 

 public class Tunnel { private List<Ship> store; private static final int maxShipsInTunel = 5; private static final int minShipsInTunel = 0; private int shipsCounter = 0; public Tunnel() { store = new ArrayList<>(); } public synchronized boolean add(Ship element) { try { if (shipsCounter < maxShipsInTunel) { notifyAll(); store.add(element); String info = String.format("%s + The ship arrived in the tunnel: %s %s %s", store.size(), element.getType(), element.getSize(), Thread.currentThread().getName()); System.out.println(info); shipsCounter++; } else { System.out.println(store.size() + "> There is no place for a ship in the tunnel: " + Thread.currentThread().getName()); wait(); return false; } } catch (InterruptedException e) { e.printStackTrace(); } return true; } public synchronized Ship get(Type shipType) { try { if (shipsCounter > minShipsInTunel) { notifyAll(); for (Ship ship : store) { if (ship.getType() == shipType) { shipsCounter--; System.out.println(store.size() + "- The ship is taken from the tunnel: " + Thread.currentThread().getName()); store.remove(ship); return ship; } } } System.out.println("0 < There are no ships in the tunnel"); wait(); } catch (InterruptedException e) { e.printStackTrace(); } return null; } 

 public class ShipGenerator implements Runnable { private Tunnel tunnel; private int shipCount; public ShipGenerator(Tunnel tunnel, int shipCount) { this.tunnel = tunnel; this.shipCount = shipCount; } @Override public void run() { int count = 0; while (count < shipCount) { Thread.currentThread().setName(" Generator ship"); count++; tunnel.add(new Ship(getRandomSize(), getRandomType())); try { Thread.sleep(1000); } catch (InterruptedException e) { e.printStackTrace(); } } } private Type getRandomType() { Random random = new Random(); return Type.values()[random.nextInt(Type.values().length)]; } private Size getRandomSize() { Random random = new Random(); return Size.values()[random.nextInt(Size.values().length)]; } } 

 public class PierLoader implements Runnable { private Tunnel tunnel; private Type shipType; public PierLoader(Tunnel tunnel, Type shipType) { this.tunnel = tunnel; this.shipType =shipType; } @Override public void run() { while (true) { try { Thread.currentThread().setName("Loader "+shipType); //Time to load the goods Thread.sleep(500); Ship ship = tunnel.get(shipType); if(ship!=null) while (ship.countCheck()){ Thread.sleep(100); ship.add(10); System.out.println(ship.getCount() + " Loaded ship. " + Thread.currentThread().getName()); } } catch (InterruptedException e) { e.printStackTrace(); } } } } 

 public class Main { public static void main(String[] args) { System.out.println("Available number of cores: " + Runtime.getRuntime().availableProcessors()); Tunnel tunnel = new Tunnel(); ShipGenerator shipGenerator = new ShipGenerator(tunnel, 10); PierLoader pierLoader1 = new PierLoader(tunnel, Type.DRESS); PierLoader pierLoader2 = new PierLoader(tunnel, Type.BANANA); PierLoader pierLoader3 = new PierLoader(tunnel, Type.MEAL); ExecutorService service = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors()); service.execute(shipGenerator); service.execute(pierLoader1); service.execute(pierLoader2); service.execute(pierLoader3); service.shutdown(); } }