threads synchronization

gistfile1.py

from async import async

from time import sleep


class ThreadSyncer(object):
    def __init__(self, threads_amount):
        self.amount = threads_amount
        self.finished_count = 0

    def thread_ended(self):
        self.finished_count += 1

    def wait_for_threads(self, callback):
        while self.finished_count < self.amount:
            continue
        callback()
syncer = ThreadSyncer(2)

@async(callback=syncer.thread_ended, errback=syncer.thread_ended)
def my_first_function():
    sleep(5)

@async(callback=syncer.thread_ended, errback=syncer.thread_ended)
def my_other_function():
    sleep(3)

def last_function():
    print "Finished"

my_first_function()
my_other_function()
syncer.wait_for_threads(last_function)