Module Import alias Import alias ImportFrom alias Import alias ImportFrom alias identifier ImportFrom alias identifier ImportFrom alias identifier Assign NameStore Call AttributeLoad NameLoad attr NameLoad Assign NameStore Call NameLoad FunctionDef arguments args NameParam NameParam NameParam NameParam defaults body Assign NameStore NameLoad While NameLoad body If Call AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore NameLoad orelse Assign NameStore Call AttributeLoad NameLoad attr If CompareIs NameLoad NameLoad body Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Str NameLoad Assign NameStore NameLoad orelse Assign TupleStore NameStore NameStore NameLoad If Call AttributeLoad NameLoad attr body TryExcept body Assign NameStore Call NameLoad handlers ExceptHandler type NameLoad body Expr Call AttributeLoad NameLoad attr Str NameLoad Assign TupleStore NameStore NameStore NameStore Call AttributeLoad NameLoad attr If AttributeLoad NameLoad attr body Expr Call AttributeLoad NameLoad attr NameLoad NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr For NameStore NameLoad body Expr Call AttributeLoad NameLoad attr Assign NameStore NameLoad orelse Expr Call AttributeLoad NameLoad attr NameLoad decorator_list ClassDef bases NameLoad body FunctionDef arguments args NameParam NameParam defaults body Assign AttributeStore NameLoad attr ListLoad Assign AttributeStore NameLoad attr Call NameLoad NameLoad Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr decorator_list FunctionDef arguments args NameParam NameParam defaults body If AttributeLoad NameLoad attr body Raise Call NameLoad BinOpMod Str Call NameLoad AttributeLoad NameLoad attr Assign AttributeStore NameLoad attr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr Assign NameStore ListLoad For NameStore Call NameLoad Num AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad NameLoad attr keyword NameLoad keyword TupleLoad BinOpAdd NameLoad Num AttributeLoad NameLoad attr AttributeLoad NameLoad attr NameLoad Assign AttributeStore NameLoad attr NameLoad Expr Call AttributeLoad NameLoad attr Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad For NameStore NameLoad body Assign NameStore Call AttributeLoad NameLoad attr Expr Call AttributeLoad NameLoad attr NameLoad Expr Call AttributeLoad AttributeLoad NameLoad attr attr TupleLoad NameLoad NameLoad Return NameLoad decorator_list FunctionDef arguments args NameParam defaults body Expr Call AttributeLoad AttributeLoad NameLoad attr attr NameLoad While AttributeLoad NameLoad attr body Assign NameStore Call AttributeLoad AttributeLoad NameLoad attr attr Expr Call AttributeLoad NameLoad attr decorator_list decorator_list
N/A N/A sys N/A threading concurrent futures N/A six six.moves queue compat_queue six.moves range compat_range anvil log logging N/A LOG N/A N/A logging getLogger __name__ N/A _TOMBSTONE N/A object _chained_worker N/A N/A ident shared_death queue futs N/A N/A N/A running True N/A running N/A N/A N/A N/A shared_death is_set N/A N/A N/A N/A LOG warn Worker %s dying unhappily... ident N/A running False N/A N/A w N/A N/A queue get N/A N/A w _TOMBSTONE N/A N/A N/A N/A queue put w N/A N/A N/A LOG info Worker %s dying happily... ident N/A running False N/A N/A N/A func fut w N/A N/A N/A fut set_running_or_notify_cancel N/A N/A N/A N/A result N/A func N/A N/A N/A BaseException N/A N/A N/A N/A LOG exception Worker %s dying unhappily... ident N/A N/A exc_type exc_val exc_tb N/A N/A sys exc_info N/A N/A six PY2 N/A N/A N/A N/A fut set_exception_info exc_val exc_tb N/A N/A N/A N/A fut set_exception exc_val N/A N/A N/A shared_death set N/A fut futs N/A N/A N/A N/A fut cancel N/A running False N/A N/A N/A N/A fut set_result result N/A ChainedWorkerExecutor N/A object N/A __init__ N/A N/A self max_workers N/A N/A N/A N/A self _workers N/A N/A N/A self _max_workers N/A int max_workers N/A N/A self _queue N/A N/A compat_queue Queue N/A N/A self _death N/A N/A threading Event N/A run N/A N/A self funcs N/A N/A N/A N/A self _workers N/A N/A N/A RuntimeError N/A Can not start another `run` with %s existing workers N/A len N/A self _workers N/A N/A self _queue N/A N/A compat_queue Queue N/A N/A N/A N/A self _death clear N/A futs N/A N/A i N/A compat_range 0 N/A self _max_workers N/A N/A w N/A N/A threading Thread target _chained_worker args N/A N/A i 1 N/A self _death N/A self _queue futs N/A N/A w daemon True N/A N/A N/A w start N/A N/A N/A N/A self _workers append w N/A func funcs N/A N/A fut N/A N/A futures Future N/A N/A N/A futs append fut N/A N/A N/A N/A self _queue put N/A func fut N/A futs N/A wait N/A N/A self N/A N/A N/A N/A N/A N/A self _queue put _TOMBSTONE N/A N/A self _workers N/A N/A w N/A N/A N/A self _workers pop N/A N/A N/A w join N/A N/A