+
     Bi                         R t ^ RIHt ^ RIt^ RIt^RIHt ^ RItR t	 ! R R]P                  4      t
 ! R R]P                  4      t ! R	 R
]P                  4      tR# )z#Implements InterpreterPoolExecutor.)interpretersN)threadc                     V! V/ VB #   \          dv   p T P                  T4       h   \        P                   dF    \	        R \
        P                  R7       \        P                  ! T4       T P                  R4        h i ; iRp?ii ; i)zexception is not shareable:)fileN)	BaseExceptionputr   NotShareableErrorprintsysstderr	tracebackprint_exception)resultsfuncargskwargsexcs   &&&& 5/usr/lib/python3.14/concurrent/futures/interpreter.pydo_callr   
   s    T$V$$ 
	KK 	 -- 	/cjjA%%c*KK	
s0   
 B
(BAB?BBBB
c                   N   a  ] tR t^t o ]R 4       tR tR tR tR t	R t
RtV tR# )	WorkerContextc                   a a R  pVe    V! W/ 4      oMRoV V3R lpWC3#   \          d0    \        T\        4      '       d   T'       d   \        RT: 24      hh i ; i)c                 P    \        V \        4      '       d   \        R 4      hWV3pV# )zscripts not supported)
isinstancestr	TypeError)fnr   r   tasks   &&& r   resolve_task+WorkerContext.prepare.<locals>.resolve_task   s*    "c"" 788&)K    Nz.an initializer script does not take args, got c                     < S ! S4      # N )clsinitdatas   r   create_context-WorkerContext.prepare.<locals>.create_context/   s    x= r    )
ValueErrorr   r   )r$   initializerinitargsr   r&   r%   s   f&&  @r   prepareWorkerContext.prepare   sn    	 "'rB H	!++  k3//H$'UV^Ua%bccs   	! (A
Ac                .    Wn         R V n        R V n        R # r"   r%   interpr   )selfr%   s   &&r   __init__WorkerContext.__init__3   s     r    c                F    V P                   e   V P                  4        R # R # r"   )r/   finalize)r0   s   &r   __del__WorkerContext.__del__8   s    ;;"MMO #r    c                R   V P                   e   Q V P                   4       h\        P                  ! 4       V n          ^ p\        P                  ! V4      V n        V P
                  '       d   V P                  V P
                  4       R # R #   \         d    T P                  4        h i ; ir"   )	r/   r   createcreate_queuer   r%   runr   r4   )r0   maxsizes   & r   
initializeWorkerContext.initialize<   s    {{"/DKK/""))+	G'44W=DL}}}'  	MMO	s   .B	 *B	 	B&c                    V P                   pV P                  pR V n        R V n         Ve   ?Ve   VP                  4        R # R # r"   )r/   r   close)r0   r/   r   s   &  r   r4   WorkerContext.finalizeI   s?    ,,LLN r    c                     V P                   P                  ! \        V P                  .VO5!  #   \        P
                   d'   pT P                  P                  4       pTf   h Y2hR p?ii ; ir"   )r/   callr   r   r   ExecutionFailedget)r0   r   wrapperr   s   &&  r   r:   WorkerContext.runS   s]    	#;;##GT\\ADAA++ 	#,,""$C{"	#s   ,/ A*!A%%A*r.   N)__name__
__module____qualname____firstlineno__classmethodr+   r1   r5   r<   r4   r:   __static_attributes____classdictcell__)__classdict__s   @r   r   r      s5     , ,,
	# 	#r    r   c                       ] tR t^_tRtRtR# )BrokenInterpreterPoolzP
Raised when a worker thread in an InterpreterPoolExecutor failed initializing.
r#   N)rG   rH   rI   rJ   __doc__rL   r#   r    r   rP   rP   _   s    r    rP   c                   J   a a ] tR t^et o]t]R 4       tRV 3R lltRt	Vt
V ;t# )InterpreterPoolExecutorc                ,    \         P                  W4      # r"   )r   r+   )r$   r)   r*   s   &&&r   prepare_context'InterpreterPoolExecutor.prepare_contexti   s    $$[;;r    c                b   < T;'       g    RV P                  4        2p\        SV `	  WW44       R# )a  Initializes a new InterpreterPoolExecutor instance.

Args:
    max_workers: The maximum number of interpreters that can be used to
        execute the given calls.
    thread_name_prefix: An optional name prefix to give our threads.
    initializer: A callable or script used to initialize
        each worker interpreter.
    initargs: A tuple of arguments to pass to the initializer.
zInterpreterPoolExecutor-N)_countersuperr1   )r0   max_workersthread_name_prefixr)   r*   	__class__s   &&&&&r   r1    InterpreterPoolExecutor.__init__m   s<     1 M M!9$--/9JK 	$	0r    r#   )N Nr#   )rG   rH   rI   rJ   rP   BROKENrK   rU   r1   rL   rM   __classcell__)r\   rN   s   @@r   rS   rS   e   s&     "F< <0 0r    rS   )rQ   
concurrentr   r
   textwrapr^   r   _threadr   r   r   BrokenThreadPoolrP   ThreadPoolExecutorrS   r#   r    r   <module>rf      sU    ) # 
    B#G)) B#JG44 0g88 0r    