Python3多執行緒threading
阿新 • • 發佈:2019-07-28
執行緒的呼叫方式
直接呼叫
import threading import time def sayhi(num): #定義每個執行緒要執行的函式 print("running on number:%s" %num) time.sleep(3) if __name__ == '__main__': t1 = threading.Thread(target=sayhi,args=(1,)) #生成一個執行緒例項 t2 = threading.Thread(target=sayhi,args=(2,)) #生成另一個執行緒例項 t1.start() #啟動執行緒 t2.start() #啟動另一個執行緒 print(t1.getName()) #獲取執行緒名 print(t2.getName())
繼承式呼叫
import threading import time class MyThread(threading.Thread): def __init__(self,num): threading.Thread.__init__(self) self.num = num def run(self):#定義每個執行緒要執行的函式 print("running on number:%s" %self.num) time.sleep(3) if __name__ == '__main__': t1 = MyThread(1) t2 = MyThread(2) t1.start() t2.start()
執行緒相關的其他方法
Thread例項物件的方法
- isAlive(): 返回執行緒是否活動的。
- getName(): 返回執行緒名。
- setName(): 設定執行緒名。
threading模組提供的一些方法:
- threading.currentThread(): 返回當前的執行緒變數。 - threading.enumerate(): 返回一個包含正在執行的執行緒的list。正在執行指執行緒啟動後、結束前,不包括啟動前和終止後的執行緒。 - threading.activeCount(): 返回正在執行的執行緒數量,與len(threading.enumerate())有相同的結果。
from threading import Thread
import threading
from multiprocessing import Process
import os
def work():
import time
time.sleep(3)
print(threading.current_thread().getName())
if __name__ == '__main__':
#在主程序下開啟執行緒
t=Thread(target=work)
t.start()
print(threading.current_thread().getName())
print(threading.current_thread()) #主執行緒
print(threading.enumerate()) #連同主執行緒在內有兩個執行的執行緒
print(threading.active_count())
print('主執行緒/主程序')
'''
列印結果:
MainThread
<_MainThread(MainThread, started 140735268892672)>
[<_MainThread(MainThread, started 140735268892672)>, <Thread(Thread-1, started 123145307557888)>]
主執行緒/主程序
Thread-1
'''
join
主執行緒等待子執行緒結束
from threading import Thread
import time
def sayhi(name):
time.sleep(2)
print('%s say hello' %name)
if __name__ == '__main__':
t=Thread(target=sayhi,args=('egon',))
t.start()
t.join()
print('主執行緒')
print(t.is_alive())
'''
egon say hello
主執行緒
False
'''
守護執行緒
無論是程序還是執行緒,都遵循:守護xxx會等待主xxx執行完畢後被銷燬
- 對主程序來說,執行完畢指的是主程序程式碼執行完畢
- 對主執行緒來說,執行完畢指的是主執行緒所在的程序內所有非守護執行緒統統執行完畢,主執行緒才算執行完畢
from threading import Thread
import time
def foo():
print(123)
time.sleep(1)
print("end123")
def bar():
print(456)
time.sleep(3)
print("end456")
t1=Thread(target=foo)
t2=Thread(target=bar)
t1.daemon=True
t1.start()
t2.start()
print("main---