成人在线亚洲_国产日韩视频一区二区三区_久久久国产精品_99国内精品久久久久久久

您的位置:首頁技術(shù)文章
文章詳情頁

python 實現(xiàn)多線程的三種方法總結(jié)

瀏覽:2日期:2022-06-21 13:24:04
1._thread.start_new_thread(了解)

import threadingimport timeimport _threaddef job(): print('這是一個需要執(zhí)行的任務(wù)。。。。。') print('當(dāng)前線程的個數(shù):', threading.active_count() ) print('當(dāng)前線程的信息:', threading.current_thread()) time.sleep(100)if __name__ == ’__main__’: # 創(chuàng)建多線程時, 需要制定該線程執(zhí)行的任務(wù) _thread.start_new_thread(job, ()) _thread.start_new_thread(job, ()) job()2.threading.Thread

import threadingimport timedef job(): print('這是一個需要執(zhí)行的任務(wù)。。。。。') print('當(dāng)前線程的個數(shù):', threading.active_count() ) time.sleep(1) print('當(dāng)前線程的信息:', threading.current_thread())if __name__ == ’__main__’: # 創(chuàng)建多線程時, 需要制定該線程執(zhí)行的任務(wù).name線程名字 target目標(biāo)函數(shù)名 t1 = threading.Thread(target=job,name=’job1’) t2 = threading.Thread(target=job,name=’job2’) t1.start() t2.start() print(threading.active_count()) print('程序執(zhí)行結(jié)束.....')

輸出:

這是一個需要執(zhí)行的任務(wù)。。。。。

當(dāng)前線程的個數(shù): 3

這是一個需要執(zhí)行的任務(wù)。。。。。

3

程序執(zhí)行結(jié)束.....

當(dāng)前線程的個數(shù): 3

當(dāng)前線程的信息: <Thread(job1, started 140416648140544)>

當(dāng)前線程的信息: <Thread(job2, started 140416639747840)>

出現(xiàn)的問題: 主線程執(zhí)行結(jié)束, 但是子線程還在運行。

join()方法可以等待所有的子線程執(zhí)行結(jié)束之后, 再執(zhí)行主線程。

import threadingimport timedef job(): print('這是一個需要執(zhí)行的任務(wù)。。。。。') print('當(dāng)前線程的個數(shù):', threading.active_count() ) print('當(dāng)前線程的信息:', threading.current_thread()) time.sleep(1)if __name__ == ’__main__’: # 創(chuàng)建多線程時, 需要制定該線程執(zhí)行的任務(wù).name線程名字 target目標(biāo)函數(shù)名 t1 = threading.Thread(target=job,name=’job1’) t2 = threading.Thread(target=job,name=’job2’) t1.start() t2.start() print(threading.active_count()) # 出現(xiàn)的問題: 主線程執(zhí)行結(jié)束, 但是子線程還在運行。 # 等待所有的子線程執(zhí)行結(jié)束之后, 再執(zhí)行主線程 t1.join() t2.join() print('程序執(zhí)行結(jié)束.....')

python 實現(xiàn)多線程的三種方法總結(jié)

之前寫過一個簡單爬蟲的實驗,現(xiàn)在希望獲取十個ip的城市和國家

-不使用多線程

import timefrom urllib.request import urlopen# 記錄時間的裝飾器def timeit(f): def wrapper(*args, **kwargs):start_time = time.time()res = f(*args, **kwargs)end_time = time.time()print('%s函數(shù)運行時間:%.2f' % (f.__name__, end_time - start_time))return res return wrapperdef get_addr(ip): url = 'http://ip-api.com/json/%s' % (ip) urlObj = urlopen(url) # 服務(wù)端返回的頁面信息, 此處為字符串類型 pageContent = urlObj.read().decode(’utf-8’) # 2. 處理Json數(shù)據(jù) import json # 解碼: 將json數(shù)據(jù)格式解碼為python可以識別的對象; dict_data = json.loads(pageContent) print('''%s 所在城市: %s 所在國家: %s''' % (ip, dict_data[’city’], dict_data[’country’]))@timeitdef main(): ips = [’12.13.14.%s’ % (i + 1) for i in range(10)] for ip in ips:get_addr(ip)if __name__ == ’__main__’: main()

