Hi&ddlZddlZddlmZddlmZddgZdZGddZGddZ Gd d e Z dS) N)queue) greenlets GreenPool GreenPileTcbeZdZdZddZdZdZdZdZdZ d Z d Z d Z d Z d ZdZdZdS)rz4The GreenPool class is a pool of green threads. c t|}nQ#t$rD}dt|t |}t |d}~wwxYw|dkr1dt |}t|||_t|_ tj ||_ tj |_dS)Nz-GreenPool() expect size :: int, actual: {} {}rz(GreenPool() expect size >= 0, actual: {})int ValueErrorformattypestr TypeErrorreprsizesetcoroutines_runningeventlet SemaphoresemEventno_coros_running)selfremsgs W/home/mmwave/public_html/mmwave/venv/lib/python3.11/site-packages/eventlet/greenpool.py__init__zGreenPool.__init__s !t99DD ! ! !AHHdUXYZU[U[\\CC..  ! !88<CCDJJOOCS// ! "%%%%d++ ( 0 0s A ?AA cR||jz }|jxj|z c_||_dS)a Change the max number of greenthreads doing work at any given time. If resize is called when there are more than *new_size* greenthreads already working on tasks, they will be allowed to complete but no new tasks will be allowed to get launched until enough greenthreads finish their tasks to drop the overall quantity below *new_size*. Until then, the return value of free() will be negative. N)rrcounter)rnew_size size_deltas rresizezGreenPool.resizes1 )  J& c*t|jS)zd Returns the number of greenthreads that are currently executing functions in the GreenPool.)lenrrs rrunningzGreenPool.running+s4*+++r#c|jjS)z Returns the number of greenthreads available for use. If zero or less, the next call to :meth:`spawn` or :meth:`spawn_n` will block the calling greenthread until a slot becomes available.)rrr&s rfreezGreenPool.free0s xr#ctj}|jrA||jvr8tj|}|||||S|jtj |g|Ri|}|jstj |_ |j || |j|S)a Run the *function* with its arguments in its own green thread. Returns the :class:`GreenThread ` object that is running the function, which can be used to retrieve the results. If the pool is currently at capacity, ``spawn`` will block until one of the running greenthreads completes its task and frees up a slot. This function is reentrant; *function* can call ``spawn`` on the same pool without risk of deadlocking the whole thing. )r getcurrentrlockedr greenthread GreenThreadmainacquirespawnrraddlink _spawn_done)rfunctionargskwargscurrentgts rr1zGreenPool.spawn7s%'' 8??   &D,C!C!C%11'::B GGHdF + + +I H     :4:::6::B* 9(0(8(8%  # ' ' + + + GGD$ % % % r#cN ||i|n=#tttjf$rtrt jYnxYw|*tj}| |dSdS#|)tj}| |wwxYwN) KeyboardInterrupt SystemExitgreenlet GreenletExitDEBUG traceback print_excrr+r4)rfuncr6r7coros r _spawn_n_implzGreenPool._spawn_n_implTs ' *d%f%%%%%z83HI    **')))*,,  &&&&& t*,,  &&&& s A78AA77-B$ctj}|jr#||jvr||||ddS|jtj|j|||d}|jstj|_ |j |dS)zCreate a greenthread to run the *function*, the same as :meth:`spawn`. The difference is that :meth:`spawn_n` returns None; the results of *function* are not retrievable. NT) rr+rr,rrEr0spawn_nrrr2)rr5r6r7r8gs rrGzGreenPool.spawn_nbs%'' 8??   +D,C!C!C   xvt < < < < < H      "$..A* 9(0(8(8%  # ' ' * * * * *r#ctj|jvs Jd|r|jdSdS)z>Waits until all greenthreads in the pool are finished working.zWCalling waitall() from within one of the GreenPool's greenthreads will never terminate.N)rr+rr'rwaitr&s rwaitallzGreenPool.waitallusd"$$D,CCCC =DCC <<>> )  ! & & ( ( ( ( ( ) )r#c|j||j||jj|jkr|jddSdSr;)rreleaserremovebalancerrsend)rrDs rr4zGreenPool._spawn_done}sl     # * *4 0 0 0 8 ty ( (  ! & &t , , , , , ) (r#c@|jjdkr |jj SdS)zz#GreenPool.starmap..s!r#)GreenMaprrrGrW)rr5iterablerVs rstarmapzGreenPool.starmaps@  #|Hdi x2>>> r#c<||t|S)aThis is the same as :func:`itertools.imap`, and has the same concurrency and memory behavior as :meth:`starmap`. It's quite convenient for, e.g., farming out jobs from a file:: def worker(line): return do_something(line) pool = GreenPool() for result in pool.imap(worker, open("filename", 'r')): print(result) )r_zip)rr5 iterabless rimapzGreenPool.imaps||Hc9o666r#Nr)__name__ __module__ __qualname____doc__rr"r'r)r1rErGrKr4rRrWr_rcrZr#rrr s 1 1 1 1   ,,,    : ' ' '+++&)))--- , 7 7 7 7 7r#c6eZdZdZd dZdZdZdZeZdZ dS) raGreenPile is an abstraction representing a bunch of I/O-related tasks. Construct a GreenPile with an existing GreenPool object. The GreenPile will then use that pool's concurrency as it processes its jobs. There can be many GreenPiles associated with a single GreenPool. A GreenPile can also be constructed standalone, not associated with any GreenPool. To do this, construct it with an integer size parameter instead of a GreenPool. It is not advisable to iterate over a GreenPile in a different greenthread than the one which is calling spawn. The iterator will exit early in that situation. rct|tr||_nt||_tj|_d|_dS)Nr) isinstancerpoolr LightQueuewaitersr)r size_or_pools rrzGreenPile.__init__sG lI . . 0$DII!,//DI'))  r#c|xjdz c_ |jj|g|Ri|}|j|dS#|xjdzc_xYw)znRuns *func* in its own green thread, with the result available by iterating over the GreenPile object.N)rrlr1rnput)rrCr6kwr9s rr1zGreenPile.spawnst    333333B L  R   LLA LL s 0AAc|Sr;rZr&s r__iter__zGreenPile.__iter__s r#c\|jdkrt|S)zWait for the next result, suspending the current greenthread until it is available. Raises StopIteration when there are no more results.r)r StopIteration_nextr&s rnextzGreenPile.nexts) <1  // !zz||r#c |j|xjdzc_S#|xjdzc_wxYw)Nrq)rngetrJrr&s rrxzGreenPile._nextsN <##%%**,, LLA LLLDLLA LLLLLLs *=ANrd) rerfrgrhrr1rury__next__rxrZr#rrrsu      Hr#c.eZdZfdZdZdZeZxZS)r]ct|tj|jj|_dS)N)maxsize)superrrrmrlrrn)rro __class__s rrzGreenMap.__init__s8 &&&' ??? r#c2|ddS)NctSr;)rwrZr#rr\z(GreenMap.done_spawning..s =??r#)r1r&s rrTzGreenMap.done_spawnings **+++++r#c\|}t|tr||Sr;)rxrkrw)rvals rryz GreenMap.nexts+jjll c= ) ) IJr#)rerfrgrrTryr| __classcell__)rs@rr]r]sV@@@@@,,, HHHHHr#r]) rArreventlet.supportrr>__all__r@rrr]rZr#rrs222222  $ i7i7i7i7i7i7i7i7X22222222pyr#