init

Author: Pyrokines17

training/topic8/.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/topic8/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.topic8.task1</groupId>
+    <artifactId>topic8</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/topic8/src/main/java/ru/nsu/gunko/topic8/task1/Check.java

@@ -0,0 +1,15 @@
+package ru.nsu.gunko.topic8.task1;
+
+import java.util.List;
+import java.util.concurrent.Future;
+
+public class Check {
+    public static boolean start(List<Future<?>> futures) {
+        for (Future<?> future : futures) {
+            if (!future.isDone()) {
+                return true;
+            }
+        }
+        return false;
+    }
+}

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

@@ -0,0 +1,33 @@
+package ru.nsu.gunko.topic8.task1;
+
+import java.util.concurrent.BlockingDeque;
+
+public class Consumer implements Runnable {
+    private final BlockingDeque<String> storage;
+
+    Consumer(BlockingDeque<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/topic8/src/main/java/ru/nsu/gunko/topic8/task1/Main.java

@@ -0,0 +1,40 @@
+package ru.nsu.gunko.topic8.task1;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.concurrent.*;
+
+public class Main {
+    public static void main(String[] args) {
+        int count = Integer.parseInt(args[0]);
+        BlockingDeque<String> storage = new LinkedBlockingDeque<>(count);
+
+        int countP = Integer.parseInt(args[1]);
+        int countC = Integer.parseInt(args[2]);
+
+        Producer p = new Producer(storage);
+        Consumer c = new Consumer(storage);
+
+        List<Future<?>> futures = new ArrayList<>();
+
+        try (ExecutorService service = Executors.newCachedThreadPool()) {
+            for (int i = 0; i < countP; ++i) {
+                futures.add(service.submit(p));
+            }
+
+            for (int i = 0; i < countC; ++i) {
+                futures.add(service.submit(c));
+            }
+
+            synchronized (Thread.currentThread()) {
+                Thread.currentThread().wait(1000);
+            }
+
+            if (Check.start(futures)) {
+                service.shutdownNow();
+            }
+        } catch (InterruptedException ex) {
+            System.err.println(ex.getLocalizedMessage());
+        }
+    }
+}

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

@@ -0,0 +1,30 @@
+package ru.nsu.gunko.topic8.task1;
+
+import java.util.concurrent.BlockingDeque;
+
+public class Producer implements Runnable {
+    private final BlockingDeque<String> storage;
+    private int count;
+
+    Producer(BlockingDeque<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;
+    }
+}
+