+
    Biy                        ^ RI t ^ RIt^ RIt^ RIt^ RIt^ RIHt ^ RIHtH	t	H
t
HtHtHt ^ RIHt ^ RIHt ^ RIHt ]RR3R lt]! ]R7      t]! ]	R7      t]! ]
R7      t]! ]R7      t]! ]]! 4       R	7      t]! ]^*R
7      t ! R R]P8                  4      t ! R R4      t ! R R]4      t]P@                  ! RRR7       ! R R]4      4       t! ! R R]4      t" ! R R]4      t# ! R R]4      t$]3]]!]"]$]#33R lt%R t&R# )    N)futures)PENDINGRUNNING	CANCELLEDCANCELLED_AND_NOTIFIEDFINISHEDFuture)_check_system_limits)support)threading_helperc                 >    \        4       pWn        Wn        W#n        V# N)r	   _state
_exception_result)state	exceptionresultfs   &&& 8/usr/lib/python3.14/test/test_concurrent_futures/util.pycreate_futurer      s    AHLIH    )r   )r   r   )r   r   c                   ,   a  ] tR t^ t o R tR tRtV tR# )BaseTestCasec                :    \         P                  ! 4       V n        R # r   )r   threading_setup_thread_keyselfs   &r   setUpBaseTestCase.setUp!   s    +;;=r   c                l    \         P                  ! 4        \        P                  ! V P                  !   R # r   )r   reap_childrenr   threading_cleanupr   r   s   &r   tearDownBaseTestCase.tearDown$   s"    **D,<,<=r   )r   N)__name__
__module____qualname____firstlineno__r    r%   __static_attributes____classdictcell____classdict__s   @r   r   r       s     >> >r   r   c                   L   a a ] tR t^)t o^t/ tV 3R ltV 3R ltR tRt	Vt
V ;t# )ExecutorMixinc                  < \         SV `  4        \        P                  ! 4       V n        \        V R 4      '       dc   V P                  ! RRV P                  RV P                  4       /V P                  B V n
        V P                  4       P                  4       V n        R# V P                  ! RRV P                  /V P                  B V n
        RV n        R# )ctxmax_workers
mp_contextN )superr    time	monotonict1hasattrexecutor_typeworker_countget_contextexecutor_kwargsexecutorManagermanagerr   	__class__s   &r   r    ExecutorMixin.setUp-   s    .."4 .. ( --(++-( &&(DM  ++-557DL .. ( --(&&(DM  DLr   c                  < V P                   P                  R R7       RV n         V P                  e"   V P                  P                  4        RV n        \        P                  ! 4       V P
                  ,
          p\        P                  '       d   \        RV,          RR7       V P                  VRR4       \        SV `-  4        R# )T)waitNz%.2fs )endi,  z+synchronization issue: test lasted too long)r?   shutdownrA   r7   r8   r9   r   verboseprint
assertLessr6   r%   )r   dtrC   s   & r   r%   ExecutorMixin.tearDown=   s    D)<<#LL!!#DL^^'???'B,C(C!NOr   c                B    \         P                  ! V P                  4      # r   )multiprocessingr=   r2   r   s   &r   r=   ExecutorMixin.get_contextK   s    **48844r   )r?   rA   r9   )r'   r(   r)   r*   r<   r>   r    r%   r=   r+   r,   __classcell__rC   r.   s   @@r   r0   r0   )   s#     LO  5 5r   r0   c                   >   a  ] tR t^Ot o ]P
                  tR tRtV t	R# )ThreadPoolMixinc                ,    \         P                  ! 4       # r   )	threadingEventr   s   &r   create_eventThreadPoolMixin.create_eventR   s      r   r5   N)
r'   r(   r)   r*   r   ThreadPoolExecutorr;   rY   r+   r,   r-   s   @r   rU   rU   O   s     ..M! !r   rU   z.gh-129824: data races in InterpreterPool testsTthreadc                   >   a  ] tR t^Vt o ]P
                  tR tRtV t	R# )InterpreterPoolMixinc                (    V P                  R 4       R# )z.InterpreterPoolExecutor doesn't support eventsN)skipTestr   s   &r   rY   !InterpreterPoolMixin.create_eventZ   s    FGr   r5   N)
