Могу ли я передать метод apply_async или карту в многопроцессорности python?

Question

Как я могу заставить следующее работать? Главное, что я хочу запустить метод (а не функцию) асинхронно.

from multiprocessing import Pool 

class Async: 
    def __init__(self, pool): 
     self.pool = pool 
     self.run() 

    def run(self): 
     p.apply_async(self.f, (10,)) 

    def f(self, x): 
     print x*x 

if __name__ == '__main__': 
    p = Pool(5) 
    a = Async(p) 
    p.close() 
    p.join() 

Это не печатает.

Answer 1

Проблема, как представляется, в связи с тем, что multiprocessing необходимо протравить self.f в то время как связанные методы не пригодны для консервирования. Обсуждается вопрос о том, как решить проблему here.

apply_async, по-видимому, создает исключение, которое помещается в будущее. Вот почему ничего не печатается. Если в будущем выполняется get, то возникает исключение.

Answer 2

Его определенно можно использовать методы класса, используя threadpool в python 2 - следующая программа сделала то, что я ожидал бы.

#!/usr/bin/env python 

from multiprocessing.pool import ThreadPool 

class TestAsync(): 
    def __init__(self): 
    pool = ThreadPool(processes = 2) 

    async_completions = [] 
    for a in range(2): 
     async_completions.append(pool.apply_async(self.print_int, ( a,))) 

    for completion in async_completions: 
     res = completion.get() 
     print("res = %d" % res) 

    def print_int(self, value): 
    print(value) 
    return (value*10) 


a = TestAsync()