python 實現多線程的三種方法總結

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

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

輸出：

這是一個需要執行的任務。。。。。

當前線程的個數: 3

這是一個需要執行的任務。。。。。

3

程序執行結束.....

當前線程的個數: 3

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

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

出現的問題: 主線程執行結束， 但是子線程還在運行。

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

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

之前寫過一個簡單爬蟲的實驗，現在希望獲取十個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函數運行時間:%.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) # 服務端返回的頁面信息, 此處為字符串類型 pageContent = urlObj.read().decode(’utf-8’) # 2. 處理Json數據 import json # 解碼: 將json數據格式解碼為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函數運行時間:%.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) # 服務端返回的頁面信息, 此處為字符串類型 pageContent = urlObj.read().decode(’utf-8’) # 2. 處理Json數據 import json # 解碼: 將json數據格式解碼為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=目標函數名，args=目標函數參數(元組格式)t = threading.Thread(target=get_addr, args=(ip, ))threads.append(t)t.start()# 等待所有子線程結束再運行主線程 [thread.join() for thread in threads]if __name__ == ’__main__’: main()

重寫run方法， 實現多線程， 因為start方法執行時， 調用的是run方法;run方法里面編寫的內容就是你要執行的任務；

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

重寫run方法實現剛才爬蟲多線程案例

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函數運行時間:%.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)# 服務端返回的頁面信息, 此處為字符串類型pageContent = urlObj.read().decode(’utf-8’)# 2. 處理Json數據import json# 解碼: 將json數據格式解碼為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()

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