From 437f40b5d93a1762b7253a704540069531900e93 Mon Sep 17 00:00:00 2001
From: Feruz Gofurov <gofurovferuz123@gmail.com>
Date: Mon, 13 Oct 2025 15:41:39 +0500
Subject: [PATCH 1/2] added

---
 .idea/misc.xml      |  6 ++++
 .idea/workspace.xml | 69 +++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 75 insertions(+)
 create mode 100644 .idea/misc.xml
 create mode 100644 .idea/workspace.xml

diff --git a/.idea/misc.xml b/.idea/misc.xml
new file mode 100644
index 0000000..639900d
--- /dev/null
+++ b/.idea/misc.xml
@@ -0,0 +1,6 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="ProjectRootManager">
+    <output url="file://$PROJECT_DIR$/out" />
+  </component>
+</project>
\ No newline at end of file
diff --git a/.idea/workspace.xml b/.idea/workspace.xml
new file mode 100644
index 0000000..36099c1
--- /dev/null
+++ b/.idea/workspace.xml
@@ -0,0 +1,69 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project version="4">
+  <component name="AutoImportSettings">
+    <option name="autoReloadType" value="SELECTIVE" />
+  </component>
+  <component name="ChangeListManager">
+    <list default="true" id="337c6ce9-e8ed-4d95-b364-55effd56cf34" name="Changes" comment="">
+      <change beforePath="$PROJECT_DIR$/Flight/flightInfo.txt" beforeDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/main/java/lessons/lesson06/ReservationSystem.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/lessons/lesson06/ReservationSystem.java" afterDir="false" />
+      <change beforePath="$PROJECT_DIR$/src/main/java/lessons/lesson06/ReserveMain.java" beforeDir="false" afterPath="$PROJECT_DIR$/src/main/java/lessons/lesson06/ReserveMain.java" afterDir="false" />
+    </list>
+    <option name="SHOW_DIALOG" value="false" />
+    <option name="HIGHLIGHT_CONFLICTS" value="true" />
+    <option name="HIGHLIGHT_NON_ACTIVE_CHANGELIST" value="false" />
+    <option name="LAST_RESOLUTION" value="IGNORE" />
+  </component>
+  <component name="ExternalProjectsData">
+    <projectState path="$PROJECT_DIR$">
+      <ProjectState />
+    </projectState>
+  </component>
+  <component name="ExternalProjectsManager">
+    <system id="GRADLE">
+      <state>
+        <projects_view>
+          <tree_state>
+            <expand>
+              <path>
+                <item name="" type="6a2764b6:ExternalProjectsStructure$RootNode" />
+                <item name="java-course" type="f1a62948:ProjectNode" />
+              </path>
+            </expand>
+            <select />
+          </tree_state>
+        </projects_view>
+      </state>
+    </system>
+  </component>
+  <component name="Git.Settings">
+    <option name="RECENT_GIT_ROOT_PATH" value="$PROJECT_DIR$" />
+  </component>
+  <component name="ProjectColorInfo"><![CDATA[{
+  "associatedIndex": 5
+}]]></component>
+  <component name="ProjectId" id="33v9d9Ly4LUY5i5hyojkBY2aRpq" />
+  <component name="ProjectViewState">
+    <option name="hideEmptyMiddlePackages" value="true" />
+    <option name="showLibraryContents" value="true" />
+  </component>
+  <component name="PropertiesComponent"><![CDATA[{
+  "keyToString": {
+    "Gradle.java-course [:lessons.lesson06.ReserveMain.main()].executor": "Run",
+    "RunOnceActivity.ShowReadmeOnStart": "true",
+    "RunOnceActivity.git.unshallow": "true",
+    "git-widget-placeholder": "backup__all__lessons"
+  }
+}]]></component>
+  <component name="SpellCheckerSettings" RuntimeDictionaries="0" Folders="0" CustomDictionaries="0" DefaultDictionary="application-level" UseSingleDictionary="true" transferred="true" />
+  <component name="TaskManager">
+    <task active="true" id="Default" summary="Default task">
+      <changelist id="337c6ce9-e8ed-4d95-b364-55effd56cf34" name="Changes" comment="" />
+      <created>1760186764962</created>
+      <option name="number" value="Default" />
+      <option name="presentableId" value="Default" />
+      <updated>1760186764962</updated>
+    </task>
+    <servers />
+  </component>
+</project>
\ No newline at end of file

