多線程編程知識(shí)點(diǎn)記錄：
1袖订、單線程函數(shù)如何轉(zhuǎn)換為多線程
1)線程函數(shù)調(diào)用
import threading
import time
from threading import current_thread
def myThread(arg1, arg2):
print(current_thread().getName(),'start')
print('%s %s'%(arg1, arg2))
time.sleep(1)
print(current_thread().getName(),'stop')
for i in range(1,6,1):
# t1 = myThread(i, i+1)
t1 = threading.Thread(target=myThread,args=(i, i+1))#多線程分配
t1.start()
print(current_thread().getName(),'end')
2）線程類調(diào)用
import threading
from threading import current_thread
class Mythread(threading.Thread):
def run(self):
print(current_thread().getName(),'start')
print('run')
print(current_thread().getName(),'stop')
for i in range(1,6,1):
t1 = Mythread()
t1.start()
t1.join()
print(current_thread().getName(),'end')
問(wèn)題解答1:老師，我想不明白你重寫(xiě)這個(gè)run方法之后為什么這個(gè)線程還能夠執(zhí)行赋铝，之前是start函數(shù)調(diào)用原來(lái)這個(gè)run方法，你現(xiàn)在將它重寫(xiě)啦，重寫(xiě)不是覆蓋前面父類的方法嗎疫诽，您重寫(xiě)的run方法只是打印而已，怎么會(huì)執(zhí)行呢笼恰？
答：Thread是threading模塊的一個(gè)用于創(chuàng)建線程的類踊沸，創(chuàng)建線程有兩個(gè)方法，一個(gè)是通過(guò)繼承Thread類社证，重寫(xiě)run方法逼龟；我在視頻中演示的Mythread類就是這種方法了，要注意覆蓋的是父類繼承過(guò)來(lái)的run方法追葡，start還是繼承過(guò)來(lái)不變的腺律。這里要注意的是start()和run() 是Thread的兩種不同方法，官方定義在這里：https://docs.python.org/3.7/library/threading.html那么把他們的解釋翻譯成中文就是 start() 開(kāi)始線程工作宜肉，把run()方法放到一個(gè)另外的單獨(dú)的線程里執(zhí)行 匀钧；run() 線程工作方法，在“當(dāng)成”線程執(zhí)行函數(shù)里面的代碼谬返。所以他們的作用一個(gè)是開(kāi)啟新線程之斯，一個(gè)是按照線程的方式執(zhí)行程序。我們可以寫(xiě)個(gè)小程序來(lái)驗(yàn)證一下：
import threading
from threading import current_thread
class Mythread(threading.Thread):
def run(self):
print(current_thread().getName())
t1 = Mythread()
t1.run()
t1.start()
這段程序的執(zhí)行結(jié)果是：
MainThread
Thread-1
也就是說(shuō)單獨(dú)運(yùn)行run()方法遣铝，會(huì)把主進(jìn)程當(dāng)做一個(gè)線程來(lái)看佑刷，執(zhí)行的代碼空間在MainThread主線程中，執(zhí)行了start()方法酿炸，python會(huì)新創(chuàng)建一個(gè)線程瘫絮，叫Thread-1，然后再去調(diào)用run()來(lái)運(yùn)行填硕，這就是他們兩個(gè)的區(qū)別了麦萤。
問(wèn)題解答2：多線程不能無(wú)限多吧鹿鳖，應(yīng)該是看計(jì)算機(jī)的硬件性能。那么如何確定可以使用的最多線程壮莹？
答：最多線程由兩方面決定：內(nèi)存容量和軟件限制翅帜。雖然線程是輕量級(jí)進(jìn)程，但是創(chuàng)建線程也是要消耗內(nèi)存的垛孔，初始狀態(tài)下消耗大小就是內(nèi)存棧了藕甩，每創(chuàng)建一個(gè)線程為其分配一個(gè)線程棧，還有一種限制是系統(tǒng)的配置參數(shù)限制周荐，比如在linux上 每進(jìn)程默認(rèn)創(chuàng)建線程是1024個(gè)狭莱，在local_lim.h中定義，可以使用ulimt -a查看線程棧大小概作。
2腋妙、生產(chǎn)者和消費(fèi)者程序事例
from threading import Thread,current_thread
import time
import random
from queue import Queue
queue = Queue(5)
class ProducerThread(Thread):
def run(self):
name = current_thread().getName()
nums = range(100)
global queue
while True:
num = random.choice(nums)
queue.put(num)
print('生產(chǎn)者 %s 生產(chǎn)了數(shù)據(jù) %s' %(name, num))
t = random.randint(1,3)
time.sleep(t)
print('生產(chǎn)者 %s 睡眠了 %s 秒' %(name, t))
class ConsumerTheard(Thread):
def run(self):
name = current_thread().getName()
global queue
while True:
num = queue.get()
queue.task_done()
print('消費(fèi)者 %s 消耗了數(shù)據(jù) %s' %(name, num))
t = random.randint(1,5)
time.sleep(t)
print('消費(fèi)者 %s 睡眠了 %s 秒' % (name, t))
p1 = ProducerThread(name = 'p1')
p1.start()
p2 = ProducerThread(name = 'p2')
p2.start()
p3 = ProducerThread(name = 'p3')
p3.start()
c1 = ConsumerTheard(name = 'c1')
c1.start()
c2 = ConsumerTheard(name = 'c2')
c2.start()
問(wèn)題解答：消費(fèi)者的task_done()還是不清楚用來(lái)干什么？
答：task_done()是配合join()使用的讯榕，join() 會(huì)讓隊(duì)列一直處于阻塞狀態(tài)骤素，直到queue里面所有的message都被get()取出來(lái)調(diào)用了task_done()才能返回，不用這個(gè)函數(shù)會(huì)讓join()出現(xiàn)無(wú)限掛起的問(wèn)題愚屁，不符合我們寫(xiě)程序的預(yù)期济竹。它和join()一起使用來(lái)判斷隊(duì)列里是否還有message需要處理的一種機(jī)制，如果看它的代碼實(shí)現(xiàn)霎槐，會(huì)發(fā)現(xiàn)它通過(guò)信號(hào)與join()進(jìn)行配合的送浊。
或許在初學(xué)階段，大家更容易理解這種用法
while not workQueue.empty():
pass
就是一直循環(huán)丘跌，直到隊(duì)列為空袭景。
兩種機(jī)制都可以判斷為隊(duì)列是否為空，看你需要那種方法和想要在哪種場(chǎng)景下使用闭树。
