pub_sub_example.py

from threading import Thread


q = []
running = True


def publish(thing):
    print('publishing: {}'.format(thing))
    q.append(thing)


def consumer():
    global q
    global running

    while running:
        if len(q) > 0:
            print("consuming: {}".format(q.pop(0)))


if __name__ == '__main__':
    t = None
    try:
        t = Thread(target=consumer)
        t.start()

    except KeyboardInterrupt:
        global running
        running = False