Python concurrent.features.Future объект: где определяется Future.arg? - PullRequest
Новая
       7

Python concurrent.features.Future объект: где определяется Future.arg?

0 голосов
/ 12 января 2019

Я изучаю модуль python, называемый concurrent.futures. В приведенном ниже примере они используют f.arg ... который является свойством класса Future Я посмотрел на этот класс, но не могу найти, где он определен 

from concurrent import futures
import time


def task(n):
    print('{}: sleeping'.format(n))
    time.sleep(0.5)
    print('{}: done'.format(n))
    return n / 10


def done(fn):
    if fn.cancelled():
        print('{}: canceled'.format(fn.arg))
    elif fn.done():
        error = fn.exception()
        if error:
            print('{}: error returned: {}'.format(
                fn.arg, error))
        else:
            result = fn.result()
            print('{}: value returned: {}'.format(
                fn.arg, result))


if __name__ == '__main__':
    ex = futures.ThreadPoolExecutor(max_workers=2)
    print('main: starting')
    f = ex.submit(task, 5)
    f.arg = 5
    f.add_done_callback(done)
    result = f.result()
...