TAiSrSSKJr SSKrSSKJrJr SSKJrJ r SSK J r J r SSK JrJr \ "S5rS rSS jr"S S \5rSS jr"SS\5rg)z"OCRmyPDF concurrency abstractions.) annotationsN)ABCabstractmethod)CallableIterable)AnyTypeVar)NullProgressBar ProgressBarTcgN)_args_kwargss P/var/www/html/land-ocr/venv/lib/python3.13/site-packages/ocrmypdf/_concurrent.py _task_nooprs c$UR5 gr)update)_resultpbars r_task_finished_nooprs KKMrc\rSrSrSr\R "5r\r SS.Sjr SSSSS.S Sjjr \ S Sj5r Srg) ExecutorzAbstract concurrent executor.N pbar_classc U(aXlggrr)selfrs r__init__Executor.__init__ s (O r)worker_initializertasktask_arguments task_finishedc U(dgU(d[nU(d[nU(d[nUR URUUUUUUUS9 SSS5 g!,(df  g=f)abSet up parallel execution and progress reporting. Args: use_threads: If ``False``, the workload is the sort that will benefit from running in a multiprocessing context (for example, it uses Python heavily, and parallelizing it with threads is not expected to be performant). max_workers: The maximum number of workers that should be run. progress_kwargs: Arguments to set up the progress bar. worker_initializer: Called when a worker is initialized, in the worker's execution context. If the child workers are processes, it must be possible to marshall/pickle the worker initializer. ``functools.partial`` can be used to bind parameters. task: Called when the worker starts a new task, in the worker's execution context. Must be possible to marshall to the worker. task_finished: Called when a worker finishes a task, in the parent's context. task_arguments: An iterable that generates a group of parameters for each task. This runs in the parent's context, but the parameters must be marshallable to the worker. N) use_threads max_workersprogress_kwargsr#r$r%r&)rr pool_lock_executer r(r)r*r#r$r%r&s r__call__Executor.__call__$s[@ !!+ /MD ^^ MM'' /#5-+  ^^s A A)cg)z-Custom executors should override this method.Nrr-s rr,Executor._executeXsr)r(boolr)intr*dictr#zCallable | Noner$zCallable[..., T] | Noner%zIterable | Noner&z'Callable[[T, ProgressBar], None] | NonereturnNoner(r2r)r3r*r4r#rr$rr%rr&r)__name__ __module__ __qualname____firstlineno____doc__ threadingLockr+r rr!r.rr,__static_attributes__rrrrrs' I J%))/3(,*.AE22 2  2 , 2&2(2?2 2h < < <  < % < <! <  < \rSrSrSrSSjrSrg)SerialExecutorlzImplements a purely sequential executor using the parallel protocol. The current process/thread will be the worker that executes all tasks in order. As such, ``worker_initializer`` will never be called. cUR"S0UD6nUHn U"U 6n U"X5 M SSS5 g!,(df  g=f)Nrr) r r(r)r*r#r$r%r&rargsresults rr,SerialExecutor._executess<__ / /4&tf+'0 / /s 3 ArNr7)r8r9r:r;r<r,r?rrrrHrHlsR ,, ,  , % ,,!, ,rrH)rrrr )r5r)r< __future__rr=abcrrcollections.abcrrtypingrr ocrmypdf._progressbarr r r rrrrFrHrrrrSsP)"#.> CL J