+ Jl^RIt^RIt^RIt^RI5RR.tRt!RR]4t!RR]4t !RR 4t !R R 4t !R R ]4t !RR]4t !RR]4t!RR] 4t!RR] 4tR#)N)*Pool TimeoutErrorzp Standard Python Pool implementation based on Python API for Intel(R) oneAPI Threading Building Blocks (oneTBB) c]tRt^OtRtRtR#)rz>Raised when a result is not available within the given timeoutN)__name__ __module__ __qualname____firstlineno____doc____static_attributes__r.build/lib/python3.14/site-packages/tbb/pool.pyrrOsHrca]tRt^TtoRtRRltR]!43RltRRltRRlt RRlt R]!4R3Rlt RR lt RR lt RR ltR tR tRtRtRtRtRtRtVtR#)rz The Pool class provides standard multiprocessing.Pool interface which is mapped onto oneTBB tasks executing in its thread pool c `RVn\4VnR.\4,VnR#)zv :param nworkers (integer) number of worker threads to start :param name (string) prefix for the worker threads' name FN)_closed task_group_tasksdefault_num_threads_pool)selfnworkersnames&&&r__init__ Pool.__init__Zs&   l W022 rc BVPWV4P4#)zOEquivalent of the apply() builtin function. It blocks till the result is ready.) apply_asyncget)rfuncargskwdss&&&&rapply Pool.applycs D15577rNc BVPWV4P4#)a,A parallel equivalent of the map() builtin function. It blocks till the result is ready. This method chops the iterable into a number of chunks which it submits to the process pool as separate tasks. The (approximate) size of these chunks can be specified by setting chunksize to a positive integer.) map_asyncr)rriterable chunksizes&&&&rmapPool.maphs~~di8<<>>rc T\RR7pVPWW44\V4#)a An equivalent of itertools.imap(). The chunksize argument is the same as the one used by the map() method. For very long iterables using a large value for chunksize can make the job complete much faster than using the default value of 1. Also if chunksize is 1 then the next() method of the iterator returned by the imap() method has an optional timeout parameter: next(timeout) will raise processing.TimeoutError if the result cannot be returned within timeout seconds. T as_iterator)OrderedResultCollector_create_sequencesiterrrr&r' collectors&&&& rimap Pool.imaprs(+t<  tyDIrc P\4pVPWW44\V4#)zThe same as imap() except that the ordering of the results from the returned iterator should be considered arbitrary. (Only when there is only one worker process is the order guaranteed to be "correct".))UnorderedResultCollectorr.r/r0s&&&& rimap_unorderedPool.imap_unordereds& -.  tyDIrc VP'dQh\VR7p\WW54pVPP V4V#)a[A variant of the apply() method which returns an ApplyResult object. If callback is specified then it should be a callable which accepts a single argument. When the result becomes ready, callback is applied to it (unless the call failed). callback should complete immediately since otherwise the thread which handles the results will get blocked.callback)r ApplyResultJobrrun)rrr r!r: apply_resultjobs&&&&& rrPool.apply_asyncs?<<<"H5 $d1 rc \VR7p\VRR7pVPWW64'gVP.4V#)aWA variant of the map() method which returns a ApplyResult object. If callback is specified then it should be a callable which accepts a single argument. When the result becomes ready callback is applied to it (unless the call failed). callback should complete immediately since otherwise the thread which handles the results will get blocked.r9Fr+)r;r-r. _set_valuerrr&r'r:r>r1s&&&&& rr%Pool.map_asyncsA#H5 -lN %%diKK  ! !" %rc \VR7p\VRR7pVPWW64'gVP\ .44V#)aA variant of the imap() method which returns an ApplyResult object that provides an iterator (next method(timeout) available). If callback is specified then it should be a callable which accepts a single argument. When the resulting iterator becomes ready, callback is applied to it (unless the call failed). callback should complete immediately since otherwise the thread which handles the results will get blocked.r9Tr+)r;r-r.rBr/rCs&&&&& r imap_asyncPool.imap_asyncsE#H5 -lM %%diKK  ! !$r( +rc \VR7p\V4pVPWW64'gVP\ .44V#)aA variant of the imap_unordered() method which returns an ApplyResult object that provides an iterator (next method(timeout) available). If callback is specified then it should be a callable which accepts a single argument. When the resulting iterator becomes ready, callback is applied to it (unless the call failed). callback should complete immediately since otherwise the thread which handles the results will get blocked.r9)r;r5r.rBr/rCs&&&&& rimap_unordered_asyncPool.imap_unordered_asyncsC#H5 / = %%diKK  ! !$r( +rc RVnR#)zPrevents any more tasks from being submitted to the pool. Once all the tasks have been completed the worker processes will exit.TN)rrs&rclose Pool.closes  rc ZVP4VPP4R#)zStops the worker processes immediately without completing outstanding work. When the pool object is garbage collected terminate() will be called immediately.N)rMrcancelrLs&r terminatePool.terminates  rc :VPP4R#)z`Wait for the worker processes to exit. One must call close() or terminate() before using join().N)rwaitrLs&rjoin Pool.joins rcV#NrrLs&r __enter__Pool.__enter__ rc&VP4R#rX)rU)rexc_type exc_value tracebacks&&&&r__exit__ Pool.__exit__s  rcFVP4VP4R#rX)rQrUrLs&r__del__ Pool.__del__s  rc VP'dQh\V4pRp.pV'g{.p\T;'g^4F9p \V4p \ T4p \ Y3/T 4p TPT 4K; V'gKfVP\V44KVFp VPPV 4K V# \dRpK]i;i)ap Create callable objects to process and pushes them on the work queue. Each work unit is meant to process a slice of iterable of size chunksize. If collector is specified, then the ApplyResult objects associated with the jobs will notify collector when their result becomes ready. eturn the list callable objects (basically: JobSequences) pushed onto the work queue FT) rr/rangenext StopIterationr;r<append JobSequencerr=)rrr&r'r1it_ exit_loop sequencesseq_argr>r?ts&&&&& rr.Pool._create_sequencess<<<8n  C9>>*s)C +95 $L9 3+s  S!12A KKOOA % $Is C  CC)rrr)rrrrX)NN)rr r r r rdictr"r(r2r6rr%rFrIrMrQrUrYr`rcr.r __classdictcell__ __classdict__s@rrrTss 3 "8 ?$&(dft   " rc0a]tRtRtoRtRtRtRtVtR#)r<i zBA work unit that corresponds to the execution of a single functionc 6WnW nW0nW@nR#)z :param func/args/kwds used to call the function :param apply_result ApplyResult object that holds the result of the function call N)_func_args_kwds_result)rrr r!r>s&&&&&rr Job.__init__ s    # rc VP!VP/VPBpVPP V4R# TPP 4R#;i)z Call the function with the args/kwds and tell the ApplyResult that its result is ready. Correctly handles the exceptions happening during the execution of the function N)r{r|r}r~rB_set_exception)rresults& r__call__ Job.__call__sM  ,ZZ:tzz:F LL # #F + * LL ' ' )s &AA$)r|r{r}r~N rr r r r rrr rvrws@rr<r< sL $ , ,rr<c0a]tRtRtoRtRtRtRtVtR#)rji&zVA work unit that corresponds to the processing of a continuous sequence of Job objectscWnR#rX_jobs)rjobss&&rrJobSequence.__init__*s rc :VPF pV!4K R#)z3 Call all the Job objects that have been specified Nr)rr?s& rrJobSequence.__call__-s::C ErrNrrws@rrjrj&srrjcZa]tRtRtoRtR RltR RltR RltRtRt R t R t R t Vt R#)r;i5aEAn object associated with a Job object that holds its result: it's available during the whole life the Job and after, even when the Job didn't process yet. It's possible to use this object to wait for the result/exception of the job to be available. The result objects returns by the Pool::*_async() methods are of this typeNc RVn\P!4VnRVnRVnW nVeVPV4WnR#R#)a :param collector when not None, the notify_ready() method of the collector will be called when the result from the Job is ready :param callback when not None, function to call when the result becomes available (this is the parameter passed to the Pool::*_async() methods. FN)_success threadingEvent_event_data _collector _callbackregister_result)rr1r:s&&&rrApplyResult.__init__>sJ oo'  !   % %d +'O !rc $VPV4'g\RV,4hVP'd VP#VP^,!VP^,4P VP^,4h)z Returns the result when it arrives. If timeout is not None and the result does not arrive within timeout seconds then TimeoutError is raised. If the remote call raised an exception then that exception will be reraised by get(). zResult not available within %fs)rTrrrwith_tracebackrtimeouts&&rrApplyResult.getQseyy!!@7JK K ===:: jjmDJJqM*99$**Q-HHrc lVPPV4VPP4#)zBWaits until the result is available or until timeout seconds pass.)rrTisSetrs&&rrTApplyResult.wait^s) !{{  ""rc 6VPP4#)z'Returns whether the call has completed.)rrrLs&rreadyApplyResult.readyds{{  ""rc JVP4'gQhVP#)zvReturns whether the call completed without raising an exception. Will raise AssertionError if the result is not ready.)rrrLs&r successfulApplyResult.successfulhszz|||}}rc TVP4'dQhWnRVnVPP 4VP eVP P V4VPeVPV4R#R# \P!4R#;i)zCalled by a Job object to tell the result is ready, and provides the value of this result. The object will become ready and successful. The collector's notify_ready() method will be called, and the callback method tooTN) rrrrsetr notify_readyrr_ print_exc)rvalues&&rrBApplyResult._set_valueos~ ::<<    ?? & OO ( ( . >> % &u% & &##%s 8B B'c VP4'dQh\P!4VnRVnVP P 4VPeVPPV4R#R#)zCalled by a Job object to tell that an exception occurred during the processing of the function. The object will become ready but not successful. The collector's notify_ready() method will be called, but NOT the callback methodFN) rsysexc_inforrrrrrrLs&rrApplyResult._set_exceptionsX ::<<\\^    ?? & OO ( ( . 'r)rrrrrrtrX)rr r r r rrrTrrrBrr rvrws@rr;r;5s3(& I# #&" / /rr;cFa]tRtRtoRtRtRtRtR RltRt R t Vt R#) AbstractResultCollectoriaABC to define the interface of a ResultCollector object. It is basically an object which knows whuich results it's waiting for, and which is able to get notify when they get available. It is also able to provide an iterator over the results when they are availablec WnR#zu :param to_notify ApplyResult object to notify when all the results we're waiting for become available. Can be None. N _to_notifyr to_notifys&&rr AbstractResultCollector.__init__s $rc \R4h)Used to identify which results we're waiting for. Will always be called BEFORE the Jobs get submitted to the work queue, and BEFORE the __iter__ and _get_result() methods can be called :param apply_result ApplyResult object to add in our collection "Children classes must implement itNotImplementedErrorrr>s&&rr'AbstractResultCollector.register_result""FGGrc \R4h)Called by the ApplyResult object (already registered via register_result()) that it is now ready (ie. the Job's result is available or an exception has been raised). :param apply_result ApplyResult object telling us that the job has been processed rrrs&&rr$AbstractResultCollector.notify_readyrrNc \R4h)BCalled by the CollectorIterator object to retrieve the result's values one after another (order defined by the implementation) :param idx The index of the result we want, wrt collector's order :param timeout integer telling how long to wait (in seconds) for the result at index idx to be available, or None (wait forever) rrridxrs&&&r _get_result#AbstractResultCollector._get_results""FGGrc \V4#)z8Return a new CollectorIterator object for this collector)CollectorIteratorrLs&r__iter__ AbstractResultCollector.__iter__s  &&rrrX) rr r r r rrrrrr rvrws@rrrs+ $HH H''rrc@a]tRtRtoRtRtRtR RltRtRt Vt R#) rizAn iterator that allows to iterate over the result values available in the given collector object. Equipped with an extended next() method accepting a timeout argument. Created by the AbstractResultCollector::__iter__() methodc Wn^VnR#)z':param AbstractResultCollector instanceNr_idx)rr1s&&rrCollectorIterator.__init__s# rcV#rXrrLs&rrCollectorIterator.__iter__r[rNc VPPVPV4pT;P^, unTP 4'gQhTP ^4# \d^Tn\h^Tnh;i)zwReturn the next result value in the sequence. Raise StopIteration at the end. Can raise the exception raised by the Job)rrr IndexErrorrhrr)rrr>s&& rrgCollectorIterator.nexts~ ??66tyy'JL Q !!####"" DI  DI s &A**!B c"VP4#rX)rgrLs&r__next__CollectorIterator.__next__syy{rrrX) rr r r r rrrgrr rvrws@rrrs#2  #"rrcHa]tRtRtoRtR RltRtR RltR RltRt Vt R#) r5izAn AbstractResultCollector implementation that collects the values of the ApplyResult objects in the order they become ready. The CollectorIterator object returned by __iter__() will iterate over them in the order they become readyNc \PW4\P!4Vn.Vn^VnR#r)rrr Condition_cond _collection _expectedrs&&rr!UnorderedResultCollector.__init__s1 ((9((* rc 8V;P^, unR#rN)rrs&&rr(UnorderedResultCollector.register_results !rc @VPP4WP8d\hV\ VP 48d.VP V,VPP 4#V\ VP 48wd \4hVPPVR7VP V,VPP 4# \d \R4hi;i TPP 4i;i)aMCalled by the CollectorIterator object to retrieve the result's values one after another, in the order the results have become available. :param idx The index of the result we want, wrt collector's order :param timeout integer telling how long to wait (in seconds) for the result at index idx to be available, or None (wait forever) )rz!Timeout while waiting for results) racquirerrlenrreleaserTrrs&&&rr$UnorderedResultCollector._get_results  !nn$  s4++,,'', JJ   D,,-- l" 0L++C0 JJ   "L&'JKKL JJ   s%AD9AD:C''C>>DDc RpVPP4VPPV4\ VP4^8HpVPP 4VPP 4V'd7VPe'VPP\V44R#R#R# TPP 4i;irFN) rrrrir notifyAllrrrBr/)rr> first_items&& rr%UnorderedResultCollector.notify_readys   !    # #L 1d../14J JJ " JJ   $//5 OO & &tDz 26: JJ   s A CC!)rrrrX rr r r r rrrrr rvrws@rr5r5s#+ !833rr5cDa]tRtRtoRtR RltRtR RltRtRt Vt R#) r-i+zAn AbstractResultCollector implementation that collects the values of the ApplyResult objects in the order they have been submitted. The CollectorIterator object returned by __iter__() will iterate over them in the order they have been submittedNc \PW4.Vn\P!4Vn^VnW nR#)a9 :param to_notify ApplyResult object to notify when all the results we're waiting for become available. Can be None. :param as_iterator boolean telling whether the result value set on to_notify should be an iterator (available as soon as 1 result arrived) or a list (available only after the last result arrived) N)rr_resultsrLock_lock _remaining _as_iterator)rrr,s&&&rrOrderedResultCollector.__init__1s4 ((9 ^^% 'rc nVPPV4V;P^, unR#r)rrirrs&&rr&OrderedResultCollector.register_result@s$ \* 1rc NVPV,pVPV4V#)r)rrT)rrrress&&& rr"OrderedResultCollector._get_resultJs#mmC   rc $RpRpVPP4VP^8gQh\VP4VP8HpV;P^,unVP^8HpVPP 4VP eVP'd/V'd'VP P\V44R#VP'gRV'dHVPUu.uFqDP^4NK ppVP PV4R#R#R#R# TPP 4i;iuupi TP P4R#;ir) rrrrrrrrrBr/rr)rr> got_firstgot_lastrlsts&& rr#OrderedResultCollector.notify_readyWs'   !??Q& &&T]]+t>I OOq O1,H JJ   ?? &   Y**4:6&&&84-1]];]558]C;OO..s3 ,4& ' JJ   <5OO224s*AE E0E+'E0 E(+E00F)rrrr)NTrXrrws@rr-r-+s$D ( 44rr-)rrr_api__all__r Exceptionrobjectrr<rjr;rrr5r-rrrrsF  > "   9 s6sl,,8  V/&V/r-'f-'`  FG36G3TG44G4r