otra confusión más con error de multiprocesamiento, el objeto 'módulo' no tiene el atributo 'f'

Question

Sé que esto ha sido respondido antes, pero parece que la ejecución del script directamente "python filename.py" no funciona. Tengo Python 2.6.2 en SuSE Linux.

Código:

#!/usr/bin/python 
# -*- coding: utf-8 -*- 
from multiprocessing import Pool 
p = Pool(1) 
def f(x): 
    return x*x 
p.map(f, [1, 2, 3]) 

Línea de comandos:

> python example.py 
Process PoolWorker-1: 
Traceback (most recent call last): 
File "/usr/lib/python2.6/multiprocessing/process.py", line 231, in _bootstrap 
    self.run() 
File "/usr/lib/python2.6/multiprocessing/process.py", line 88, in run 
    self._target(*self._args, **self._kwargs) 
File "/usr/lib/python2.6/multiprocessing/pool.py", line 57, in worker 
    task = get() 
File "/usr/lib/python2.6/multiprocessing/queues.py", line 339, in get 
    return recv() 
AttributeError: 'module' object has no attribute 'f' 

Answer 1

Reestructurar el código para que la función f() se defina antes de crear la instancia de Pool. De lo contrario, el trabajador no puede ver su función.

#!/usr/bin/python 
# -*- coding: utf-8 -*- 

from multiprocessing import Pool 

def f(x): 
    return x*x 

p = Pool(1) 
p.map(f, [1, 2, 3]) 

Answer 2

Esta funciona:

#!/usr/bin/python 
# -*- coding: utf-8 -*- 
from multiprocessing import Pool 

def f(x): 
    return x*x 

if __name__ == "__main__": 
    p = Pool(1) 
    p.map(f, [1, 2, 3]) 

No estoy 100% seguro de por qué su código no funciona, pero yo Supongo que la razón es que los procesos secundarios iniciados por el módulo multiprocessing intentan importar el módulo principal (para tener acceso a los métodos que definió) y la estrofa if __name__ == "__main__" es necesaria para no ejecutar el código de inicialización donde configuró su grupo.

Answer 3

Una posibilidad es que el archivo de Python tiene el mismo nombre que un módulo:

• test.py
• prueba/
  • __init__.py

en pickle.py, tiene el error de venir g a partir de:

def find_class(self, module, name): 
     # Subclasses may override this 
     __import__(module) 
     mod = sys.modules[module] # <- here mod will reference your test/__init__.py 
     klass = getattr(mod, name) 
     return klass 

Answer 4

El problema que tuve fue resuelto mediante el uso de if __name__ == "__main__" como se ha señalado por Tamás; en Eclipse para Windows, los ejemplos no funcionan bajo el intérprete. Esto se explica en http://docs.python.org/2/library/multiprocessing