Python多線程正確用法實例解析
python 里有一個 threading 模塊,其中提供了一個函數(shù):
threading.Thread(target=function, args=(), kwargs={})
function 是開發(fā)者定義的線程函數(shù),
args 是傳遞給線程函數(shù)的參數(shù),必須是tuple類型,
kwargs 是可選參數(shù),字典類型。
調(diào)用 threading.Thread 之后,會創(chuàng)建一個新的線程,參數(shù) target 指定線程將要運行的函數(shù),args 和 kwargs 則指定函數(shù)的參數(shù)來執(zhí)行
function 函數(shù)。
改寫一下前面的代碼,將抓取的部分放在一個函數(shù)中:
def get_weather(city): req = requests.get('http://wthrcdn.etouch.cn/weather_mini?city=%s' % city) dic_city = req.json() city_data = dic_city.get('data') # 沒有'data‘的話返回 [] print(city_data.get('city')) if city_data: city_forecast = city_data['forecast'][0] # 下面的都可以換成'get'方法 print(city_forecast.get('date')) print(city_forecast.get('high')) print(city_forecast.get('low')) print(city_forecast.get('type')) else: print('未獲得') print()
之后,程序采用了三個循環(huán),在第一個循環(huán)中,針對每一個城市,都創(chuàng)建了一個新線程,并將線程加入到一個列表中,用于之后的啟動。
threads = [] cities = ['北京', '南京', '上海', '深圳', '廣州', '杭州', '蘇州', '天津', '西安', '成都'] files = range(len(cities))for i in files: # 創(chuàng)建線程 t = threading.Thread(target=get_weather, args=(cities[i],)) threads.append(t)
在第二個循環(huán)中,start 正式開啟子線程;
for i in files: threads[i].start()
在第三個循環(huán)中,join 用來同步數(shù)據(jù),主線程運行到這一步,將會停下來等待子線程運行完畢。沒有這句,主線程則會忽略子線程,運行
完自己的代碼后結(jié)束程序。
for i in files: threads[i].join()
以上就是本文的全部內(nèi)容,希望對大家的學習有所幫助,也希望大家多多支持腳本之家。
相關文章
利用Opencv中Houghline方法實現(xiàn)直線檢測
這篇文章主要為大家詳細介紹了利用Opencv中的Houghline方法進行直線檢測,文中示例代碼介紹的非常詳細,具有一定的參考價值,感興趣的小伙伴們可以參考一下2018-02-02Python3.6實現(xiàn)連接mysql或mariadb的方法分析
這篇文章主要介紹了Python3.6實現(xiàn)連接mysql或mariadb的方法,結(jié)合實例形式分析了Python3.6針對mysql或mariadb數(shù)據(jù)庫操作的相關模塊安裝、數(shù)據(jù)庫與表的創(chuàng)建、數(shù)據(jù)庫連接等操作技巧與注意事項,需要的朋友可以參考下2018-05-05Python中讓MySQL查詢結(jié)果返回字典類型的方法
這篇文章主要介紹了Python中讓MySQL查詢結(jié)果返回字典類型的方法,默認情況下Mysql返回的是元組類型,本文實現(xiàn)了返回字典類型,需要的朋友可以參考下2014-08-08