FilesExpand file tree

 master

/

queueProcess.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

33 lines (29 loc) · 853 Bytes

 master

/

queueProcess.py

Copy path

Top

File metadata and controls

• Code
• Blame

33 lines (29 loc) · 853 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

#!/usr/bin/env/python

#-*-coding:utf-8-*-

from multiprocessing import Queue,Process

import os,time,random

def write(q):

for value in ['A','B','C']:

print 'Put %s in queue...'%value

q.put(value)

time.sleep(random.random())

def read(q):

while not q.empty():

value = q.get(True)

print 'Get %s in queue...'%value

time.sleep(random.random())

if __name__ == '__main__':

# 父进程创建Queue并传递给各个子进程

q = Queue()

pw = Process(target=write,args=(q,))

pr = Process(target=read,args=(q,))

# 启动pw子进程，写入

pw.start()

# 等待pw结束

pw.join()

# 启动pr子进程，读取

pr.start()

# pr进程是死循环，无法等待结束，只能强制结束

pr.join()

print ''

print '所有数据都已写入并且读完...'