a dC"@sdZddlmZddlZddlZddlZddlZddlZddlZe Z da e Z ddZeeeedreje je je jdGd d d eZd d ZGd ddejZGdddejZdS)z"Brian Quinlan (brian@sweetapp.com))_baseNFcCsftdaWdn1s0Ytt}|D]\}}|dq8|D]\}}|qPdSNT)_global_shutdown_lock _shutdownlist_threads_queuesitemsputjoin)rtqr >/opt/alt/python39/lib64/python3.9/concurrent/futures/thread.py _python_exits"    rregister_at_fork)ZbeforeZafter_in_childZafter_in_parentc@s&eZdZddZddZeejZdS) _WorkItemcCs||_||_||_||_dSN)futurefnargskwargs)selfrrrrr r r__init__/sz_WorkItem.__init__c Csl|jsdSz|j|ji|j}Wn4tyZ}z|j|d}WYd}~nd}~00|j|dSr)rZset_running_or_notify_cancelrrr BaseException set_exceptionZ set_result)rresultexcr r rrun5s  z _WorkItem.runN) __name__ __module__ __qualname__rr classmethodtypes GenericAlias__class_getitem__r r r rr.s rcCs|durPz ||Wn:tyNtjjddd|}|durH|YdS0zx|jdd}|dur|~|}|dur|j~qR|}t s|dus|j r|durd|_ | dWdS~qRWn"tytjjdddYn0dS)NzException in initializer:T)exc_info)blockzException in worker) rrZLOGGERZcritical_initializer_failedgetr_idle_semaphorereleaserr )Zexecutor_referenceZ work_queue initializerinitargsZexecutor work_itemr r r_workerEs8      r.c@s eZdZdS)BrokenThreadPoolN)rrr r r r rr/psr/c@s`eZdZejZdddZddZe j jj e_ dd Z d d Z dd dddZe j jj e_ dS)ThreadPoolExecutorNr cCs|durtdtpdd}|dkr.td|durFt|sFtd||_t|_ t d|_ t |_d|_d|_t |_|pd||_||_||_dS) N rz"max_workers must be greater than 0zinitializer must be a callableFzThreadPoolExecutor-%d)minos cpu_count ValueErrorcallable TypeError _max_workersqueueZ SimpleQueue _work_queue threadingZ Semaphorer)set_threads_brokenrLock_shutdown_lock_counter_thread_name_prefix _initializer _initargs)rZ max_workersZthread_name_prefixr+r,r r rr{s$     zThreadPoolExecutor.__init__c Os|jtv|jrt|j|jr,tdtr8tdt}t||||}|j || |WdWdS1s0YWdn1s0YdS)Nz*cannot schedule new futures after shutdownz6cannot schedule new futures after interpreter shutdown) rCrrAr/r RuntimeErrorrZFuturerr=r _adjust_thread_count)rrrrfwr r rsubmits  zThreadPoolExecutor.submitcCs|jjddrdS|jfdd}t|j}||jkrd|jp>||f}tj|t t |||j|j |j fd}||j||jt|<dS)Nr)ZtimeoutcSs|ddSr)r )_r r r r weakref_cbsz;ThreadPoolExecutor._adjust_thread_count..weakref_cbz%s_%d)nametargetr)r)acquirer=lenr@r;rEr>ZThreadr.weakrefrefrFrGstartaddr)rrNZ num_threadsZ thread_namer r r rrIs$     z'ThreadPoolExecutor._adjust_thread_countc Cst|jZd|_z|j}Wntjy4YqRYn0|dur|jt|jqWdn1sf0YdS)NzBA thread initializer failed, the thread pool is not usable anymore) rCrAr= get_nowaitr<Emptyrrr/)rr-r r rr's z&ThreadPoolExecutor._initializer_failedTF)cancel_futuresc Cs|jbd|_|rNz|j}Wntjy8YqNYn0|dur|jq|jdWdn1sn0Y|r|j D] }| qdSr) rCrr=rWr<rXrZcancelr r@r )rwaitrYr-r r r rshutdowns  * zThreadPoolExecutor.shutdown)Nr1Nr )T)rrr itertoolscount__next__rDrrLrExecutor__doc__rIr'r[r r r rr0vs  &  r0) __author__Zconcurrent.futuresrr\r<r>r"rSr6WeakKeyDictionaryrrrBrrZ_register_atexithasattrrrQ_at_fork_reinitr*objectrr.ZBrokenExecutorr/r_r0r r r rs*   +