init

Author: Pyrokines17

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

@@ -0,0 +1,31 @@
+package ru.nsu.gunko.topic9.task1;
+
+public class CommonRes {
+    private int thread;
+    private int string;
+
+    public CommonRes() {
+        thread = 1;
+        string = 1;
+    }
+
+    public int getString() {
+        return string;
+    }
+
+    public int getThread() {
+        return thread;
+    }
+
+    public void addString() {
+        ++string;
+    }
+
+    public void addThread() {
+        ++thread;
+    }
+
+    public void begThread() {
+        thread = 1;
+    }
+}

training/topic9/src/main/java/ru/nsu/gunko/topic9/task1/Handler.java

@@ -0,0 +1,29 @@
+package ru.nsu.gunko.topic9.task1;
+
+public class Handler implements Runnable {
+    private final Printer printer;
+    private final CommonRes commonRes;
+    private final int M;
+
+    public Handler(int M, Printer printer, CommonRes commonRes) {
+        this.printer = printer;
+        this.commonRes = commonRes;
+        this.M = M;
+    }
+
+    @Override
+    public void run() {
+        String name = Thread.currentThread().getName();
+        int numThread = Integer.parseInt(name.substring(name.length()-1));
+        int i = 0;
+
+        while (i < M) {
+            if (numThread == commonRes.getThread()) {
+                printer.print(numThread);
+                ++i;
+            } else {
+                printer.myWait();
+            }
+        }
+    }
+}

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

@@ -0,0 +1,18 @@
+package ru.nsu.gunko.topic9.task1;
+
+import java.util.concurrent.*;
+
+public class Main {
+    public static void main(String[] args) {
+        int N = Integer.parseInt(args[0]),
+                M = Integer.parseInt(args[1]);
+        CommonRes commonRes = new CommonRes();
+        Printer printer = new Printer(N, commonRes);
+
+        try (ExecutorService service = Executors.newCachedThreadPool()) {
+            for (int i = 0; i < N; ++i) {
+                service.execute(new Handler(M, printer, commonRes));
+            }
+        }
+    }
+}

training/topic9/src/main/java/ru/nsu/gunko/topic9/task1/Printer.java

@@ -0,0 +1,34 @@
+package ru.nsu.gunko.topic9.task1;
+
+public class Printer {
+    private final CommonRes commonRes;
+    private final int N;
+
+    public Printer(int N, CommonRes commonRes) {
+        this.commonRes = commonRes;
+        this.N = N;
+    }
+
+    public synchronized void print(int numThread) {
+        System.out.println(numThread+"-"+commonRes.getString());
+
+        synchronized (commonRes) {
+            if (numThread == N) {
+                commonRes.begThread();
+                commonRes.addString();
+            } else {
+                commonRes.addThread();
+            }
+        }
+
+        notifyAll();
+    }
+
+    public synchronized void myWait() {
+        try {
+            wait(100);
+        } catch (InterruptedException e) {
+            throw new RuntimeException(e);
+        }
+    }
+}