From 380b8adf1863c1b325964e57ef33c34cdb03a321 Mon Sep 17 00:00:00 2001
From: Feruz Gofurov <gofurovferuz123@gmail.com>
Date: Wed, 22 Oct 2025 14:20:11 +0500
Subject: [PATCH 2/2] Completed lesson11

---
 .../java/lessons/lesson11/task1/Main.java     | 15 ++++++
 .../lessons/lesson11/task1/Publisher.java     | 25 ++++++++++
 .../lessons/lesson11/task1/QueueMessage.java  | 24 +++++++++
 .../lessons/lesson11/task1/Subscriber.java    | 21 ++++++++
 .../java/lessons/lesson11/task2/Main.java     | 29 +++++++++++
 .../java/lessons/lesson11/task2/MyThread.java | 26 ++++++++++
 .../lesson11/task2/SimpleThreadPool.java      | 49 +++++++++++++++++++
 7 files changed, 189 insertions(+)
 create mode 100644 src/main/java/lessons/lesson11/task1/Main.java
 create mode 100644 src/main/java/lessons/lesson11/task1/Publisher.java
 create mode 100644 src/main/java/lessons/lesson11/task1/QueueMessage.java
 create mode 100644 src/main/java/lessons/lesson11/task1/Subscriber.java
 create mode 100644 src/main/java/lessons/lesson11/task2/Main.java
 create mode 100644 src/main/java/lessons/lesson11/task2/MyThread.java
 create mode 100644 src/main/java/lessons/lesson11/task2/SimpleThreadPool.java

