File "queues.cpython-39.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python39/lib64/python3.9/multiprocessing/__pycache__/queues.cpython-39.pyc
File size: 9.95 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
a
XC?h. @ s g d Z ddlZddlZddlZddlZddlZddlZddlZddlZddl m
Z
m Z ddl Z ddl
mZ ddl
mZ ejjZddlmZmZmZmZmZ G dd d eZe ZG d
d d eZ G d d
d
eZ dS ))Queue SimpleQueue
JoinableQueue N)EmptyFull )
connection)context)debuginfoFinalizeregister_after_fork
is_exitingc @ s e Zd Zd-ddZdd Zdd Zdd Zd.d d Zd/ddZd0ddZ dd Z
dd Z dd Z dd Z
dd Zd d Zd d Zd!d" Zd#d$ Zed%d& Zed'd( Zed)d* Zed+d, ZdS )1r r c C s |dkrddl m} || _tjdd\| _| _| | _t
| _ t j
dkrTd | _n
| | _||| _d| _| t j
dkrt| tj d S )Nr r )
SEM_VALUE_MAXFZduplexwin32)Z synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockZBoundedSemaphore_sem
_ignore_epipe_resetr
r _after_forkselfmaxsizectx r& ;/opt/alt/python39/lib64/python3.9/multiprocessing/queues.py__init__% s
zQueue.__init__c C s. t | | j| j| j| j| j| j| j| j fS N)
r assert_spawningr r r r r r r r r# r& r& r' __getstate__9 s
zQueue.__getstate__c C s0 |\| _ | _| _| _| _| _| _| _| d S r) ) r r r r r r r r r r# stater& r& r' __setstate__> s zQueue.__setstate__c C s t d | jdd d S )NzQueue._after_fork()T)
after_fork)r
r r+ r& r& r' r! C s zQueue._after_forkFc C sj |r| j ntt | _ t | _d | _d | _ d| _
d| _ d | _ | j
j| _| jj| _| jj| _d S NF) _notempty_at_fork_reinit threading Conditionr collectionsdeque_buffer_thread _jointhread_joincancelled_closed_closer
send_bytes _send_bytesr
recv_bytes _recv_bytespoll_poll)r# r0 r& r& r' r G s
z Queue._resetTNc C sz | j rtd| d| j||s(t| j8 | jd u rB| | j | | j
W d n1 sl0 Y d S NzQueue z
is closed) r<
ValueErrorr acquirer r2 r9
_start_threadr8 appendnotifyr# objblocktimeoutr& r& r' putV s
z Queue.putc C s | j rtd| d|r\|d u r\| j | }W d n1 sF0 Y | j n||rlt | }| j||s~t zL|r|t }|
|st n |
st | }| j W | j n | j 0 t |S rD )
r< rE r rA r releasetime monotonicrF r rC _ForkingPicklerloads)r# rL rM resZdeadliner& r& r' getb s* &
z Queue.getc C s | j | jj S r) )r r _semlockZ
_get_valuer+ r& r& r' qsize| s z Queue.qsizec C s
| S r) rC r+ r& r& r' empty s z Queue.emptyc C s | j j S r) )r rV _is_zeror+ r& r& r' full s z
Queue.fullc C s
| dS r1 )rU r+ r& r& r'
get_nowait s zQueue.get_nowaitc C s | |dS r1 )rN r# rK r& r& r'
put_nowait s zQueue.put_nowaitc C s d| _ | j}|r d | _| d S )NT)r< r= )r# closer& r& r' r_ s
z Queue.closec C s. t d | js J d| | jr*| d S )NzQueue.join_thread()zQueue {0!r} not closed)r
r< formatr: r+ r& r& r' join_thread s zQueue.join_threadc C s4 t d d| _z| j W n ty. Y n0 d S )NzQueue.cancel_join_thread()T)r
r; r: ZcancelAttributeErrorr+ r& r& r' cancel_join_thread s zQueue.cancel_join_threadc C s t d | j tjtj| j| j| j| j | j
j | j j | j
| j| jf dd| _d| j_t d | j t d | jst| jtjt| jgdd| _t| tj| j| jgd d| _d S )
NzQueue._start_thread()ZQueueFeederThread)targetargsnameTzdoing self._thread.start()z ... done self._thread.start())Z exitpriority
)r
r8 clearr4 ZThreadr _feedr2 r? r r r_ r r _on_queue_feeder_errorr r9 Zdaemonstartr; r _finalize_joinweakrefrefr: _finalize_closer= r+ r& r& r' rG s4
zQueue._start_threadc C s4 t d | }|d ur(| t d nt d d S )Nzjoining queue threadz... queue thread joinedz ... queue thread already dead)r
join)Ztwrthreadr& r& r' rm s
zQueue._finalize_joinc C sB t d |" | t | W d n1 s40 Y d S )Nz telling queue thread to quit)r
rH _sentinelrI )buffernotemptyr& r& r' rp s
zQueue._finalize_closec
C sr t d |j} |j}
|j} | j} t}
tjdkr<|j}|j}nd }z| z| sT| W |
n|
0 zn| }||
u rt d | | W W d S t |}|d u r|| qh| z|| W | qh| 0 qhW n t
y Y n0 W q@ t yj } zf|r$t |ddt
jkr$W Y d }~d S t rDtd| W Y d }~d S | ||| W Y d }~q@d }~0 0 q@d S )Nz$starting thread to feed data to piper z%feeder thread got sentinel -- exitingerrnor zerror in queue thread: %s)r
rF rO waitpopleftrs r r rR dumps
IndexError Exceptiongetattrrv ZEPIPEr r )rt ru r> Z writelockZ reader_closeZ writer_closeZ ignore_epipeonerrorZ queue_semZnacquireZnreleaseZnwaitZbpopleftsentinelZwacquireZwreleaserK er& r& r' rj sP
z Queue._feedc C s ddl }| dS )z
Private API hook called when feeding data in the background thread
raises an exception. For overriding by concurrent.futures.
r N) traceback print_exc)r rK r r& r& r' rk s z Queue._on_queue_feeder_error)r )F)TN)TN)__name__
__module__ __qualname__r( r, r/ r! r rN rU rW rY r[ r\ r^ r_ ra rc rG staticmethodrm rp rj rk r& r& r& r' r # s0
!
>r c @ s@ e Zd ZdddZdd Zdd Zdd
d Zd d
Zdd Zd S )r r c C s* t j| ||d |d| _| | _d S )N)r% r )r r( Z Semaphore_unfinished_tasksr5 _condr" r& r& r' r( ( s zJoinableQueue.__init__c C s t | | j| jf S r) )r r, r r r+ r& r& r' r, - s zJoinableQueue.__getstate__c C s, t | |d d |dd \| _| _d S )N)r r/ r r r- r& r& r' r/ 0 s zJoinableQueue.__setstate__TNc C s | j rtd| d| j||s(t| jh | jB | jd u rJ| | j
| | j | j
W d n1 s~0 Y W d n1 s0 Y d S rD )r< rE r rF r r2 r r9 rG r8 rH r rO rI rJ r& r& r' rN 4 s
zJoinableQueue.putc C sT | j : | jds td| jj r2| j W d n1 sF0 Y d S )NFz!task_done() called too many times)r r rF rE rV rZ Z
notify_allr+ r& r& r' task_doneA s
zJoinableQueue.task_donec C s@ | j & | jj s | j W d n1 s20 Y d S r) )r r rV rZ rw r+ r& r& r' rq H s zJoinableQueue.join)r )TN) r r r r( r, r/ rN r rq r& r& r& r' r & s
r c @ sN e Zd Zdd Zdd Zdd Zdd Zd d
Zd d Zd
d Z e
e j Z
dS )r c C sH t jdd\| _| _| | _| jj| _tj dkr:d | _
n
| | _
d S )NFr r ) r r r r r r rB rC r r r )r# r% r& r& r' r( S s
zSimpleQueue.__init__c C s | j | j d S r) )r r_ r r+ r& r& r' r_ \ s
zSimpleQueue.closec C s
| S r) rX r+ r& r& r' rY ` s zSimpleQueue.emptyc C s t | | j| j| j| jfS r) )r r* r r r r r+ r& r& r' r, c s
zSimpleQueue.__getstate__c C s" |\| _ | _| _| _| j j| _d S r) )r r r r rB rC r- r& r& r' r/ g s zSimpleQueue.__setstate__c C s: | j | j }W d n1 s&0 Y t|S r) )r r r@ rR rS )r# rT r& r& r' rU k s (zSimpleQueue.getc C sX t |}| jd u r"| j| n2| j | j| W d n1 sJ0 Y d S r) )rR ry r r r> r] r& r& r' rN q s
zSimpleQueue.putN)r r r r( r_ rY r, r/ rU rN classmethodtypes GenericAlias__class_getitem__r& r& r& r' r Q s
r ) __all__r r r4 r6 rP r rn rv Zqueuer r Z_multiprocessing r r Z reductionZForkingPicklerrR utilr
r r r
r objectr rs r r r& r& r& r' <module>
s& z
+