Je suis désolé de ne pas pouvoir reproduire l'erreur avec un exemple plus simple et mon code est trop compliqué à publier. Si j'exécute le programme dans le shell IPython au lieu du Python normal, les choses fonctionnent bien. J'ai recherché quelques notes précédentes sur ce problème. Ils ont tous...
J'essaie d'apprendre à utiliser le multiprocessingpackage de Python , mais je ne comprends pas la différence entre map_asyncet imap. J'ai remarqué que les deux map_asyncet imapsont exécutés de manière asynchrone. Alors, quand devrais-je utiliser l'un sur l'autre? Et comment récupérer le résultat...
Dans l'exemple de code ci-dessous, j'aimerais récupérer la valeur de retour de la fonction worker. Comment puis-je faire cela? Où cette valeur est-elle stockée? Exemple de code: import multiprocessing def worker(procnum): '''worker function''' print str(procnum) + ' represent!' return procnum if...
J'utilise 'multiprocess.Pool.imap_unordered' comme suit from multiprocessing import Pool pool = Pool() for mapped_result in pool.imap_unordered(mapping_func, args_iter): do some additional processing on mapped_result Dois-je appeler pool.closeou pool.joinaprès la boucle for?
La documentation du multiprocessingmodule montre comment transmettre une file d'attente à un processus démarré avec multiprocessing.Process. Mais comment puis-je partager une file d'attente avec des processus de travail asynchrones démarrés avec apply_async? Je n'ai pas besoin de jointure...