init task1

Author: Pyrokines17

training/topic7/.gitignore

@@ -0,0 +1,38 @@
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**/target/
+!**/src/test/**/target/
+
+### IntelliJ IDEA ###
+.idea/modules.xml
+.idea/jarRepositories.xml
+.idea/compiler.xml
+.idea/libraries/
+*.iws
+*.iml
+*.ipr
+
+### Eclipse ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+!**/src/main/**/build/
+!**/src/test/**/build/
+
+### VS Code ###
+.vscode/
+
+### Mac OS ###
+.DS_Store

training/topic7/pom.xml

@@ -0,0 +1,17 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <groupId>ru.nsu.gunko.topic7.task1</groupId>
+    <artifactId>topic7</artifactId>
+    <version>1.0-SNAPSHOT</version>
+
+    <properties>
+        <maven.compiler.source>21</maven.compiler.source>
+        <maven.compiler.target>21</maven.compiler.target>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+    </properties>
+
+</project>

training/topic7/src/main/java/ru/nsu/gunko/topic7/task1/Consumer.java

@@ -0,0 +1,31 @@
+package ru.nsu.gunko.topic7.task1;
+
+public class Consumer implements Runnable {
+    private final Storage<String> storage;
+
+    Consumer(Storage<String> s) {
+        storage = s;
+    }
+
+    public void run() {
+        try {
+            while (true) {
+                consume(storage.take());
+                synchronized (Thread.currentThread()) {
+                    try {
+                        Thread.currentThread().wait(75);
+                    } catch (InterruptedException ex) {
+                        System.err.println(ex.getLocalizedMessage());
+                    }
+                }
+            }
+        } catch (InterruptedException ex) {
+            System.err.println(ex.getLocalizedMessage());
+        }
+    }
+
+    void consume(Object x) {
+        String name = Thread.currentThread().getName();
+        System.out.println("c" + name.substring(name.length()-1) + " consumes " + x);
+    }
+}

training/topic7/src/main/java/ru/nsu/gunko/topic7/task1/Main.java

@@ -0,0 +1,21 @@
+package ru.nsu.gunko.topic7.task1;
+
+public class Main {
+    public static void main(String[] args) {
+        Storage<String> storage = new Storage<>(Integer.parseInt(args[0]));
+
+        int countP = Integer.parseInt(args[1]);
+        int countC = Integer.parseInt(args[2]);
+
+        Producer p = new Producer(storage);
+        Consumer c = new Consumer(storage);
+
+        for (int i = 0; i < countP; ++i) {
+            new Thread(p).start();
+        }
+
+        for (int i = 0; i < countC; ++i) {
+            new Thread(c).start();
+        }
+    }
+}

training/topic7/src/main/java/ru/nsu/gunko/topic7/task1/Producer.java

@@ -0,0 +1,28 @@
+package ru.nsu.gunko.topic7.task1;
+
+public class Producer implements Runnable {
+    private final Storage<String> storage;
+    private int count;
+
+    Producer(Storage<String> s) {
+        storage = s;
+        count = 1;
+    }
+
+    public void run() {
+        try {
+            while (true) {
+                storage.put(produce());
+                ++count;
+            }
+        } catch (InterruptedException ex) {
+            System.err.println(ex.getLocalizedMessage());
+        }
+    }
+
+    String produce() {
+        String name = Thread.currentThread().getName();
+        return "p" + name.substring(name.length()-1) + "-" + count;
+    }
+}
+

training/topic7/src/main/java/ru/nsu/gunko/topic7/task1/Storage.java

@@ -0,0 +1,34 @@
+package ru.nsu.gunko.topic7.task1;
+
+import java.util.*;
+
+public class Storage<T> {
+    List<T> box;
+    int count;
+
+    Storage(int count) {
+        this.count = count;
+        box = new ArrayList<>();
+    }
+
+    synchronized public void put(T obj) throws InterruptedException {
+        while (box.size() == count) {
+            wait();
+        }
+
+        box.add(obj);
+        notifyAll();
+    }
+
+    synchronized public T take() throws InterruptedException {
+        while (box.isEmpty()) {
+            wait();
+        }
+
+        T obj = box.getLast();
+        box.removeLast();
+        notifyAll();
+
+        return obj;
+    }
+}