Discussion :

[bibi9]

Bonjour,

Voici mon probeme: En utilisant "import multiporcessing using Pool"
je fait ce schema:

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
def do_task(data):
   print "Executing: " + data
   return data
 
def do_something(data):
   print "Starting do_something"
   result2 = pool.map_async(do_task, ["AA","BB"])  
   print "before get"
   result.get()
   print "after get"
   return data
 
def main():
    pool = Pool(processes=4)             
    result = pool.apply_async(do_something, "A")  
    print result.get()

Donc, je creer mon pool de process, puis je start le process "A", le do_something de ce prosess A lance a son tour "AA" et BB (avec map cette fois si. mais apparement do_task n'est jamais appele ? Voic le output:

Code :

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

1
2
Starting do_something
before get

Quelqu'un peut-il m'expliquer purquoi cela bloque ?

Merci (je tappe depuis un clavier sans accent desole)

[wiztricks]

Salut,

Le multiprocessing est d'une utilisation "compliquée".

Si vous montrez du code, il faut qu'il soit "fonctionnel": à quoi correspond "result" dans do_something alors que le result des "process" démarrés par .map_async ne peuvent remonter que par un "callback"?

- W