cj" d Z dZddlmZ ddlZddlZddlZddlZddlZddl Z ej Z da ej Zd Z ej e ee d rP e j$ ej& ej( ej* e j$ e j, G d
d Zd Z G d
dej2 Z G d dej6 Z y)z Implements ThreadPoolExecutor.z"Brian Quinlan (brian@sweetapp.com) )_baseNFc t 5 dad d d t t j } | D ] \ }}|j d | D ] \ }}|j
y # 1 sw Y \xY wNT)_global_shutdown_lock _shutdownlist_threads_queuesitemsputjoin)r
tqs 2/usr/lib64/python3.12/concurrent/futures/thread.py _python_exitr s[
&&( )E1 d 1
s A%%A.register_at_fork)beforeafter_in_childafter_in_parent)r c < e Zd Zd Zd Z eej Zy) _WorkItemc < || _ || _ || _ || _ y N)futurefnargskwargs)selfr r r r s r __init__z_WorkItem.__init__0 s c $ | j j sy | j | j i | j }| j j | y # t $ r'}| j j | d } Y d }~y d }~ww xY wr )r set_running_or_notify_cancelr r r
set_result
BaseException
set_exception)r resultexcs r runz
_WorkItem.run6 st {{779 + TWWdii74;;7F
KK " "6 * KK % %c *D s &A B( B
BN) __name__
__module__ __qualname__r r' classmethodtypes GenericAlias__class_getitem__ r r r r / s + $E$6$67r r c ` | || |j }||j ~& | }t s| |j r|d|_ |j d y ~]# t $ r= t j j dd | }||j Y y w xY w# t j $ r9 | }||j j ~|j d }Y w xY w# t $ r$ t j j dd Y y w xY w)NzException in initializer:T)exc_info)blockzException in worker)r# r LOGGERcritical_initializer_failed
get_nowaitqueueEmpty_idle_semaphorereleasegetr' r r )executor_reference
work_queue initializerinitargsexecutor work_items r _workerrB F s@ "!D
7 & 1 1 3 $
)+H
H ,0B0B ')-H&t$= LL ! !"= ! M)+H#,,. ;;
7-/' ,,446 &NNN 6
78 D
3d CDsM A( D B1 A D &D (AB.-B.1A C=:D <C==D *D-,D-c e Zd ZdZy)BrokenThreadPoolzR
Raised when a worker thread in a ThreadPoolExecutor failed initializing.
N)r( r) r* __doc__r/ r r rD rD t s r rD c e Zd Z ej j
Z d dZd Ze j j j e_ d Z d Z
d
dddZe j j j e_ y) ThreadPoolExecutorNc |%t dt j xs ddz }|dk r t d |t | s t d || _ t j | _ t j d | _ t | _ d| _ d| _ t j" | _ |xs d | j' z | _ || _ || _ y)
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_workersr7 SimpleQueue _work_queue threading Semaphorer9 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$Kr z%s_%d)nametargetr )r9 acquirerT lenrX rR r] rU ThreadrB weakrefrefr^ r_ startaddr )r rm num_threads thread_namer
s r re z'ThreadPoolExecutor._adjust_thread_count s ' ' ' 2 ! , , $--( ** *!T%=%=%E%0%2 2K k''.{{4'D'+'7'7'+'8'8'+~~'78A
GGI MM a !%!1!1OA +r c " | j 5 d| _ | j j }|.|j j t | j L# t j
$ r Y nw xY w d d d y # 1 sw Y y xY w)NzBA thread initializer failed, the thread pool is not usable anymore) r[ rY rT r6 r7 r8 r r$ rD )r rA s r r5 z&ThreadPoolExecutor._initializer_failed s
4DL $ 0 0 ; ; =I ( $$223CDLL3QR
{{ !
s- BA"1B"A85B7A88BBF)cancel_futuresc z | j 5 d| _ |r9 | j j }||j j 8| j j d d d d |r"| j D ] }|j y y # t j
$ r Y ]w xY w# 1 sw Y GxY wr ) r[ r rT r6 r7 r8 r cancelr rX r )r waitrz rA r
s r shutdownzThreadPoolExecutor.shutdown s
!DN $($4$4$?$?$A !,!((//1
& ! ]] # !;; !
s- B1B8B1B.+B1-B..B11B:)N Nr/ )T)r( r) r* itertoolscount__next__r\ r rh r ExecutorrE re r5 r~ r/ r r rG rG z ss y ))H<>,.$"L" ^^**22FN2. SE ( ~~..66Hr rG ) rE
__author__concurrent.futuresr r r7 rU r, rs rM WeakKeyDictionaryr r rZ r r _register_atexithasattrr rp _at_fork_reinitr: clearr rB BrokenExecutorrD r rG r/ r r r s %
1
$ ,'++- ' ( < ( 2!"B 4 < <'<'L'L(=(E(EG B'<'<=8 8.+D\u++ v7 v7r