Python 線程（四）：Semphore同步

Semphore，是一種帶計數的線程同步機制，當調用release時，增加計算，當acquire時，減少計數，當計數為0時，自動阻塞，等待release被調用。

而在Python中存在兩種Semphore，一種就是純粹的Semphore，還有一種就是BoundedSemaphore。

區別：

Semphore:  在調用release()函數時，不會檢查，增加的計數是否超過上限（沒有上限，會一直上升）

BoundedSemaphore：在調用release()函數時，會檢查，增加的計數是否超過上限，這樣就保證了使用的計數

代碼：

import threading
import time

semaphore = threading.Semaphore(3)
#semaphore = threading.BoundedSemaphore(3)

def fun():
    print "Thread %s is waiting semphore\n" % threading.currentThread().getName()
    semaphore.acquire()
    print "Thread %s get semphore\n" % threading.currentThread().getName()
    time.sleep(1)
    print "Thread %s release semphore\n" % threading.currentThread().getName()
    semaphore.release()


if __name__ == "__main__":
    t1 = threading.Thread(target=fun)
    t2 = threading.Thread(target=fun)
    t3 = threading.Thread(target=fun)
    t4 = threading.Thread(target=fun)

    t1.start()
    t2.start()
    t3.start()
    t4.start()

    t1.join()
    t2.join()
    t3.join()
    t4.join()

    semaphore.release()  #這里因為是簡單的Semaphore,所以可以再次釋放，不會報錯，而BoundedSemaphore，則會報錯