Python: joblib не работает с настраиваемой функцией

Question

Я пытаюсь использовать joblib пакета параллельных вычислений в python. Я могу привести следующий пример и получить результат

Parallel(n_jobs=8)(delayed(sqrt)(i) for i in range(10)) 

Однако, следующий код не работает.

from joblib import Parallel, delayed 
def f(x): 
    return 1 
def y(x): 
    result=Parallel(n_jobs=8)(delayed(x)(i) for i in range(10)) 
    return result 
if __name__ == '__main__': 
    print y(f) 

Когда я запускаю вышеуказанный код, он продолжает работать вечно, не генерируя никаких результатов или сообщений.

Может ли кто-нибудь выяснить причину этого странного поведения (я использую окна)? спасибо

Answer 1

Когда я пробую ваш код, он всегда работает для меня тоже.

Я не совсем уверен, но я думаю, что проблема в «замедленной (х)»

Если я пытаюсь это:

if __name__ == '__main__': 
    def f(x): 
     return 1 
    def y(x): 
     result=Parallel(n_jobs=8)(delayed(sqrt)(i) for i in range(10)) 
     return result 
    print(y(5)) 

он работает как шарм.

Похоже, что ваш код выдает сообщение об ошибке, но поскольку ошибка внутри части parrellel, как-то она не будет отображаться.