import urllib.request as ur
import concurrent.futures
def concurrent_exe(): # concurrent exection function that use ThreadPoolExecutor.
thread_pool_exe = concurrent.futures.ThreadPoolExecutor()
for v in range(10000):
future = thread_pool_exe.submit(access_example)
print(v, future.result())
def access_example():
return ur.urlopen("http://example.com").read().decode("utf-8")[10:15]
def seq_exe(): # sequential exectute function
for v in range(10000):
print(v, access_example())
def concurrent_exe():
futures_list = []
thread_pool_exe = concurrent.futures.ThreadPoolExecutor()
for v in range(10000):
future = thread_pool_exe.submit(access_example, v)
futures_list.append(future)
for v in concurrent.futures.as_completed(futures_list):
print(v.result())