FilesExpand file tree

 master

/

futures_future_callback.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

30 lines (24 loc) · 702 Bytes

 master

/

futures_future_callback.py

Copy path

Top

File metadata and controls

• Code
• Blame

30 lines (24 loc) · 702 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

20

21

22

23

24

25

26

27

28

29

30

from concurrent import futures

import time

def task(n):

print("{}: sleeping".format(n))

time.sleep(0.5)

print("{}: done".format(n))

return n / 10

def done(fn):

if fn.cancelled():

print("{}: cancelled.".format(fn.arg))

elif fn.done():

error = fn.exception()

if error:

print("{}: error returned: {}".format(fn.arg, error))

else:

result = fn.result()

print("{}: value returned: {}".format(fn.arg, result))

if __name__ == "__main__":

ex = futures.ThreadPoolExecutor(max_workers=2)

print("main: starting")

f = ex.submit(task, 5)

f.arg = 5

f.add_done_callback(done)

result = f.result()