线程锁装饰器

mutex.py

import thread
import time


lock = thread.allocate_lock()


def mutex(func):

    def wrapper(*arg, **kwargs):
        global lock
        lock.acquire()
        r = func(*arg, **kwargs)
        lock.release()
        return r

    return wrapper


@mutex
def worker(t):
    print 'worker begin', t
    time.sleep(t)
    print 'worker finish', t



thread.start_new_thread(worker, (5, ))
thread.start_new_thread(worker, (4, ))
thread.start_new_thread(worker, (3, ))


while True:
    pass