Lab02

.gitignore

@@ -0,0 +1,3 @@
+**.idea
+**/out
+**.iml

lab-02/.gitignore

@@ -0,0 +1 @@
+/logs

lab-02/lab-02.iml

@@ -0,0 +1,32 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<module type="JAVA_MODULE" version="4">
+  <component name="NewModuleRootManager" inherit-compiler-output="true">
+    <exclude-output />
+    <content url="file://$MODULE_DIR$">
+      <sourceFolder url="file://$MODULE_DIR$/by/waitingsolong/docks_and_hobos" isTestSource="false" />
+      <sourceFolder url="file://$MODULE_DIR$/resources" type="java-resource" />
+      <sourceFolder url="file://$MODULE_DIR$/src" isTestSource="false" />
+      <excludeFolder url="file://$MODULE_DIR$/.idea" />
+    </content>
+    <orderEntry type="inheritedJdk" />
+    <orderEntry type="sourceFolder" forTests="false" />
+    <orderEntry type="module-library">
+      <library>
+        <CLASSES>
+          <root url="jar://$MODULE_DIR$/../../../java/lib/apache-log4j-2.22.0-bin/log4j-core-2.22.0.jar!/" />
+        </CLASSES>
+        <JAVADOC />
+        <SOURCES />
+      </library>
+    </orderEntry>
+    <orderEntry type="module-library">
+      <library>
+        <CLASSES>
+          <root url="jar://$MODULE_DIR$/../../../java/lib/apache-log4j-2.22.0-bin/log4j-api-2.22.0.jar!/" />
+        </CLASSES>
+        <JAVADOC />
+        <SOURCES />
+      </library>
+    </orderEntry>
+  </component>
+</module>

lab-02/log_example/README.txt

@@ -0,0 +1,2 @@
+Логи работают странно, в самом начале вставляют какой-то сценарий из буффера.
+Настоящие начинаются со слов "Start of program"

lab-02/resources/config.json

@@ -0,0 +1,20 @@
+{
+  "generating_time" : 3,
+  "ship_capacity_min" : 10,
+  "ship_capacity_max" : 100,
+  "cargo_types" : [
+    "CHEMICAL",
+    "FOOD",
+    "WEAPON",
+    "RAW_MATERIALS",
+    "SLAVES"
+  ],
+  "max_ships" : 3,
+  "unloading_speed" : 10,
+  "dock_capacity" : 50,
+  "hobos" : 4,
+  "ingredients_count" : [2, 2, 3],
+  "stealing_time" : 2,
+  "crimes_per_day" : 3,
+  "cooking_time": 10
+}

lab-02/resources/log4j2.xml

@@ -0,0 +1,20 @@
+<Configuration status="WARN">
+    <Appenders>
+        <Console name="Console" target="SYSTEM_OUT">
+            <PatternLayout pattern="%d{HH:mm:ss.SSS} [%t] %-5level %c{1} - %msg%n"/>
+        </Console>
+        <RollingFile name="RollingFile" fileName="logs/0.log" filePattern="logs/log-%d{yyyy-MM-dd-HH-mm}-n%i.log">
+            <PatternLayout pattern="%d{yyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %c{1} - %msg%n"/>
+            <Policies>
+                <TimeBasedTriggeringPolicy interval="1" modulate="true"/>
+            </Policies>
+            <DefaultRolloverStrategy max="10"/>
+        </RollingFile>
+    </Appenders>
+    <Loggers>
+        <Root level="info">
+            <AppenderRef ref="Console"/>
+            <AppenderRef ref="RollingFile"/>
+        </Root>
+    </Loggers>
+</Configuration>

lab-02/resources/names.txt

@@ -0,0 +1,4 @@
+Sviatoslav Dobrojir Tihomir Ratibor Dobrinya Tishilo
+Naum Bogdan Borislav Dobrojir Zvenislav Yaropolk
+Svetozar Mirolyub Bogomil Vsemysl Dobrovlad
+Kazimir Luchezar Milomir Unislav Snovid Jidobor

lab-02/src/by/waitingsolong/docks_and_hobos/Dock.java

@@ -0,0 +1,100 @@
+package by.waitingsolong.docks_and_hobos;
+
+import by.waitingsolong.docks_and_hobos.helpers.CargoType;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
+
+import java.util.Map;
+import java.util.Optional;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.locks.ReentrantLock;
+
+public class Dock implements Runnable {
+    private static final Logger logger = LogManager.getLogger(Dock.class);
+    private final int unloading_speed;
+    private final int dock_capacity;
+    private volatile Map<CargoType, Integer> storage = new ConcurrentHashMap<>();
+    private final Tunnel tunnel;
+    private final long recallDelay;
+    private final Thread thread;
+    public Dock(int unloadingSpeed, int dockCapacity, Tunnel tunnel, long recallDelay) {
+        this.unloading_speed = unloadingSpeed;
+        this.dock_capacity = dockCapacity;
+        this.tunnel = tunnel;
+        this.thread = new Thread(this);
+        this.recallDelay = recallDelay;
+        for (CargoType cargoType : CargoType.values()) {
+            storage.put(cargoType, 0);
+        }
+    }
+
+    @Override
+    public void run() {
+        while (!thread.isInterrupted()) {
+            logger.info("Dock calls");
+            Optional<Ship> call = tunnel.call();
+            if (call.isPresent()) {
+                logger.info("There is a response");
+                processShip(call.get());
+            } else {
+                logger.info("There is no response, wait a little...");
+                try {
+                    Thread.sleep(recallDelay * 1000);
+                } catch (InterruptedException e) {
+                    logger.error("Dock is interrupted during sleep", e);
+                    return;
+                }
+            }
+        }
+    }
+
+
+    public void processShip(Ship ship) {
+        logger.info("Dock ready for ship unloading");
+        ReentrantLock wakeUpLock = ship.getWakeUpLock();
+        wakeUpLock.lock();
+
+        logger.info("Ship " + ship.getName() + " entered the dock");
+        synchronized (ship) {
+            unload(ship);
+
+            logger.info("Ship " + ship.getName() + " leaves the dock");
+            ship.notify();
+        }
+    }
+
+    private void unload(Ship ship) {
+        CargoType cargoType = ship.getCargoType();
+
+        logger.info("Ship " + ship.getName() + " with " + cargoType.getName() + " is unloading...");
+        while (true) {
+            int unloaded = ship.unload(unloading_speed);
+            if (unloaded == 0) {
+                return;
+            }
+
+            int become  = storage.get(cargoType) + unloaded;
+            if (become < dock_capacity) {
+                storage.put(cargoType, become);
+            } else {
+                storage.put(cargoType, dock_capacity);
+                logger.info(cargoType.getName() + " storage is full");
+                return;
+            }
+
+            Thread.yield();
+
+            logger.info("The ship " + ship.getName() + " is unloading...");
+            try {
+                Thread.sleep(recallDelay * 1000);
+            } catch(InterruptedException e) {
+                logger.error("Unloading of ship is interrupted");
+                Thread.currentThread().interrupt();
+            }
+        }
+    }
+
+    public void start() {
+        thread.start();
+    }
+}