+ "ݳjq#a0t$Rt^RIHt^RIt^RIt^RIt^RIt^RIt^RI H t H t ^RI H t ^RIHt^RIHtRtR]R &^tR ]R &]P*!4tRsR ]R &RsR]R&RsR]R&RRltRRltRRlt]!4;'d(]!]R4;'d]P<!4'*sR]R&Rs R]R&\>\@3s!R]R&Rs"R]R&R R!lt#R"R#lt$R$R%lt%R?R&R'llt&]R?R(R)ll4t'R*R/R+R,llt(R*RR-R./R/R0llt)R1R2/R3R4llt*R5R6lt+R7RR8R/R9R:llt,R;R<lt-R=R>lt.]P^!]*4.R@Ot0R#)Az>Shared thread-pool management for the high-level PCRE helpers.) annotationsN)CallableIterator)ThreadPoolExecutor)contextmanager)Finalz pcre-workerz Final[str] _POOL_NAMEz Final[int]_MIN_CORES_FOR_THREADSzThreadPoolExecutor | None _THREAD_POOL int | None_THREAD_POOL_WORKERS_PERFORMANCE_CPU_TOTALcV^8dQhRR/#returnint)formats"M/home/luca/screen-checking/.venv/lib/python3.14/site-packages/pcre/threads.py __annotate__rsCc@\P!4;'g^#)os cpu_countrrr _cpu_totalrs <<>  QrcV^8dQhRR/#rrboolr)rs"rrr s22T2rc$\4\8#)z?Report whether the threaded backend is allowed on this machine.)rr rrrthreading_supportedr" s <1 11rcV^8dQhRR/#rr)rs"rrr&srcH\pVeV#\PR8wd^pVsV#\P!.ROR\P R7p\ ^\VP444pVsV# \\\P3d ^pTsT#i;i)zFReturn macOS performance-tier logical CPUs when the kernel exposes it.darwinT)textstderr)sysctlz-nzhw.perflevel0.logicalcpu) r sysplatform subprocess check_outputDEVNULLmaxrstripOSError ValueErrorCalledProcessError)snapshotresultvalues r_performance_cpu_totalr6&s&H ||x$ M ++<!))E C ./F$ MZ%B%BC F# M sA A99"B! B!_is_gil_enabledr _THREADS_DEFAULTi`r_THREAD_AUTO_THRESHOLDztuple[bool, int]_THREAD_CONFIG_THREAD_POOL_CONFIGcV^8dQhRR/#rr)rs"rrrKs""c"rc\4'g^#\4p\4pV^8dV#\^V^,4#)r"rr6r.) cpu_totalperformance_totals r _max_threadsrBKs=   I.01  q)q. !!rc V^8dQhRRRR/#)rr5r rrr)rs"rrrUs:#rc\4pV^8Xd \R4hVfV#\V4pT^8:d \ R4hY!8dTpT# \\3dp\R4ThRp?ii;i)r?zGThreaded backend requires at least 8 CPU cores; refusing to create poolNz"max_workers must be an int or Nonezmax_workers must be >= 1)rB RuntimeErrorr TypeErrorr1)r5maximumresolvedexcs& r_determine_worker_countrJUsnG!| U   }Gu:1}344 O z "G<=3FGs A A- A((A-c V^8dQhRRRR/#)rtargetrrz4tuple[ThreadPoolExecutor, ThreadPoolExecutor | None]r)rs"rrrks"" "9"rc\e\V8Xd Vs\R3#\p\V\R7sVsVs\V3#)z?Return a pool for *target* while holding ``_THREAD_POOL_LOCK``.N) max_workersthread_name_prefix)r r r;rr)rLold_pools& r_pool_for_target_lockedrQksQ$8F$B$T!!H%%L"   !!rc V^8dQhRRRR/#)rrNr rrr)rs"rrrsJ:Lrc\4\;_uu_4\VeTM\4p\ V4wr#RRR4XeVP RR7X# +'giL(;i)z@Return the shared executor, creating or resizing it if required.NTwaitr6_THREAD_POOL_LOCKrJr rQshutdown)rNrLpoolrPs& rensure_thread_poolrZs_   (&2K8L 18 t$ K  s #A A, c V^8dQhRRRR/#)rrNr rz(Iterator[tuple[ThreadPoolExecutor, int]]r)rs"rrrs)))-)rc#2"Rp\4\;_uu_4\VeTM\4p\ V4wr1W23xRRR4VeVP RR7R#R# +'giL*;i TeTP RR7ii;i5i)apLease the pool state while a caller submits a batch of work. The lease is deliberately limited to executor acquisition and submission. Waiting for futures while holding the lock could deadlock if user work re-enters pool configuration. Reconfiguration cannot shut down the leased executor until the context exits, so every submission is accepted by a live executor. NTrTrV)rNrPrLrYs& r_thread_pool_submissionr]s+/H )  ,*6 = 0)rWr8r r9rrFr1r:)rqrr new_enabled new_thresholdrIs$$ rconfigure_threadsrws  *1/&tG} .   E #I q  !9::&!.%5  z* E :;D E   s- B A B B1 A==BB B cV^8dQhRR/#rr)rs"rrrsDrc\^,#r>r:rrrget_thread_defaultr{ ! rcV^8dQhRR/#rr)rs"rrrsCrc\^,#rrzrrrget_auto_thresholdrr|r)N) rirwrZrr{rprmrer")1__conditional_annotations____doc__ __future__ratexitrr+r) threadingcollections.abcrrconcurrent.futuresr contextlibrtypingrr__annotations__r RLockrWr r r rr"r6hasattrr7r8r9r:r;rBrJrQrZr]rerirmrprwr{rregister__all__)rs@rrst E"  .1%& J&%& &OO%*. '.#'j'%) )2 4-. C"#==(;(;(=4$%$%56L#M M"&Z&",".*))4DH!%7<: ! ! $ "<@2$% r