python 實現(xiàn)多線程的三種方法總結(jié)

時間需要138.91秒。

-使用多線程

import threadingimport timefrom urllib.request import urlopendef timeit(f): def wrapper(*args, **kwargs):start_time = time.time()res = f(*args, **kwargs)end_time = time.time()print('%s函數(shù)運行時間:%.2f' % (f.__name__, end_time - start_time))return res return wrapperdef get_addr(ip): url = 'http://ip-api.com/json/%s' % (ip) urlObj = urlopen(url) # 服務(wù)端返回的頁面信息, 此處為字符串類型 pageContent = urlObj.read().decode(’utf-8’) # 2. 處理Json數(shù)據(jù) import json # 解碼: 將json數(shù)據(jù)格式解碼為python可以識別的對象; dict_data = json.loads(pageContent) print('''%s 所在城市: %s 所在國家: %s''' % (ip, dict_data[’city’], dict_data[’country’]))@timeitdef main(): ips = [’12.13.14.%s’ % (i + 1) for i in range(10)] threads = [] for ip in ips:# 實例化10個對象,target=目標(biāo)函數(shù)名,args=目標(biāo)函數(shù)參數(shù)(元組格式)t = threading.Thread(target=get_addr, args=(ip, ))threads.append(t)t.start()# 等待所有子線程結(jié)束再運行主線程 [thread.join() for thread in threads]if __name__ == ’__main__’: main()

python 實現(xiàn)多線程的三種方法總結(jié) python 實現(xiàn)多線程的三種方法總結(jié)

3.重寫run方法

重寫run方法, 實現(xiàn)多線程, 因為start方法執(zhí)行時, 調(diào)用的是run方法;run方法里面編寫的內(nèi)容就是你要執(zhí)行的任務(wù);

import threadingimport time# 重寫一個類,繼承于threading.Threadclass MyThread(threading.Thread): def __init__(self, jobName):super(MyThread, self).__init__()self.jobName = jobName # 重寫run方法, 實現(xiàn)多線程, 因為start方法執(zhí)行時, 調(diào)用的是run方法; # run方法里面編寫的內(nèi)容就是你要執(zhí)行的任務(wù); def run(self):print('這是一個需要執(zhí)行的任務(wù)%s。。。。。' %(self.jobName))print('當(dāng)前線程的個數(shù):', threading.active_count() )time.sleep(1)print('當(dāng)前線程的信息:', threading.current_thread())if __name__ == ’__main__’: t1 = MyThread('name1') t2 = MyThread('name2') t1.start() t2.start() t1.join() t2.join() print('程序執(zhí)行結(jié)束.....')

重寫run方法實現(xiàn)剛才爬蟲多線程案例

import threadingimport timefrom urllib.request import urlopendef timeit(f): def wrapper(*args, **kwargs):start_time = time.time()res = f(*args, **kwargs)end_time = time.time()print('%s函數(shù)運行時間:%.2f' % (f.__name__, end_time - start_time))return res return wrapperclass MyThread(threading.Thread): def __init__(self, ip):super(MyThread, self).__init__()self.ip = ip def run(self):url = 'http://ip-api.com/json/%s' % (self.ip)urlObj = urlopen(url)# 服務(wù)端返回的頁面信息, 此處為字符串類型pageContent = urlObj.read().decode(’utf-8’)# 2. 處理Json數(shù)據(jù)import json# 解碼: 將json數(shù)據(jù)格式解碼為python可以識別的對象;dict_data = json.loads(pageContent)print(''' %s所在城市: %s所在國家: %s''' % (self.ip, dict_data[’city’], dict_data[’country’]))@timeitdef main(): ips = [’12.13.14.%s’ % (i + 1) for i in range(10)] threads = [] for ip in ips:# 實例化自己重寫的類t = MyThread(ip)threads.append(t)t.start() [thread.join() for thread in threads]if __name__ == ’__main__’: main()

以上為個人經(jīng)驗,希望能給大家一個參考,也希望大家多多支持好吧啦網(wǎng)。如有錯誤或未考慮完全的地方,望不吝賜教。

標(biāo)簽: Python 編程
相關(guān)文章: