How to Use a Bounded Buffer with threading.Condition in Python

import threading
import time
import random

class BoundedBuffer:
    def __init__(self, capacity):
        self.capacity = capacity
        self.buffer = []
        self.condition = threading.Condition()

    def put(self, item):
        with self.condition:
            while len(self.buffer) >= self.capacity:
                self.condition.wait()
            self.buffer.append(item)
            print(f"Produced {item}, buffer={self.buffer}")
            self.condition.notify_all()

    def get(self):
        with self.condition:
            while not self.buffer:
                self.condition.wait()
            item = self.buffer.pop(0)
            print(f"Consumed {item}, buffer={self.buffer}")
            self.condition.notify_all()
            return item

def producer(buffer, items):
    for i in range(items):
        buffer.put(i)
        time.sleep(random.uniform(0.1, 0.3))

def consumer(buffer, items):
    for _ in range(items):
        buffer.get()
        time.sleep(random.uniform(0.1, 0.3))

if __name__ == "__main__":
    buffer = BoundedBuffer(capacity=3)
    threads = [
        threading.Thread(target=producer, args=(buffer, 5)),
        threading.Thread(target=consumer, args=(buffer, 5))
    ]
    for t in threads:
        t.start()
    for t in threads:
        t.join()
    print("All done")