FilesExpand file tree

 master

/

example6.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

29 lines (20 loc) · 573 Bytes

 master

/

example6.py

Copy path

Top

File metadata and controls

• Code
• Blame

29 lines (20 loc) · 573 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

# ch6/example6.py

import multiprocessing

class MyWorker():

def __init__(self, x):

self.x = x

def process(self):

pname = multiprocessing.current_process().name

print('Starting process %s for number %i...' % (pname, self.x))

def work(q):

worker = q.get()

worker.process()

if __name__ == '__main__':

my_queue = multiprocessing.Queue()

p = multiprocessing.Process(target=work, args=(my_queue,))

p.start()

my_queue.put(MyWorker(10))

my_queue.close()

my_queue.join_thread()

p.join()

print('Done.')