Untitled

mail@pastecode.io avatar
unknown
plain_text
10 days ago
756 B
2
Indexable
Never
from threading import Thread, Condition
import logging
from time import sleep

def worker(condition: Condition):
    logging.debug('Worker ready to work')
    with condition:
        condition.wait()
        logging.debug('Worker started to work')

def chief(condition: Condition):
    logging.debug('Im the boss')
    with condition:
        logging.debug('Im sending guys to work')
        condition.notify_all()

logging.basicConfig(level=logging.DEBUG, format='%(threadName)s %(message)s')
cond = Condition()

our_chief = Thread(target=chief, args=(cond,))
worker1 = Thread(target=worker, args=(cond,))
worker2 = Thread(target=worker, args=(cond,))

worker1.start()
worker2.start()
our_chief.start()

logging.debug('The end')
Leave a Comment