From 9e54dd85ab0d41b2e6596fa0eb70d44cfefaa8ec Mon Sep 17 00:00:00 2001
From: Vitaliy <vitaliyufc@gmail.com>
Date: Tue, 31 Mar 2026 23:27:57 +0300
Subject: [PATCH 1/2] Done blocking-queue task

---
 pom.xml                                       | 10 +++++++
 .../java/core/basesyntax/BlockingQueue.java   | 28 ++++++++++++++-----
 .../java/core/basesyntax/thread/Consumer.java | 15 +++++++---
 .../java/core/basesyntax/thread/Producer.java |  2 +-
 4 files changed, 43 insertions(+), 12 deletions(-)

diff --git a/pom.xml b/pom.xml
index fb0e6d4d..687064a9 100644
--- a/pom.xml
+++ b/pom.xml
@@ -25,6 +25,16 @@
             <version>4.12</version>
             <scope>test</scope>
         </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-api</artifactId>
+            <version>2.22.1</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.logging.log4j</groupId>
+            <artifactId>log4j-core</artifactId>
+            <version>2.22.1</version>
+        </dependency>
     </dependencies>
     <build>
         <plugins>
diff --git a/src/main/java/core/basesyntax/BlockingQueue.java b/src/main/java/core/basesyntax/BlockingQueue.java
index 77a20440..7f0e73df 100644
--- a/src/main/java/core/basesyntax/BlockingQueue.java
+++ b/src/main/java/core/basesyntax/BlockingQueue.java
@@ -4,24 +4,38 @@
 import java.util.Queue;
 
 public class BlockingQueue<T> {
-    private Queue<T> queue = new LinkedList<>();
-    private int capacity;
+    private final Queue<T> queue = new LinkedList<>();
+    private final int capacity;
 
     public BlockingQueue(int capacity) {
         this.capacity = capacity;
     }
 
     public synchronized void put(T element) throws InterruptedException {
-        // write your code here
+
+        while (queue.size() == capacity) {
+            wait();
+        }
+
+        queue.add(element);
+
+        notifyAll();
     }
 
     public synchronized T take() throws InterruptedException {
-        // write your code here
-        return null;
+
+        while (queue.isEmpty()) {
+            wait();
+        }
+
+        T element = queue.poll();
+
+        notifyAll();
+        return element;
     }
 
     public synchronized boolean isEmpty() {
-        // write your code here
-        return true;
+
+        return queue.isEmpty();
     }
 }
diff --git a/src/main/java/core/basesyntax/thread/Consumer.java b/src/main/java/core/basesyntax/thread/Consumer.java
index a28994fa..148e1c6d 100644
--- a/src/main/java/core/basesyntax/thread/Consumer.java
+++ b/src/main/java/core/basesyntax/thread/Consumer.java
@@ -1,9 +1,13 @@
 package core.basesyntax.thread;
 
 import core.basesyntax.BlockingQueue;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 public class Consumer implements Runnable {
-    private BlockingQueue<Integer> blockingQueue;
+
+    private static final Logger logger = LogManager.getLogger(Consumer.class);
+    private final BlockingQueue<Integer> blockingQueue;
 
     public Consumer(BlockingQueue<Integer> blockingQueue) {
         this.blockingQueue = blockingQueue;
@@ -11,11 +15,14 @@ public Consumer(BlockingQueue<Integer> blockingQueue) {
 
     @Override
     public void run() {
-        while (!blockingQueue.isEmpty()) {
+        while (!Thread.currentThread().isInterrupted()) {
             try {
-                System.out.println("Took value " + blockingQueue.take());
+                Integer value = blockingQueue.take();
+                System.out.println("Took value " + value);
             } catch (InterruptedException e) {
-                throw new RuntimeException("Consumer was interrupted!", e);
+                Thread.currentThread().interrupt();
+                logger.warn("Thread was interrupted while taking from queue", e);
+                break;
             }
         }
     }
diff --git a/src/main/java/core/basesyntax/thread/Producer.java b/src/main/java/core/basesyntax/thread/Producer.java
index a08376ce..45fe07ce 100644
--- a/src/main/java/core/basesyntax/thread/Producer.java
+++ b/src/main/java/core/basesyntax/thread/Producer.java
@@ -3,7 +3,7 @@
 import core.basesyntax.BlockingQueue;
 
 public class Producer implements Runnable {
-    private BlockingQueue<Integer> blockingQueue;
+    private final BlockingQueue<Integer> blockingQueue;
 
     public Producer(BlockingQueue<Integer> blockingQueue) {
         this.blockingQueue = blockingQueue;

From efbd21b07f87f9d31f62e0f532a77b541330e490 Mon Sep 17 00:00:00 2001
From: Vitaliy <vitaliyufc@gmail.com>
Date: Tue, 31 Mar 2026 23:42:39 +0300
Subject: [PATCH 2/2] Fixed Producer.Class

---
 src/main/java/core/basesyntax/thread/Producer.java | 8 +++++++-
 1 file changed, 7 insertions(+), 1 deletion(-)

diff --git a/src/main/java/core/basesyntax/thread/Producer.java b/src/main/java/core/basesyntax/thread/Producer.java
index 45fe07ce..479a1ad2 100644
--- a/src/main/java/core/basesyntax/thread/Producer.java
+++ b/src/main/java/core/basesyntax/thread/Producer.java
@@ -1,8 +1,12 @@
 package core.basesyntax.thread;
 
 import core.basesyntax.BlockingQueue;
+import org.apache.logging.log4j.LogManager;
+import org.apache.logging.log4j.Logger;
 
 public class Producer implements Runnable {
+
+    private static final Logger logger = LogManager.getLogger(Consumer.class);
     private final BlockingQueue<Integer> blockingQueue;
 
     public Producer(BlockingQueue<Integer> blockingQueue) {
@@ -15,7 +19,9 @@ public void run() {
             try {
                 blockingQueue.put(i);
             } catch (InterruptedException e) {
-                throw new RuntimeException("Producer was interrupted!", e);
+                Thread.currentThread().interrupt();
+                logger.warn("Producer interrupted while putting value {}", i, e);
+                break;
             }
         }
     }