From 6d524f0d1f303da144e14cce21ecd332bca4e8fa Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=D0=94=D0=B0=D0=BD=D0=B8=D0=B8=D0=BB=20=D0=9A=D0=B0=D0=BB?=
 =?UTF-8?q?=D0=B0=D1=88=D0=BD=D0=B8=D0=BA=D0=BE=D0=B2?=
 <ddkalashnikov@edu.hse.ru>
Date: Sat, 14 Mar 2026 13:26:38 +0300
Subject: [PATCH] queue: first

---
 .../tasks/queue/BoundedBlockingQueue.java     | 42 ++++++++++++++++---
 1 file changed, 37 insertions(+), 5 deletions(-)

diff --git a/src/main/java/hse/java/lectures/lecture6/tasks/queue/BoundedBlockingQueue.java b/src/main/java/hse/java/lectures/lecture6/tasks/queue/BoundedBlockingQueue.java
index 5c686cff..e5de52ae 100644
--- a/src/main/java/hse/java/lectures/lecture6/tasks/queue/BoundedBlockingQueue.java
+++ b/src/main/java/hse/java/lectures/lecture6/tasks/queue/BoundedBlockingQueue.java
@@ -1,25 +1,57 @@
 package hse.java.lectures.lecture6.tasks.queue;
 
+import java.util.LinkedList;
+
 public class BoundedBlockingQueue<T> {
+    final Integer capacity ;
+    LinkedList<T> list;
+    Object monitor ;
 
 
     public BoundedBlockingQueue(int capacity) {
+        if ( capacity <= 0 ) {
+            throw new IllegalArgumentException() ;
+        }
+        this.capacity = capacity;
+        list = new LinkedList<>();
+        monitor = new Object();
+
 
     }
 
-    public void put(T item) {
+    public void put(T item) throws InterruptedException {
+        if ( item == null) throw new IllegalArgumentException() ;
+
+
+        synchronized (monitor) {
+            while ( capacity ==  list.size()) {
+                monitor.wait();
+            }
+            list.add(item) ;
+            monitor.notifyAll();
+        }
 
     }
 
-    public T take() {
-        return null;
+    public T take() throws InterruptedException {
+        synchronized (monitor) {
+            while (list.isEmpty()) {
+                monitor.wait();
+            }
+            T res  = list.removeFirst();
+            monitor.notifyAll();
+            return  res;
+        }
     }
 
     public int size() {
-        return 0;
+        synchronized (monitor) {
+            return list.size();
+        }
     }
 
     public int capacity() {
-        return 0;
+        return capacity;
+
     }
 }