# -*- encoding:utf-8 -*- ''' Created on Sep 18, 2012 @author: root write by wye in cloudiya ''' import threading import time data = 0 lock = threading.Lock() def func(): global data print "%s acquire lock...." % threading.currentThread().getName() #调用acquire([timeout])时,线程将一直阻塞,直到获得锁定或者直到timeout秒后(timeout参数可选) if lock.acquire(): print "%s get the lock." % threading.currentThread().getName() data += 1 print data time.sleep(4) print "%s release lock ..." % threading.currentThread().getName() #调用release()将释放锁 lock.release() t1 = threading.Thread(target=func) t2 = threading.Thread(target=func) t3 = threading.Thread(target=func) t1.start() t2.start() t3.start() print data