diff --git a/src/main/java/core/basesyntax/BlockingQueue.java b/src/main/java/core/basesyntax/BlockingQueue.java
index 77a20440..136dceea 100644
--- a/src/main/java/core/basesyntax/BlockingQueue.java
+++ b/src/main/java/core/basesyntax/BlockingQueue.java
@@ -12,16 +12,33 @@ public BlockingQueue(int capacity) {
     }
 
     public synchronized void put(T element) throws InterruptedException {
-        // write your code here
+        while (isFull()) {
+            wait();
+        }
+        if (queue.add(element)) {
+            notifyAll();
+        }
+    }
+
+    private synchronized boolean isFull() {
+        return queue.size() == capacity;
     }
 
     public synchronized T take() throws InterruptedException {
-        // write your code here
-        return null;
+        while (isEmpty()) {
+            wait();
+        }
+
+        T result = queue.poll();
+
+        if (queue.isEmpty()) {
+            notifyAll();
+        }
+        return result;
     }
 
     public synchronized boolean isEmpty() {
-        // write your code here
-        return true;
+        return queue.isEmpty();
     }
+
 }