執行緒池submit和map的應用

執行緒池submit的應用

import time

def timeit(f):
start_time = time.time()
res = f(*args, **kwargs)
end_time = time.time()
return res
# python3.2版本之後才有的;
import threading
from concurrent.futures import threadpoolexecutor, wait
from urllib.request import urlopen
def get_area(ip):
url = "" % (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']))
@timeit
def use_ten_thread():
# 1. 例項化線城池物件,線城池裡面包含5個執行緒執行任務;
pool = threadpoolexecutor(max_workers=10)
futures = 
for i in range(30):
print("當前執行緒數:", threading.activecount())
ip = '12.13.14.%s' %(i+1)
# 往執行緒池裡面扔需要執行的任務， 返回的是乙個物件(_base.future())，
f1 = pool.submit(get_area, ip)
# 等待futures裡面所有的子執行緒執行結束， 再執行主線程(join())
wait(futures)
@timeit
def use_hundred_thread():
# 1. 例項化線城池物件,線城池裡面包含5個執行緒執行任務;
pool = threadpoolexecutor(max_workers=100)
futures = 
for i in range(30):
print("當前執行緒數:", threading.activecount())
ip = '12.13.14.%s' %(i+1)
# 往執行緒池裡面扔需要執行的任務， 返回的是乙個物件(_base.future())，
f1 = pool.submit(get_area, ip)
wait(futures)
if __name__ == '__main__':
use_ten_thread()
use_hundred_thread()

1，將陣列中的每個元素提取出來當作函式的引數，建立乙個個程序，放進程式池中

2，第乙個引數是函式，第二個引數是乙個迭代器，將迭代器中的數字作為引數依次傳入函式中

示例：

import time

def timeit(f):
start_time = time.time()
res = f(*args, **kwargs)
end_time = time.time()
return res
# python3.2版本之後才有的;
import threading
from concurrent.futures import threadpoolexecutor, wait
from urllib.request import urlopen
def get_area(ip):
url = "" % (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']))
@timeit
def use_ten_thread():
# 1. 例項化線城池物件,線城池裡面包含5個執行緒執行任務;
pool = threadpoolexecutor(max_workers=10)
# futures = 
# for i in range(30):
# print("當前執行緒數:", threading.activecount())
# ip = '12.13.14.%s' %(i+1)
# # 往執行緒池裡面扔需要執行的任務， 返回的是乙個物件(_base.future())，
# f1 = pool.submit(get_area, ip)
## # 等待futures裡面所有的子執行緒執行結束， 再執行主線程(join())
# wait(futures)
ips = ['12.13.14.%s' % (ip + 1) for ip in range(30)]
pool.map(get_area, ips)
@timeit
def use_hundred_thread():
# 1. 例項化線城池物件,線城池裡面包含5個執行緒執行任務;
pool = threadpoolexecutor(max_workers=100)
# futures = 
# for i in range(30):
# print("當前執行緒數:", threading.activecount())
# ip = '12.13.14.%s' % (i + 1)
# # 往執行緒池裡面扔需要執行的任務， 返回的是乙個物件(_base.future())，
# f1 = pool.submit(get_area, ip)
## wait(futures)
ips = ['12.13.14.%s' % (ip + 1) for ip in range(30)]
pool.map(get_area, ips)
if __name__ == '__main__':
use_ten_thread()
use_hundred_thread()

執行緒池的submit和execute方法區別

1.接收的引數不一樣 2.submit 有返回值，而execute 沒有 例如，有個validation的task，希望該task執行完後告訴我它的執行結果，是成功還是失敗，然後繼續下面的操作。3.submit 可以進行exception處理 例如，如果task裡會丟擲checked或者unchec...

執行緒池的submit和execute方法區別

1 接收的引數不一樣 2 submit有返回值，而execute沒有 用到返回值的例子，比如說我有很多個做validation的task，我希望所有的task執行完，然後每個task告訴我它的執行結果，是成功還是失敗，如果是失敗，原因是什麼。然後我就可以把所有失敗的原因綜合起來發給呼叫者。個人覺得c...

執行緒池的submit和execute方法區別

執行緒池中的execute方法大家都不陌生，即開啟執行緒執行池中的任務。還有乙個方法submit也可以做到，它的功能是提交指定的任務去執行並且返回future物件，即執行的結果。下面簡要介紹一下兩者的三個區別 1 接收的引數不一樣 2 submit有返回值，而execute沒有 用到返回值的例子，比...