Appel a map_async depuis un process mne mache pas
Bonjour,
Voici mon probeme: En utilisant "import multiporcessing using Pool"
je fait ce schema:
Code:
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:
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)