r'   r(   r)   r*   r   InterpreterPoolExecutorr;   rY   r+   r,   r-   s   @r   r_   r_   V   s     33MH Hr   r_   c                   T   a a ] tR t^^t o]P
                  tRtV 3R ltR t	Rt
VtV ;t# )ProcessPoolForkMixinforkc                "  <  \        4        \        P                  R8X  d   V P                  R4       \
        P                  ! RR7      '       d   V P                  R4       \        SV `!  4       #   \         d    T P                  R 4        Li ; i.ProcessPoolExecutor unavailable on this systemwin32zrequire unix systemTr\   z'TSAN doesn't support threads after fork	r
   NotImplementedErrorra   sysplatformr   check_sanitizerr6   r=   rB   s   &r   r=    ProcessPoolForkMixin.get_contextb   v    	L " <<7"MM/0""$//MMCDw"$$ # 	LMMJK	L   
A/ /BBc                6    V P                   P                  4       # r   rA   rX   r   s   &r   rY   !ProcessPoolForkMixin.create_eventm       ||!!##r   r5   r'   r(   r)   r*   r   ProcessPoolExecutorr;   r2   r=   rY   r+   r,   rR   rS   s   @@r   re   re   ^   s$     //M
C	%$ $r   re   c                   T   a a ] tR t^qt o]P
                  tRtV 3R ltR t	Rt
VtV ;t# )ProcessPoolSpawnMixinspawnc                z   <  \        4        \        SV `  4       #   \         d    T P                  R 4        L,i ; i)ri   )r
   rl   ra   r6   r=   rB   s   &r   r=   !ProcessPoolSpawnMixin.get_contextu   s?    	L " w"$$ # 	LMMJK	Ls   
 ::c                6    V P                   P                  4       # r   rt   r   s   &r   rY   "ProcessPoolSpawnMixin.create_event|   rv   r   r5   rw   rS   s   @@r   rz   rz   q   s$     //M
C%$ $r   rz   c                   T   a a ] tR t^t o]P
                  tRtV 3R ltR t	Rt
VtV ;t# )ProcessPoolForkserverMixin
forkserverc                "  <  \        4        \        P                  R8X  d   V P                  R4       \
        P                  ! RR7      '       d   V P                  R4       \        SV `!  4       #   \         d    T P                  R 4        Li ; irh   rk   rB   s   &r   r=   &ProcessPoolForkserverMixin.get_context   rq   rr   c                6    V P                   P                  4       # r   rt   r   s   &r   rY   'ProcessPoolForkserverMixin.create_event   rv   r   r5   rw   rS   s   @@r   r   r      s$     //M
C	%$ $r   r   c                     R  pV R,          pV FN  pV! VP                   4      : V! VP                   4      : R2p\        Wq3V3,           V,           RV/4      pWV&   KP  	  R# )c                 v    V P                  R4      '       d   V RR # V P                  R4      '       d   V RR # V # )MixinNTest)r   Tests)endswith)names   &r   strip_mixin*create_executor_tests.<locals>.strip_mixin   s>    ==+,,9]]6""9Kr   r'   r   r(   N)r'   type)	remote_globalsmixinbasesexecutor_mixinsr   moduleexer   clss	   &&&&     r   create_executor_testsr      sc     J'Fs||,k%...IK4SF*U2\64JK"t	 r   c                      \        4        \        P                  ! \        P                  P
                  4       \        P                  ! 4       p \        P                  ! \        P                  .V O5!   R #   \         d     LJi ; ir   )
r
   unittestaddModuleCleanuprP   util_cleanup_testsrl   r   r   r$   )thread_infos    r   setup_moduler      sf    G 	!!/"6"6"E"EF"224K.@@O;O  s   
A7 7BB)'rP   rm   rW   r7   r   
concurrentr   concurrent.futures._baser   r   r   r   r   r	   concurrent.futures.processr
   testr   test.supportr   r   PENDING_FUTURERUNNING_FUTURECANCELLED_FUTURECANCELLED_AND_NOTIFIED_FUTUREOSErrorEXCEPTION_FUTURESUCCESSFUL_FUTURETestCaser   r0   rU   skip_if_sanitizerr_   re   rz   r   r   r   r5   r   r   <module>r      s&    
      <  )  4  W-W- y1  -4J K  x79E !< >8$$ >#5 #5L!m ! 	KTXYH= H ZH$= $&$M $$ $& 9E+:+?+?+E+@	+B#,	Pr   