python (3.12.0)
ˑe" d Z dZddlmZ ddlZddlZddlZddlZddlZddl Z ej Z da ej Zd Z ej e ee d r3 e j$ ej& ej( ej* G d d
Zd Z G d d
ej0 Z G d dej4 Zy)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 M/BuggyBox/python/3.12.0/bootstrap/lib/python3.12/concurrent/futures/thread.py _python_exitr sl &&( )E 1 d 1 s A%%A.register_at_fork)beforeafter_in_childafter_in_parentc < e Zd Zd Zd Z eej Zy) _WorkItemc < || _ || _ || _ || _ y N)futurefnargskwargs)selfr r r r s r __init__z_WorkItem.__init__/ 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.run5 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 E 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 s 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!";<K ! AB B "8K+@ <= = ' ,,. ( 2 21 5
'nn .$6 %P%<t}}%N
'!r c | j 5 t 5 | j rt | j | j r t d t r t d t
j }t |||| }| j j | | j |cd d d cd d d S # 1 sw Y nxY wd d d y # 1 sw Y y xY w)Nz*cannot schedule new futures after shutdownz6cannot schedule new futures after interpreter shutdown) r[ r rY rD r RuntimeErrorr Futurer rT r _adjust_thread_count)r r r r fws r submitzThreadPoolExecutor.submit s
"7 ||&t||44~~"#OPP" $: ; ; A!Rv.A # % % ' s# CBB?, C?C CC c | j j d ry | j fd}t | j }|| j
k rd| j xs | |fz }t j |t t j | | | j | j | j f }|j | j j | | j t |< y y )Nr )timeoutc & |j d y r )r )_r s r
weakref_cbz;ThreadPoolExecutor._adjust_thread_count.<locals>.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
S 4DL $ 0 0 ; ; =I ( $$223CDLL3QR
{{
S
S
Ss- 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 y 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: r rB BrokenExecutorrD r rG r/ r r <module>r s %
1
$ ,'++- ' ( < ( 2!"B 4 < <'<'L'L(=(E(EG
8 8.+D\u++ v7 v7r 
Browse
Usage
Versions