comment stopper un JoinableQueue?
Bonjour à tous,
Je reproduis pour apprendre les exemples du livre "Python essential reference" de Beazley et lorsque je lance le code ci-dessous l'interpréteur ne me rend pas la main.
Que dois-je faire pour que que ce soit le cas?
Code:
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
| #!/usr/bin/python
# *-* coding UTF-8 *-*
from multiprocessing import Process, JoinableQueue
def consumer(q):
while True:
item=q.get()
if item is None:
break
print item
print "consumer done"
def producer(seq,q):
for item in seq:
q.put(item)
if __name__=='__main__':
q=JoinableQueue()
cons_p=Process(target=consumer,args=(q,))
#cons_p.deamon=True
cons_p.start()
producer([1,2,3,4,5],q)
q.put(None)
q.join() |
