add lifesafety labs

Author: NF-coder

life_safety/sem2/БЖД_расчет_меню_лаб4.pdf

@@ -1,10 +1,9 @@
-import client.ClientCycle;
 import server.ServerCycle;
 
 public class Main {
     public static void main(String[] args) {
         ServerCycle cycle = new ServerCycle();
-        Thread thread = new Thread(cycle);
-        thread.start();
+        Thread thread1 = new Thread(cycle);
+        thread1.start();
     }
 }

life_safety/sem2/БЖД_управление_страхом_лаб5.pdf

@@ -1,27 +1,37 @@
 package server.core;
 
+import server.core.promise.FinalizedPromises;
+import server.storage.StorageCycle;
 import server.core.promise.Promise;
-import server.core.promise.mappers.ToPromise;
 import server.network.NetworkDTO;
 import server.network.NetworkManager;
 import server.network.drivers.UDPDriver;
-
-import java.util.function.Function;
+import server.storage.control.IStorageController;
+import server.storage.control.Queue;
 
 public class Engine {
     private final NetworkManager network;
+    private final IStorageController SAC;
+    private final FinalizedPromises finalizedPromises;
 
     public Engine(){
         UDPDriver driver = new UDPDriver(4055);
         this.network = new NetworkManager(driver);
+        this.finalizedPromises = new FinalizedPromises();
+        this.SAC = new Queue(this.finalizedPromises);
+
+        Thread thread2 = new Thread(
+                new StorageCycle(this.SAC)
+        );
+        thread2.start();
     }
 
     public void mainCycle(){
         try{
-            Function<NetworkDTO, Promise> conv1 = ToPromise::fromNetworkDTO;
-            Promise p1 = conv1.apply(this.network.recive());
-            System.out.println(p1);
-
+            NetworkDTO in = this.network.recive();
+            System.out.println(in);
+            Promise p1 = SAC.add(in.opName(), in.args());
+            System.out.println("eng: " + p1);
         }
         catch (Exception e){
 

life_safety/sem2/Лабораторная работа Расчет меню 23(1).docx

@@ -0,0 +1,20 @@
+package server.core.promise;
+
+import java.util.ArrayDeque;
+import java.util.Deque;
+
+public class FinalizedPromises {
+    Deque<Promise> finishedOperations = new ArrayDeque<>();
+
+    public void add(Promise promise){
+        this.finishedOperations.addLast(promise);
+    }
+
+    public Promise get(){
+        return finishedOperations.pollFirst();
+    }
+
+    public boolean isEmpty(){
+        return finishedOperations.isEmpty();
+    }
+}

life_safety/sem2/Отчет к лаб.работе_Страх_2023(1).docx

@@ -8,10 +8,12 @@ public class Promise{
     private final HashMap<String,String> args;
     private HashMap<String,String> result = new HashMap<>();
     private String errorDescription;
+    private final FinalizedPromises finalizedPromises;
 
-    public Promise(String opName, HashMap<String,String> args){
+    public Promise(String opName, HashMap<String,String> args, FinalizedPromises finalizedPromises){
         this.opName = opName;
         this.args = args;
+        this.finalizedPromises = finalizedPromises;
     }
 
     public String getOperationName(){
@@ -29,6 +31,7 @@ public HashMap<String, String> getResult(){
     public void setResult(HashMap<String,String> result){
         this.result = result;
         this.status = PromiseStatus.FINISHED;
+        this.finalizedPromises.add(this);
     }
 
     public String getError(){
@@ -37,6 +40,7 @@ public String getError(){
     public void setError(String descr){
         this.errorDescription = descr;
         this.status = PromiseStatus.ERROR;
+        this.finalizedPromises.add(this);
     }
 
     public Enum<PromiseStatus> getStatus(){

programming/sem2/lab5_v2/src/Main.java

@@ -0,0 +1,17 @@
+package server.storage;
+
+import server.storage.control.IStorageController;
+import server.storage.drivers.DequeDriver;
+
+public class StorageCycle implements Runnable {
+    private final StructureDaemon sd;
+
+    public StorageCycle(IStorageController queue){
+        this.sd = new StructureDaemon(queue, new StructureManager(new DequeDriver()));
+        System.out.println("controller setted");
+    }
+    public void run(){
+        System.out.println("storage cycle started");
+        this.sd.mainCycle();
+    }
+}