7'r z d Z dZddlmZ ddlZddlZddlZddlZddlZddl Z ej
Z da ej
Zd Z ej e ee d r" e j ej ej ej G d d
e Zd Z G d d
ej Z G d dej Z dS )z Implements ThreadPoolExecutor.z"Brian Quinlan (brian@sweetapp.com) )_baseNFc t 5 dad d d n # 1 swxY w Y t t } | D ]\ }}| d | D ]\ }}| d S NT)_global_shutdown_lock _shutdownlist_threads_queuesitemsputjoin)r
tqs @/opt/alt/python311/lib64/python3.11/concurrent/futures/thread.py _python_exitr s &&(( ) )E 1 d 1 s register_at_fork)beforeafter_in_childafter_in_parentc : e Zd Zd Zd Z eej ZdS ) _WorkItemc > || _ || _ || _ || _ d S N)futurefnargskwargs)selfr r r r s r __init__z_WorkItem.__init__/ s" c | j sd S | j | j i | j }| j | d S # t $ r'}| j | d } Y d }~d S d }~ww xY wr )r set_running_or_notify_cancelr r r
set_result
BaseException
set_exception)r resultexcs r runz
_WorkItem.run5 s {7799 F + TWdi74;77F
K " "6 * * * * * K % %c * * *DDDDDDD s A
B A<<BN) __name__
__module__ __qualname__r r' classmethodtypes GenericAlias__class_getitem__ r r r r . sC + + + $ E$677r r c @ |Y || nR# t $ rE t j dd | }|| Y d S w xY w | d }|<| ~ | }||j ~U | }t s ||j r |d|_ |
d d S ~# t $ r% t j dd Y d S w xY w)NzException in initializer:T)exc_info)blockzException in worker) r# r LOGGERcritical_initializer_failedgetr' _idle_semaphorereleaser r )executor_reference
work_queue initializerinitargsexecutor work_items r _workerr? E s K " " " L ! !"= ! M M M))++H#,,... FF D "T22I$
.-//' ,44666 ))++H
H ,0B , ')-H&t$$$7 8 D D D
3d CCCCCCDs)
A AA B
C. ,C. .+D D c e Zd ZdZdS )BrokenThreadPoolzR
Raised when a worker thread in a ThreadPoolExecutor failed initializing.
N)r( r) r* __doc__r/ r r rA rA p s r rA c e Zd Z ej j Z d dZd Ze j
j j e_ d Z d Z
d
d d
d Ze j
j j e_ dS )ThreadPoolExecutorN r/ c |&t dt j pddz }|dk rt d | t | st d || _ t j | _ t j d | _ t | _ d| _ d| _ t j | _ |pd | z | _ || _ || _ dS )
a Initializes a new ThreadPoolExecutor instance.
Args:
max_workers: The maximum number of threads that can be used to
execute the given calls.
thread_name_prefix: An optional name prefix to give our threads.
initializer: A callable used to initialize worker threads.
initargs: A tuple of arguments to pass to the initializer.
N r z"max_workers must be greater than 0z initializer must be a callableFzThreadPoolExecutor-%d)minos cpu_count
ValueErrorcallable TypeError _max_workersqueue SimpleQueue _work_queue threading Semaphorer7 set_threads_brokenr Lock_shutdown_lock_counter_thread_name_prefix _initializer _initargs)r max_workersthread_name_prefixr; r< s r r zThreadPoolExecutor.__init__{ s b2<>>#6Q!";<.weakref_cb s
EE$KKKKKr z%s_%d)nametargetr )r7 acquirerS lenrW rP r\ rT Threadr? weakrefrefr] r^ startaddr )r rl num_threads thread_namer
s r rd z'ThreadPoolExecutor._adjust_thread_count s ' ' ' 2 2 F ! , $-(( * * *!T%=%E%0%2 2K k''.{4'D'D'+'7'+'8'+~'78 8 8A
GGIII M a !%!1OA + *r c | j 5 d| _ | j }n# t j $ r Y n3w xY w|,|j t | j _ d d d d S # 1 swxY w Y d S )NzBA thread initializer failed, the thread pool is not usable anymore) rZ rX rS
get_nowaitrQ Emptyr r$ rA )r r> s r r5 z&ThreadPoolExecutor._initializer_failed s
S
S 4DL
S $ 0 ; ; = =II { E ( $223CDL3Q3QRRR
S
S
S
S
S
S
S
S
S
S
S
S
S
S
S
S
S
S
Ss, A>,A>>A>>2A>>BBTF)cancel_futuresc h | j 5 d| _ |rM | j }n# t j $ r Y n w xY w||j L| j d d d d n # 1 swxY w Y |r | j D ]}|
d S d S r ) rZ r rS ry rQ rz r cancelr rW r )r waitr{ r> r
s r shutdownzThreadPoolExecutor.shutdown s(
' ' !DN
22 $($4$?$?$A$A ; ,!(//111
2
& & & ' ' ' ' ' ' ' ' ' ' ' ' ' ' ' ]
s/ B.BA BA 9BB B )NrE Nr/ )T)r( r) r* itertoolscount__next__r[ r rg r ExecutorrB rd r5 r r/ r r rD rD v s y )H<>,.$" $" $" $"L " ^*2FN2 2 2. S S SE ( ~.6Hr rD ) rB
__author__concurrent.futuresr r rQ rT r, rr rK WeakKeyDictionaryr r rY r r _register_atexithasattrr ro _at_fork_reinitr8 objectr r? BrokenExecutorrA r rD r/ r r r s % $
1
$ $ $ $ $ $ ,'+-- ' (( < ( ( ( 72!"" GB 4 <'<'L(=(EG G G G
8 8 8 8 8 8 8 8.(D (D (DV u+ v7 v7 v7 v7 v7 v7 v7 v7 v7 v7r