Learning

1
import multiprocessing
2
import random
3

4
def end_func(response):
5
    print("Задание завершено!")
6
    print(response)
7

8
def get_value(value):
9
    name = multiprocessing.current_process().name
10
    print(f"[{name}] value: {value}")
11
    return value
12

13
if __name__ == '__main__':
14
    with multiprocessing.Pool(multiprocessing.cpu_count() * 3) as p:
15
        p.map_async(get_value, list(range(100)), callback=end_func)  # смотри еще apply_async
16
        p.close()
17
        p.join()
18