+
    Bi                         ^ RI t ^ RIt^ RIt^ RIt^ RIHt ^ RIHtHtH	t	 ^ RI
Ht ^RIHtHtHtHtHtHtHtHt R t ! R R4      t]! ]! 4       ]4       R	 t]R
8X  d   ]P4                  ! 4        R# R# )    N)futures)CANCELLED_AND_NOTIFIEDFINISHEDFuture)support)PENDING_FUTURERUNNING_FUTURECANCELLED_AND_NOTIFIED_FUTUREEXCEPTION_FUTURESUCCESSFUL_FUTUREcreate_futurecreate_executor_testssetup_modulec                     W,          # N )xys   &&E/usr/lib/python3.14/test/test_concurrent_futures/test_as_completed.pymulr      s	    5L    c                   >   a  ] tR t^t o R tR tR tR tR tRt	V t
R# )AsCompletedTestsc           	     >   V P                   P                  \        ^^4      pV P                   P                  \        ^^4      p\        \        P
                  ! \        \        \        W.4      4      pV P                  \        \        \        \        W.4      V4       R#    N)
executorsubmitr   setr   as_completedr
   r   r   assertEqual)selffuture1future2	completeds   &   r   test_no_timeout AsCompletedTests.test_no_timeout   s    --&&sAr2--&&sAq1,,.!"#$ %	
 	.!"#$
 	r   c                   \         \        \        0pRp^ V3 F  pV P                  V4      ;_uu_ 4        \	        4       pV P
                  P                  \        P                  V^
,          4      p \        P                  ! W0,          V4       F  pVP                  V4       K  	  V P                  WA4       RRR4       K  	  R#   \        P                   d     L6i ; i  + '       g   i     K  ; i)zMTest ``futures.as_completed`` timing out before
completing it's final future.g?N)r
   r   r   subTestr   r   r   timesleepr   r    addTimeoutErrorr!   )r"   already_completedshort_timeouttimeoutcompleted_futuresfuturefs   &      r   test_future_times_out&AsCompletedTests.test_future_times_out&   s     ;-.0
 =)Gg&&$'E!--djj-":LM$11)H4 *--a0	   !2F '& * ++  '&&s/   <C!16C'C!C	C!C	C!!C2c                   V P                   P                  \        P                  ^4      p\        P
                  ! \        P                  ! V^4      4       Uu. uF  q"NK  	  ppV P                  \        V4      ^4       R# u upi r   )
r   r   r*   r+   r   r    	itertoolsrepeatr!   len)r"   r#   r3   r%   s   &   r   test_duplicate_futures'AsCompletedTests.test_duplicate_futuresA   sn     --&&tzz15++I,<,<Wa,HI
I!AI 	 
 	Y+
s   
Bc                   \        ^4       Uu. uF  p\        4       NK  	  ppVP                  \        \        R7      4       VP                  \        \
        ^*R7      4       V P                  \        P                  4      ;_uu_ 4        \        P                  ! V^ R7       FV  pVP                  V4       \        P                  ! V4      p?\        P                  ! 4        V P                  V! 4       4       KX  	  RRR4       V^ ,          P!                  R4       \        P                  ! V4       Fx  pVP                  V4       \        P                  ! V4      p?\        P                  ! 4        V P                  V! 4       4       V'       g   K`  V^ ,          P!                  R4       Kz  	  R# u upi   + '       g   i     L; i)   )state)r>   resultr0   Ntest)ranger   appendr   r   r   assertRaisesr   r-   r    removeweakrefrefr   
gc_collectassertIsNone
set_result)r"   _futures_listr2   wrs   &    r   "test_free_reference_yielded_future3AsCompletedTests.test_free_reference_yielded_futureK   s?    +0(3(Q(3M0FGHMDEw3344!..|QG##F+[[(""$!!"$' H 5 	Q""6***<8F'V$B bd#|Q**62 9 4 54s   F0	A3F55G	c           	     D   \         \        \        \        .pV P	                  \
        P                  4      ;_uu_ 4       p\        \
        P                  ! V^ R7      4       RRR4       V P                  \        XP                  4      R4       R#   + '       g   i     L7; i)r   r@   Nz2 (of 4) futures unfinished)r
   r   r	   r   rD   r   r-   listr    r!   str	exception)r"   rL   cms   &  r   "test_correct_timeout_exception_msg3AsCompletedTests.test_correct_timeout_exception_msgd   sn    5~&(9; w3344%%lA>? 5 	R\\*,IJ 54s   "BB	r   N)__name__
__module____qualname____firstlineno__r&   r4   r:   rN   rU   __static_attributes____classdictcell__)__classdict__s   @r   r   r      s&      G6,32K Kr   r   c                      \        4        R # r   )r   r   r   r   setUpModuler_   q   s    Nr   __main__)r7   r*   unittestrF   
concurrentr   concurrent.futures._baser   r   r   rA   r   utilr   r	   r
   r   r   r   r   r   r   r   globalsr_   rW   mainr   r   r   <module>rg      sr        . . 8 8 8VK VKr gi!1 2 zMMO r   