Python執行緒整理

巴扎黑
發布: 2016-12-09 14:11:47
原創
1483 人瀏覽過

執行緒有五種狀態 

新建、就緒、運作、阻塞、死亡。

阻塞有三種情況: 

同步阻塞是指處於競爭鎖定的狀態,執行緒請求鎖定時將進入此狀態,一旦成功獲得鎖定又恢復到運作狀態;

等待阻塞是指等待其他執行緒通知的狀態,執行緒獲得條件鎖定後,呼叫「等待」將進入這個狀態,一旦其他執行緒發出通知,執行緒將進入同步阻塞狀態,再次競爭條件鎖定;

而其他阻塞是指呼叫time.sleep()、anotherthread .join()或等待IO時的阻塞,這個狀態下執行緒不會釋放已獲得的鎖定。



python提供了兩種使用執行緒的方式,一種是函數式的,一種是類別包裝的。 

   * thread 
   * threading 

1、thread: 

>>> import thread
>>> dir(thread)
['LockType', '__doc__', '__name__', '__package__', '_count', '_local', 'allocate', 'allocate_lock', 'error', 'exit', 'exit_thread', 'get_ident', 'interrupt_main', 'stack_size', 'start_new', 'start_new_thread']
登入後複製

thread.start_new_thread ( function thread 
   * threading 

1、thread: 

>>> import threading
>>> dir(threading)
['BoundedSemaphore', 'Condition', 'Event', 'Lock', 'RLock', 'Semaphore', 'Thread', 'ThreadError', 'Timer', '_BoundedSemaphore', '_Condition', '_DummyThread', '_Event', '_MainThread', '_RLock', '_Semaphore', '_Timer', '_VERBOSE', '_Verbose', '__all__', '__builtins__', '__doc__', '__file__', '__name__', '__package__', '_active', '_active_limbo_lock', '_after_fork', '_allocate_lock', '_counter', '_enumerate', '_format_exc', '_get_ident', '_limbo', '_newname', '_pickSomeNonDaemonThread', '_profile_hook', '_shutdown', '_sleep', '_start_new_thread', '_sys', '_test', '_time', '_trace_hook', 'activeCount', 'active_count', 'currentThread', 'current_thread', 'deque', 'enumerate', 'local', 'setprofile', 'settrace', 'stack_size', 'warnings']
登入後複製

thread.start_new_thread ( function , 200,reee
thread.start_new_thread ( function , args [ ,reee

的函數 

2、threading: 

>>> dir(threading.Thread)
['_Thread__bootstrap', '_Thread__bootstrap_inner', '_Thread__delete', '_Thread__exc_clear', '_Thread__exc_info', '_Thread__initialized', '_Thread__stop', '__class__', '__delattr__', '__dict__', '__doc__', '__format__', '__getattribute__', '__hash__', '__init__', '__module__', '__new__', '__reduce__', '__reduce_ex__', '__repr__', '__setattr__', '__sizeof__', '__str__', '__subclasshook__', '__weakref__', '_block', '_note', '_reset_internal_locks', '_set_daemon', '_set_ident', 'daemon', 'getName', 'ident', 'isAlive', 'isDaemon', 'is_alive', 'join', 'name', 'run', 'setDaemon', 'setName', 'start']
登入後複製
rrreeethreading 模組提供的常用方法: 

threading.currentThread(): 傳回目前的執行緒變數。

threading.enumerate(): 傳回一個包含正在執行的執行緒的list。正在執行指執行緒啟動後、結束前,不包含啟動前和終止後的執行緒。

threading.activeCount(): 傳回正在執行的執行緒數量,與len(threading.enumerate())有相同的結果。



繼承threading.Thread方法,重寫run方法。

threading.Thread類別的初始化函數原型:def __init__(self, group=None, target=None, name=None, args=(), kwargs={}) 
  參數groupgroup是預留的,用於將來擴展將來擴展; 
  參數target是一個可呼叫物件(也稱為活動[activity]),在執行緒啟動後執行; 
  參數name是執行緒的名字。預設值為“Thread-N“,N是一個數字。 
  參數args和kwargs分別表示呼叫target時的參數清單和關鍵字參數。 


join()方法,呼叫該方法的執行緒將等待直到該Thread物件完成,然後再恢復執行。 
呼叫Thread.join將會使主調執行緒堵塞,直到被呼叫執行緒執行結束或逾時。參數timeout是一個數值類型,表示逾時時間,如果未提供該參數,那麼主調線程將一直阻塞到被調線程結束。 

threading.Lock物件:mutex,有acquire()和release()方法 

RLock允許在同一線程中被多次acquire。而Lock卻不允許這種情況。注意:如果使用RLock,那麼acquire和release必須成對出現,即調用了n次acquire,必須調用n次的release才能真正釋放所佔用的瑣。 

threading.Condition物件:condition variable,建立該物件時,會包含一個Lock物件(因為condition variable總是和mutex一起使用)。可以對Condition物件呼叫acquire()和release()方法,以控制潛在的Lock物件。 

Condition.wait([timeout]):  wait方法釋放內部所佔用的瑣,同時執行緒被掛起,直到接收到通知被喚醒或逾時(如果提供了timeout參數的話)。當執行緒被喚醒並重新佔有瑣的時候,程式才會繼續執行下去。

Condition.notify():  喚醒一個掛起的執行緒(如果有掛起的執行緒)。注意:notify()方法不會釋放所佔用的瑣。


Condition.notifyAll()  喚醒所有掛起的執行緒(如果存在掛起的執行緒)。注意:這些方法不會釋放所佔用的瑣。

🎜🎜🎜🎜🎜🎜
相關標籤:
來源:php.cn
本網站聲明
本文內容由網友自願投稿,版權歸原作者所有。本站不承擔相應的法律責任。如發現涉嫌抄襲或侵權的內容,請聯絡admin@php.cn
熱門教學
更多>
最新下載
更多>
網站特效
網站源碼
網站素材
前端模板