From 36aa4dcd815e1fc31ee8bbacb17519c0f5dafeff Mon Sep 17 00:00:00 2001
From: Olexander Kucherenko <amarokthegrey@gmail.com>
Date: Wed, 15 Apr 2026 20:02:25 +0300
Subject: [PATCH] Add thread-safe BlockingQueue with wait/notify support

---
 .../java/core/basesyntax/BlockingQueue.java   | 20 ++++++++++++++-----
 1 file changed, 15 insertions(+), 5 deletions(-)

diff --git a/src/main/java/core/basesyntax/BlockingQueue.java b/src/main/java/core/basesyntax/BlockingQueue.java
index 77a20440..959f25ba 100644
--- a/src/main/java/core/basesyntax/BlockingQueue.java
+++ b/src/main/java/core/basesyntax/BlockingQueue.java
@@ -12,16 +12,26 @@ public BlockingQueue(int 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();
     }
 }