Python3 threading的多線程管理中的線程管理與鎖

　　提到Python的多線程，大家都說雞肋。至於為什么，一定又要說什么“GIL的全稱是Global Interpreter Lock(全局解釋器鎖)”之類的解釋了，哥書讀的少，聽不太懂，反正能讓我們這種村里人看到同時跑了幾個就行，至於什么多線程多進程，CPU是並行還是並發的，都隨他去吧。

　　今天主要說一下threading模塊的進程鎖與進程管理內容。

　　用threading有幾次，都是簡單的有兩個或者三個任務需要並發執行，比如服務器的主備等等，不用管它鎖不鎖的。但這次想用於管理幾百個任務的依次並發，不得不看看了。

先說下threading.lock()

　　由於存在多個進程共同去修改某個數據的問題，所以必須要用到lock()

　　這東西比較簡單，lock.acquire()用於添加鎖，lock.release() 用於釋放鎖。太簡單就不舉例子了。

重點說下threading.Semaphore

　　Semaphore 在內部存在一個計數器，在用戶調用 acquire() 時，計數器 -1，release() 則+1

舉個例子說明下吧，剛好用下下午的簡單測試代碼：

from selenium import webdriver
import threading
import time
import random


def first_test(url):
    sem.acquire()  # 注意要第一時間去修改計數器 這點很重要
    firsttest = webdriver.Chrome()
    try:
        firsttest.get(url)  # 發送get請求
        time.sleep(random.randint(0, 50))  # 為了看清變化 random設置的比較大
    except Exception as ErrorInfo:
        print(ErrorInfo)
    finally:
        sem.release()
        firsttest.close()  # 關閉谷歌瀏覽器


if __name__ == '__main__':
    url = 'http://www.cnblogs.com/Dracular/p/8365989.html'
    sem = threading.Semaphore(3) # 設置線程閥值
    for i in range(10):
        t = threading.Thread(target=first_test, args=(url,))
        t.start()
        time.sleep(0.1)

    while threading.active_count() != 1:
        pass  # print threading.active_count()
    else:
        print('### Selenium Jobs is over!!!###')

由於為了保證計數器的不為負(因為變成負數，就相當於阻塞了哦....)，最好使用finally，來進行release()的修改....

好了，點滴積累......