Semaphore for synchronization mechanism

semaphore.py

import random, time
from threading import BoundedSemaphore, Thread
max_items = 6
"""
Consider 'container' as a container, with a capacity of 6
items. Defaults to 1 item if 'max_items' is passed.
"""
container = BoundedSemaphore(max_items)
def producer(nloops):
    for i in range(nloops):
        time.sleep(random.randrange(2, 6))
        print(time.ctime(), end=": ")
        try:
            container.release()
            print("item Produce kar rha.")
        except ValueError:
            print("Full ho gya, skipping.")
def consumer(nloops):
    for i in range(nloops):
        time.sleep(random.randrange(2, 5))
        print(time.ctime(), end=": ")
        """
        In the following if statement we disable the default
        blocking behaviour by passing False for the blocking flag.
        """
        if container.acquire(False):
            print("item Consume kar rha.")
        else:
            print("Empty box, skipping.")
threads = []
nloops = random.randrange(3, 6)
print("Starting with %s items." % max_items)
threads.append(Thread(target=producer, args=(nloops,)))
threads.append(Thread(target=consumer, args=(random.randrange(nloops, nloops+max_items+2),)))
for thread in threads:  # Starts all the threads.
    thread.start()
for thread in threads:  # Waits for threads to complete before moving on with the main script.
    thread.join()
print("All operation done.")