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)。如有錯誤或未考慮完全的地方，望不吝賜教。