&hSrSrSrSrSSKJrJr SSKr\Rr\ "5r \ "5r Sq Sq SrSSjrS rSS jr"S S 5r"S S5rSSjrg)z * Experimental * Like the map function, but can use a pool of threads. Really easy to use threads. eg. tmap(f, alist) If you know how to use the map function, you can use threads. z Rene Dudfieldz0.3.0zPython license)QueueEmptyN@cJU(aUqO [5q[[5qg)zDoes a little test to see if threading is worth it. Sets up a global worker queue if it's worth it. Calling init() is not required, but is generally better to do. N) _use_workersbenchmark_workers WorkerQueue_wq)number_of_workerss O/var/www/auris/envauris/lib/python3.13/site-packages/pygame/threads/__init__.pyinitr 's ( (*  l #Cc4[R5 SqSqg)zcleans up everything.NF)r stoprrr quitr8sHHJ CLrcR^SSKmSSKmSSKnU(dU4SjnOUnU(d-[S5Vs/sHnTR SSS5PM nnOUnUR5S-nSn[S[ 5Hn[ U5n UR5n [S5H.n [S [R"535 [X5U S 9 M0 UR5n U R5 X- n [S US U S 35 X:aUnU nX- S:dM U$ U$s snf)a#does a little test to see if workers are at all faster. Returns the number of workers which works best. Takes a little bit of time to run, so you should only really call it once. You can pass in benchmark data, and functions if you want. a_bench_func - f(data) the_data - data to work on. rNc<>TRRUS5$)N)i i@) transformscale)xpygames r doitbenchmark_workers..doitVs##))!Z8 8r )r iz active count:) worker_queueztotal time num_workers:z: time::) rpygame.transformtimerangeSurfaceMAX_WORKERS_TO_TESTr print threading active_counttmapr) a_bench_functhe_datar#rrthedatabest best_number num_workerswqt1_t2 total_timers @r rr@s$   9 >CBiHi6>>*a4iH 99; "DKQ 34  % YY[rA M)"8"8":!;< = R 0YY[  W  ' }GJURRXU45 g)z-puts a function on a queue for running later.N)r:put)r=fargskwArgss r doWorkerQueue.dos ()rcURR[5 URHnUR 5 M g)zAStops the WorkerQueue, waits for all of the threads to finish up.N)r:rJSTOPr;join)r=threads r rWorkerQueue.stops) tiiF KKM rcXURR5nU[La:URR[5 URR 5 gUS"US0USD6 URR 5 M!URR 5 f=f)z*Loops until all of the tasks are finished.rr!N)r:getrQrJ task_done)r=rLs r rDWorkerQueue.threadloops::>>#Dt| t$ $$& 'Qa,DG, $$& $$&s B B)c8URR5 g)z#waits until all tasks are complete.N)r:rR)r=s r waitWorkerQueue.waits r)r;r:N)r) __name__ __module__ __qualname____firstlineno__r>r<rNrrDr[__static_attributes__rrr r r s ) * 'rr c(\rSrSrSrSSjrSrSrg) FuncResultzkUsed for wrapping up a function call so that the results are stored inside the instances result attribute. NcDXlSUlSUlX lX0lg)zf - is the function we that we call callback(result) - this is called when the function(f) returns errback(exception) - this is called when the function(f) raises an exception. N)rK exceptionresultcallbackerrback)r=rKrhris r r>FuncResult.__init__s!    rc*UR"U0UD6UlUR(aURUR5 gg![aAnX0lUR (a UR UR5 SnAgSnAgSnAff=fr9)rKrgrh Exceptionrfri)r=rLkwargses r __call__FuncResult.__call__sl -&&$1&1DK}} dkk* -N|| T^^,, -sAA B2B  B)rhrirfrKrgNN)r]r^r_r`__doc__r>rorarrr rcrcs  -rrcc U(aUnO.[(a[nOUS:Xa [X5$[U5n[UR5S:Xa [X5$/nUH2nUR [ U55 URUSU5 M4 U(aUR5 URR5(a [S5eU(dh[(d]UR5 URR5(a.URR5n U [La [S5eU(a,[[!SU55n U (aU SR"eSU5$Xg/$)alike map, but uses a thread pool to execute. num_workers - the number of worker threads that will be used. If pool is passed in, then the num_workers arg is ignored. worker_queue - you can optionally pass in an existing WorkerQueue. wait - True means that the results are returned when everything is finished. False means that we return the [worker_queue, results] right away instead. results, is returned as a list of FuncResult instances. stop_on_error - rzbuggy threadmapcUR$r9)rf)rs r tmap.. sq{{rc38# UHoRv M g7fr9)rg).0rs r tmap..s*'Q's)r mapr lenr;rBrcrNr[r:qsize RuntimeErrorrrWrQlistfilterrf) rKseq_argsr0rr[ stop_on_errorr1resultssaum error_oness r r*r*s2  3Ba1''[)B 277|q1Gz!}% gbk2     88>>  01 1CC GGIxx~~XX\\^T>&'899 f%:GDEJ m---*'** =r)rrq)rNTT)rr __author__ __version__ __license__r:rrr(rCobjectrQFINISHr rr&r rrr rcr*rrr rs}       x    $"<~..b--:Br