Discussion :

[Krishna]

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 :

Sélectionner tout - Visualiser dans une fenêtre à part

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()

[wiztricks]

Salut,
Une JoinableQueue impose un minimum de choses aux opérations put et get pour que le "join" fonctionne...

Implicitement, çà dit chaque "put" équivaut à mettre une tache a effectuer en attente. Puis on a une sorte "serveur" qui retire les taches à faire via .get, les exécute et signale la fin de la tache via .task_done.
La différence entre le nombre de taches insérées et le nombre de taches effectuées ("task_done") rendra le .join" bloquant ou pas.
- W

[Krishna]