+
    Bi1                         ^ RI t ^ RIHtHt ^ RIHt ^ RIHt ]P                  ! RR7        ! R R] P                  4      t
]R	8X  d   ] P                  ! 4        R# R# )
    N)ThreadBarrier)batched)threading_helperT)modulec                   D   a  ] tR t^	t o ]P
                  R 4       tRtV tR# )EnumerateThreadingc           	       a	 ^
p^p\        V4      o	V	3R lp\        \        R4      4      p\        V4       Fw  p\        V^4      p. p\        V4       F  pVP	                  \        W6.R7      4       K!  	  \        P                  ! V4      ;_uu_ 4         RRR4       S	P                  4        Ky  	  R#   + '       g   i     L&; i)
   c                 f   < SP                  4          \        V 4      pK    \         d     R# i ; i)TN)waitnextStopIteration)it_barriers   & F/usr/lib/python3.14/test/test_free_threading/test_itertools_batched.pywork/EnumerateThreading.test_threading.<locals>.work   s/    LLNRA$ s   ! 00i  )targetargsN)	r   tupleranger   appendr   r   start_threadsreset)
selfnumber_of_threadsnumber_of_iterationsr   datar   batch_iteratorworker_threadsiir   s
   &        @r   test_threading!EnumerateThreading.test_threading   s    !+,	 U4[!,-B$T1-NN-.%%$-=>@ / "//?? @ MMO . @?s   B33C N)	__name__
__module____qualname____firstlineno__r   reap_threadsr$   __static_attributes____classdictcell__)__classdict__s   @r   r	   r	   	   s     "" #    r	   __main__)unittest	threadingr   r   	itertoolsr   test.supportr   requires_working_threadingTestCaser	   r'   mainr&   r/   r   <module>r8      sK     %  )  + +4 8** 8 zMMO r/   