Подкласс будущего класса

Question

Я хотел бы подкласса Future класс модуля concurrent Python.

Документы:

Будущего класс инкапсулирует асинхронное выполнение вызываемого. Будущие экземпляры создаются Executor.submit().

Документы Executor не объясняют, где взять класс Future.

... Как заставить команду Executor.submit() принять мой пользовательский класс будущего?

Зачем мне это нужно?

Мне нравится OOP, так как он создает читаемый код. Я хотел бы результат выглядеть следующим образом:

for my_future in concurrent.futures.as_completed(...): 
    my_future.my_custom_method() 

Answer 1

Рассматривая код, ProcessPoolExecutor.submit() и ThreadPollExecutor.submit(), возвращает экземпляр Future, который определен в conccurent.futures._base.Future.

Итак, вот трюк. Вы можете подклассом и заменить исходное Будущее, а затем добавить пользовательские методы в подкласс.

Это выполнимо, но не рекомендуется. Для этой цели лучше использовать композицию, а не наследование. Существует хорошая глава о наследовании и композиции в Learn Python the Hard Way

Назад к вопросу, здесь есть композиция пример:

class Myclass(object): 
    def __init__(self, workers=3): 
     self.executor = concurrent.futures.ProcessPoolExcutor(workers) 

    def run(self, job): 
     '''Job to be run in a Executor''' 

    def submit(self, jobs): 
     self.futures = [executor.submit(self, foo, job) for job in jobs] 

    def done(self, result): 
     '''Dealing with the result''' 

    def harvest(self): 
     for my_future in concurrent.futures.as_completed(self.futures): 
      self.done(my_future.result()) 

И тогда вы можете создать подкласс MyClass и реализации другого метода Выполненные.

Answer 2

Использование конкретного класса Future является зашитым в Executor.submit() (будь processes или threads). Поэтому я не думаю, что можно делать именно то, что вы просите. Тем не менее, вы можете вернуть любой результат из вызываемого, переданного в Executor.submit(). Поэтому поставить свои собственные методы в пользовательском классе возврата:

class my_result(object): 
    def my_custom_method(self): 
     pass 

def x(): 
    return my_result() 

with concurrent.futures.ThreadPoolExecutor(max_workers=5) as executor: 
    futures = [executor.submit(x), executor.submit(x)] 
    for my_future in concurrent.futures.as_completed(futures): 
     my_future.result().my_custom_method() 
       # ^^^^^^^^^ 

Edit Или, если вы действительно хотите, чтобы ваш внутренний цикл, чтобы быть чистым, измените последние две строки:

for my_result in (f.result() for f in concurrent.futures.as_completed(futures)): 
        # ^^^^^^^^^^^^^^^^^^^^ 
     my_result.my_custom_method() 

generator expression(f.result() ... (futures)) принимает итератор фьючерсов от as_completed и дает вам итератор результатов этих фьючерсов. Затем вы можете выполнить эти результаты.