| 12345678910111213141516171819202122 |
- from concurrent.futures.thread import ThreadPoolExecutor
- from concurrent.futures import as_completed
- import random
-
- import time
- def print_time(data):
- t = random.randint(1, 10)
- time.sleep(t)
- print("start_%s" % data)
- print("============")
- return t
- data = []
- for i in range(50):
- data.append(i)
- with ThreadPoolExecutor(10) as executor:
- future_list = []
- for i in range(10):
- # future = executor.submit(print_time,data)
- future = executor.submit(print_time, {"name": 111, "id": 222})
- future_list.append(future)
- for res in as_completed(future_list): # 这个futrure_list是你future对象的列表
- print(res.result())
|
