Minimal two-thread synchronization example in Python

synch_test.py

import time
import random
from threading import Thread
from multiprocessing.pool import ThreadPool

def print_ten(c):
    for i in range(10):
        time.sleep(0.1)
        print(c, end="", flush=True)
    print("")

def erratic_job(c):
    while True:
        time.sleep(2*random.random())
        print_ten(c)

def synch_erratic_job(tpe, c):
    while True:
        time.sleep(2*random.random())
        tpe.apply(print_ten, (c,))


def forever_dequeue(q):
    while True:
        tup = q.get()
        f = tup[0]
        args = tup[1]
        f(*args)

def unsynchronized_run():
    threadA = Thread(target = erratic_job, args=('a',))
    threadB = Thread(target = erratic_job, args=('b',))
    threadA.start()
    threadB.start()

def synchronized_run():
    tpe = ThreadPool(processes=1)
    threadA = Thread(target = synch_erratic_job, args=(tpe, 'a',))
    threadB = Thread(target = synch_erratic_job, args=(tpe, 'b',))
    threadA.start()
    threadB.start()


# unsynchronized_run()
# synchronized_run()