a xd<@sdZddlZddlmZddlmZddlmZddl m Z dZ d Z d Z d d ejDD]4Zd D]*Zeeedr`ddlZeee eq`qXdddZGdddejZGddde jZdS)zEventlet execution pool.N) monotonic)timer)signals)base)TaskPoolz6Celery module with %s imported before eventlet patched)z billiard.zcelery.zkombu.ccs|]}|tr|VqdSN) startswith RACE_MODS).0modr S/var/www/html/Ranjet/env/lib/python3.9/site-packages/celery/concurrency/eventlet.py r)thread threadingsocketr cCs$|sin|}tj||||||dS)N)pid)r apply_target)targetargskwargscallbackaccept_callbackgetpidr r rrs rcsLeZdZdZfddZddZddZdd Zd d Ze d d Z Z S)TimerzEventlet Timer.csBddlm}ddlm}tj|i|||_||_t|_dS)Nr) spawn_after) GreenletExit) Zeventlet.greenthreadrZgreenletrsuper__init__ _spawn_afterset_queue)selfrrrr __class__r rr &s   zTimer.__init__cKsRt|td}|||}|j|||j|||_||_||_ d|_ |S)NrF) maxrr!r#addlink _entry_exitentryetaprioritycanceled)r$r,r-r+rZsecsgr r r_enter/s  z Timer._enterc CsTz@z |Wn"|jy0|d|_Yn0W|j|n|j|0dS)NT)waitrcancelr.r#discard)r$r/r+r r rr*:s zTimer._entry_exitc Cs:|j}|r6z|Wqt|jfy2Yq0qdSr)r#popr2KeyErrorr)r$queuer r rclearDs z Timer.clearcCs&z |Wn|jy Yn0dSr)r2r)r$Ztrefr r rr2Ls z Timer.cancelcCs|jSr)r#r$r r rr6Rsz Timer.queue) __name__ __module__ __qualname____doc__r r0r*r7r2propertyr6 __classcell__r r r%rr#s   rcsreZdZdZeZdZdZdZdZdZ fddZ ddZ d d Z dd d Z dddZdddZfddZZS)rzEventlet Task Pool.FTNcsRddlmddlm}||_j|_fdd|_j|_tj |i|dS)Nr greenthread) GreenPoolcs tSr)id getcurrentr r?r rgrz#TaskPool.__init__..) Zeventletr@Zeventlet.greenpoolrAPoolrCrspawn_nrr )r$rrrAr%r?rr bs  zTaskPool.__init__cCs4||j|_tjj|d|jj|_tjj|_ dSN)sender) rElimit_poolrZeventlet_pool_startedsendrF _quick_putZeventlet_pool_apply_quick_apply_sigr8r r ron_startls zTaskPool.on_startcCs4tjj|d|jdur"|jtjj|ddSrG)rZeventlet_pool_preshutdownrKrJZwaitallZeventlet_pool_postshutdownr8r r ron_stoprs  zTaskPool.on_stopc Ks.|j||||d|t||||||jdS)N)rHrrr)rMrLrr)r$rrrrr_r r ron_applyxs zTaskPool.on_applyrcCs |j|}|j|||_dSrrIrJresizer$nrIr r rgrows  z TaskPool.growcCs |j|}|j|||_dSrrRrTr r rshrinks  zTaskPool.shrinkcs.t}||j|j|jd|S)N)zmax-concurrencyz free-threadszrunning-threads)r _get_infoupdaterIrJfreeZrunning)r$infor%r rrXs zTaskPool._get_info)NNNN)r)r)r9r:r;r<rZ signal_safeZis_greenZtask_join_will_blockrJrLr rNrOrQrVrWrXr>r r r%rrWs    r)r NNNN)r<systimerZkombu.asynchronousrZ_timerZceleryrr__all__ZW_RACEr modulesr ZsidegetattrwarningswarnRuntimeWarningrrZBasePoolrr r r rs$      4