一 python 多線(xiàn)程

因?yàn)镃Python的實(shí)現(xiàn)使用了Global Interpereter Lock(GIL)，使得python中同一時(shí)刻只有一個(gè)線(xiàn)程在執(zhí)行，從而簡(jiǎn)化了python解釋器的實(shí)現(xiàn)，且python對(duì)象模型天然地線(xiàn)程安全。如果你想你的應(yīng)用程序在多核的機(jī)器上使用更好的資源，建議使用multiprocessing或concurrent.futures.processpoolexecutor。但是如果你的程序是IO密集型，則使用線(xiàn)程仍然是很好的選擇。

二 python 多線(xiàn)程使用的兩種方法

實(shí)例：

import?threading

import?time

def?worker(num):

print?(threading.currentThread().getName()?+?'start')

time.sleep(10)

print?(threading.currentThread().getName()?+?'running')

print?(threading.currentThread().getName()?+?""?+?str(num))

print?(threading.currentThread().getName()?+?'exit')

def?deamon():

print?(threading.currentThread().getName()?+?'start')

time.sleep(20)

print?(threading.currentThread().getName()?+?'running')

print?(threading.currentThread().getName()?+?'exit')

print(threading.currentThread().getName())

d?=?threading.Thread(name='deamon',?target=deamon)

d.setDaemon(True)

d.start()

w?=?threading.Thread(name='worker',?target=worker,?args=(10,))

w.start()

class?myWorker(threading.Thread):

def?__init__(self,?num):

threading.Thread.__init__(self)

self.num?=?num

self.thread_stop?=?False

def?run(self):

print?(self.getName()+'start')

time.sleep(30)

print?(self.getName()+'running')

print?(self.getName()+""?+?str(self.num))

print?(self.getName()+'exit')

mw?=?myWorker(30)

mw.setName("MyWorker")

mw.start()

print(threading.currentThread().getName())

print("All?threads:")

print("------------")

for?th?in?threading.enumerate():

print(th.getName())

print("------------")

d.join()

w.join()

mw.join()

print(threading.currentThread().getName())

運(yùn)行結(jié)果如下：

1)python線(xiàn)程使用的兩種方法：

**直接調(diào)用threading.Thread來(lái)構(gòu)造thread對(duì)象，Thread的參數(shù)如下：

class threading.Thread(group=None, target=None, name=None, args=(), kwargs={})

group為None；

target為線(xiàn)程將要執(zhí)行的功能函數(shù)；

name為線(xiàn)程的名字，也可以在對(duì)象構(gòu)造后調(diào)用setName()來(lái)設(shè)定；

args為tuple類(lèi)型的參數(shù)，可以為多個(gè)，如果只有一個(gè)也的使用tuple的形式傳入，例如(1,)；

kwargs為dict類(lèi)型的參數(shù)，也即位命名參數(shù)；

**實(shí)現(xiàn)自己的threading.Thread的子類(lèi)，需要重載__init__()和run()。

2)threading.Thread對(duì)象的其他方法：

start()，用來(lái)啟動(dòng)線(xiàn)程；

join(), 等待直到線(xiàn)程結(jié)束；

setDeamon(), 設(shè)置線(xiàn)程為deamon線(xiàn)程，必須在start()調(diào)用前調(diào)用，默認(rèn)為非demon。

注意： python的主線(xiàn)程在沒(méi)有非deamon線(xiàn)程存在時(shí)就會(huì)退出。

3)threading的靜態(tài)方法:

threading.current_thread() , 用來(lái)獲得當(dāng)前的線(xiàn)程；

threading.enumerate() ， 用來(lái)多的當(dāng)前存活的所有線(xiàn)程；

threading.Timer 定時(shí)器，其實(shí)是thread的一個(gè)字類(lèi)型，使用如下：

def hello(): print("hello, world")

t = Timer(30.0, hello)

t.start()

4)logging是線(xiàn)程安全的

logging 模塊是線(xiàn)程安全的，所以可以使用logging來(lái)幫助調(diào)試多線(xiàn)程程序。

import logging

logging.basicConfig(level=logging.DEBUG,

format="(%(threadName)-10s : %(message)s",

)

logging.debug("wait_for_event_timeout starting")

完！

總結(jié)

以上是生活随笔為你收集整理的python 线程 的类库_python类库32[多线程]的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。