python 實現(xiàn)多線程的三種方法總結(jié)
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é)束.....')
之前寫過一個簡單爬蟲的實驗,現(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()
時間需要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()
重寫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)。如有錯誤或未考慮完全的地方,望不吝賜教。
相關(guān)文章:
1. XML入門的常見問題(三)2. XML基本概念XPath、XSLT與XQuery函數(shù)介紹3. WML的簡單例子及編輯、測試方法第1/2頁4. el-input無法輸入的問題和表單驗證失敗問題解決5. 關(guān)于html嵌入xml數(shù)據(jù)島如何穿過樹形結(jié)構(gòu)關(guān)系的問題6. CSS3實例分享之多重背景的實現(xiàn)(Multiple backgrounds)7. 不要在HTML中濫用div8. vue實現(xiàn)復(fù)制文字復(fù)制圖片實例詳解9. XML入門的常見問題(四)10. 前端html+css實現(xiàn)動態(tài)生日快樂代碼
