[Python][Async] Understanding Futures and ThreadPoolExecutor for Async

thread_pool_executor_examples.py

from concurrent import futures
import requests

def get_data(url):
	if url == 0:
		return "working"
	return requests.get(url).text

# Running a blocking task on executor.
# Increasing ThreadPool size or setting it to None, 
# changes the order of results.
with futures.ThreadPoolExecutor(None) as executor:
	urls = ['http://www.fakeresponse.com/api/?sleep=10', 'https://httpbin.org/ip', 0]
	# list of jobs, can be made with [for].
	jobs = [executor.submit(get_data, url) for url in urls]
	# Returns result on completion of each job.
	for comp_job in futures.as_completed(jobs):
		print(comp_job.result())


# Wait till all finished example.
with futures.ThreadPoolExecutor(None) as executor:
	url_slow = 'http://www.fakeresponse.com/api/?sleep=10'
	url_fast = 'https://httpbin.org/ip'
	# list of jobs
	slow_job = executor.submit(get_data, url_slow)
	fast_job = executor.submit(get_data, url_fast)
	# Blocks till all the jobs completed.
	futures.wait([slow_job, fast_job], timeout=None, return_when=futures.ALL_COMPLETED)
	# Method to check a job is done or not.
	print(slow_job.done())
	# Print results after completion.
	print(slow_job.result())
	print(fast_job.result())