The notify() method of the Condition class in Python

# Example Python program that uses the notify() method 
# of Condition object to notify the other threads waiting 
# on the same condition object
import threading as th
import time
import collections as coll

# A deque. It is filled by the producer
# thread and emptied by consumer threads
jobQueue = coll.deque(maxlen = 10)

# Target function for the producer thread
def produce(cv):
    global jobQueue
    while(len(jobQueue) <= 0):
        cv.acquire()
        for i in range(1, jobQueue.maxlen + 1):
            jobQueue.append("Job:%d"%i)
        cv.notify(2)
        cv.release()
        print("Producer has notified the consumers")
        # Give some time for consumers to act upon
        # If the sleep time is less producer terminates
        # after one round of production 
        # and other means are required to keep the
        # while loop running
        time.sleep(.01) 
    print("Producer quiting")

# Target function for the consumer thread
def consume(start_pos, end_pos, cv):
    global jobQueue

    while(True):
        cv.acquire()
        cv.wait()
        for i in range(start_pos, end_pos):
            job = jobQueue.pop()
            tid = th.get_ident()
            print("time:%s thread_id:%s job_id:%s"%(time.time(), tid, job))

        cv.release()

# Create the lock object
lock = th.Lock()

# Create the condition object 
cvar = th.Condition(lock)

# Create the producer thread
pThread     = th.Thread(target = produce, args = (cvar,))

start     = 0
end     = jobQueue.maxlen/2 

# Create the consumer threads
cThread1     = th.Thread(target = consume, args = (int(start), int(end), cvar))

start     = start + end 
end     = jobQueue.maxlen
cThread2     = th.Thread(target = consume, args = (int(start), int(end), cvar))

# Start all the threads
cThread1.start()
cThread2.start()
pThread.start()

# Wait for child threads to complete
pThread.join()
cThread1.join()
cThread2.join()