FilesExpand file tree

 master

/

ThreadPoolExecutor-demo.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

19 lines (15 loc) · 722 Bytes

 master

/

ThreadPoolExecutor-demo.py

Top

File metadata and controls

• Code
• Blame

19 lines (15 loc) · 722 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

import time

import threading

from concurrent.futures import ThreadPoolExecutor, as_completed

def sayhello(name):

print("%s say Hello to %s" % (threading.current_thread().getName(), name));

time.sleep(1)

return name

name_list =['admin','root','scott','tiger']

start_time = time.time()

with ThreadPoolExecutor(2) as executor: # 创建 ThreadPoolExecutor

future_list = [executor.submit(sayhello, name) for name in name_list] # 提交任务

for future in as_completed(future_list):

result = future.result() # 获取任务结果

print("%s get result : %s" % (threading.current_thread().getName(), result))

print('%s cost %d second' % (threading.current_thread().getName(), time.time()-start_time))