FilesExpand file tree

 main

/

lesson06_callback.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

33 lines (30 loc) · 937 Bytes

 main

/

lesson06_callback.py

Top

File metadata and controls

• Code
• Blame

33 lines (30 loc) · 937 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

31

32

33

# SuperFastPython.com

# example of a callback function for a one-off task

from random import random

from time import sleep

from multiprocessing.pool import ThreadPool

# result callback function

def result_callback(return_value):

# report a message

print(f'Callback got: {return_value}')

# custom function to be executed in a worker thread

def task(ident):

# generate a value

value = random()

# report a message

print(f'Task {ident} with {value}')

# block for a moment

sleep(value)

# return the generated value

return value

# protect the entry point

if __name__ == '__main__':

# create and configure the thread pool

with ThreadPool() as pool:

# issue tasks to the thread pool

result = pool.apply_async(task, args=(0,),

callback=result_callback)

# close the thread pool

pool.close()

# wait for all tasks to complete

pool.join()