diff --git a/src/main/java/lessons/lesson11/task1/Main.java b/src/main/java/lessons/lesson11/task1/Main.java
new file mode 100644
index 0000000..a9703f1
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task1/Main.java
@@ -0,0 +1,15 @@
+package lessons.lesson11.task1;
+
+public class Main {
+    public static void main(String[] args) {
+        QueueMessage queueMessage = new QueueMessage();
+        Publisher publisher = new Publisher(queueMessage);
+        Subscriber subscriber = new Subscriber(queueMessage);
+
+        Thread publisherThread = new Thread(publisher);
+        Thread subscriberThread = new Thread(subscriber);
+
+        publisherThread.start();
+        subscriberThread.start();
+    }
+}
diff --git a/src/main/java/lessons/lesson11/task1/Publisher.java b/src/main/java/lessons/lesson11/task1/Publisher.java
new file mode 100644
index 0000000..9f30c25
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task1/Publisher.java
@@ -0,0 +1,25 @@
+package lessons.lesson11.task1;
+
+import java.util.Scanner;
+
+public class Publisher implements Runnable {
+    private final QueueMessage queue;
+
+    public Publisher(QueueMessage queue) {
+        this.queue = queue;
+    }
+
+    @Override
+    public void run() {
+        Scanner scanner = new Scanner(System.in);
+        System.out.println("Input a word: (exit - to exit)");
+        while (true) {
+            String input = scanner.next();
+            queue.add(input);
+            if ("exit".equalsIgnoreCase(input)) {
+                break;
+            }
+        }
+        scanner.close();
+    }
+}
diff --git a/src/main/java/lessons/lesson11/task1/QueueMessage.java b/src/main/java/lessons/lesson11/task1/QueueMessage.java
new file mode 100644
index 0000000..89fcb44
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task1/QueueMessage.java
@@ -0,0 +1,24 @@
+package lessons.lesson11.task1;
+
+import java.util.LinkedList;
+import java.util.Queue;
+
+public class QueueMessage {
+    private final Queue<String> messages = new LinkedList<>();
+
+    public synchronized void add(String message) {
+        messages.add(message);
+        notify();
+    }
+
+    public synchronized String get() {
+        while (messages.isEmpty()) {
+            try {
+                wait();
+            } catch (Exception e) {
+                Thread.currentThread().interrupt();
+            }
+        }
+        return messages.poll();
+    }
+}
diff --git a/src/main/java/lessons/lesson11/task1/Subscriber.java b/src/main/java/lessons/lesson11/task1/Subscriber.java
new file mode 100644
index 0000000..a9add49
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task1/Subscriber.java
@@ -0,0 +1,21 @@
+package lessons.lesson11.task1;
+
+public class Subscriber implements Runnable {
+    private final QueueMessage queue;
+
+    public Subscriber(QueueMessage queue) {
+        this.queue = queue;
+    }
+
+    @Override
+    public void run() {
+        while (true) {
+            String message = queue.get();
+            if ("exit".equalsIgnoreCase(message)) {
+                System.out.println("Subscriber exited");
+                break;
+            }
+            System.out.println("Subscriber got:" + message + "\n");
+        }
+    }
+}
diff --git a/src/main/java/lessons/lesson11/task2/Main.java b/src/main/java/lessons/lesson11/task2/Main.java
new file mode 100644
index 0000000..ca30a59
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task2/Main.java
@@ -0,0 +1,29 @@
+package lessons.lesson11.task2;
+
+public class Main {
+    public static void main(String[] args) {
+        SimpleThreadPool pool = new SimpleThreadPool(4);
+
+        for (int i = 1; i <= 10; i++) {
+            int taskNum = i;
+            pool.submit(() -> {
+                System.out.println(Thread.currentThread().getName() + " task: " + taskNum);
+                try {
+                    Thread.sleep(500);
+                } catch (InterruptedException e) {
+                    Thread.currentThread().interrupt();
+                }
+            });
+        }
+
+        try {
+            Thread.sleep(3000);
+        } catch (InterruptedException e) {
+            Thread.currentThread().interrupt();
+        }
+
+        pool.shutdown();
+        System.out.println("Completing task...");
+    }
+}
+
diff --git a/src/main/java/lessons/lesson11/task2/MyThread.java b/src/main/java/lessons/lesson11/task2/MyThread.java
new file mode 100644
index 0000000..68e7f44
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task2/MyThread.java
@@ -0,0 +1,26 @@
+package lessons.lesson11.task2;
+
+public class MyThread extends Thread {
+    private SimpleThreadPool pool;
+
+    public MyThread(SimpleThreadPool pool, String name) {
+        super(name);
+        this.pool = pool;
+    }
+
+    @Override
+    public void run() {
+        while (true) {
+            Runnable task = pool.getTask();
+            if (task == null) {
+                break;
+            }
+            try {
+                task.run();
+            } catch (RuntimeException e) {
+                System.out.println(getName() + " error:" + e.getMessage());
+            }
+        }
+        System.out.println(getName() + " is finished.");
+    }
+}
diff --git a/src/main/java/lessons/lesson11/task2/SimpleThreadPool.java b/src/main/java/lessons/lesson11/task2/SimpleThreadPool.java
new file mode 100644
index 0000000..9f26e8d
--- /dev/null
+++ b/src/main/java/lessons/lesson11/task2/SimpleThreadPool.java
@@ -0,0 +1,49 @@
+package lessons.lesson11.task2;
+
+import java.util.LinkedList;
+import java.util.List;
+import java.util.Queue;
+
+public class SimpleThreadPool {
+    private final Queue<Runnable> tasks = new LinkedList<>();
+    private List<MyThread> threads = new LinkedList<>();
+    private volatile boolean isRunning = true;
+    private final int counter;
+
+    public SimpleThreadPool(int counter) {
+        this.counter = counter;
+        for (int i = 0; i < counter; i++) {
+            MyThread myThread = new MyThread(this, "Pull: " + (i + 1));
+            threads.add(myThread);
+            myThread.start();
+        }
+    }
+
+    public synchronized void submit(Runnable task) {
+        tasks.add(task);
+        notify();
+    }
+
+    public synchronized Runnable getTask() {
+        while (tasks.isEmpty()) {
+            if (!isRunning) {
+                return null;
+            }
+            try {
+                wait();
+            } catch (Exception e) {
+                Thread.currentThread().interrupt();
+                if (tasks.isEmpty() && !isRunning) {
+                    return null;
+                }
+            }
+        }
+        return tasks.poll();
+    }
+
+    public synchronized void shutdown() {
+        isRunning = false;
+        notifyAll();
+        System.out.println("All tasks submitted, shutting down pool...");
+    }
+}