/usr/lib64/python3.9/multiprocessing/__pycache__
Edit: /usr/lib64/python3.9/multiprocessing/__pycache__/queues.cpython-39.pyc (10176B)
a
i. @ 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_MAXFduplexwin32) synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockBoundedSemaphore_sem
_ignore_epipe_resetr
r _after_forkselfmaxsizectx r) ./usr/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& r3 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 r5 r<
_start_threadr; 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 rG )
r? rH r rD r! releasetime monotonicrI r rF _ForkingPicklerloads)r& rO rP resdeadliner) r) r* getb s* &
z Queue.getc C s | j | jj S r, )r r! _semlock
_get_valuer. r) r) r* qsize| s z Queue.qsizec C s
| S r, rF r. r) r) r* empty s z Queue.emptyc C s | j j S r, )r! rZ _is_zeror. r) r) r* full s z
Queue.fullc C s
| dS r4 )rY r. r) r) r*
get_nowait s zQueue.get_nowaitc C s | |dS r4 )rQ r& rN r) r) r*
put_nowait s zQueue.put_nowaitc C s d| _ | j}|r d | _| d S )NT)r? r@ )r& closer) r) r* rd 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= cancelAttributeErrorr. 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()QueueFeederThread)targetargsnameTzdoing self._thread.start()z ... done self._thread.start()) exitpriority
)r
r; clearr7 Threadr _feedr5 rB r r rd r r" _on_queue_feeder_errorr! r< daemonstartr> r _finalize_joinweakrefrefr= _finalize_closer@ r. r) r) r* rJ 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)twrthreadr) r) r* rw s
zQueue._finalize_joinc C sB t d |" | t | W d n1 s40 Y d S )Nz telling queue thread to quit)r
rK _sentinelrL )buffernotemptyr) r) r* rz 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
rI rR waitpopleftr~ r r rU dumps
IndexError Exceptiongetattrr EPIPEr r )r r rA writelock reader_close writer_close ignore_epipeonerror queue_semnacquirenreleasenwaitbpopleftsentinelwacquirewreleaserN er) r) r* rs 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 rN r r) r) r* rt s z Queue._on_queue_feeder_error)r )F)TN)TN)__name__
__module__ __qualname__r+ r/ r2 r$ r# rQ rY r\ r^ r` ra rc rd rf ri rJ staticmethodrw rz rs rt 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+ Semaphore_unfinished_tasksr8 _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 r2 r r r0 r) r) r* r2 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 rG )r? rH r! rI r r5 r r< rJ r; rK r rR rL rM r) r) r* rQ 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 rI rH rZ r_
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 rZ r_ r r. r) r) r* r{ H s zJoinableQueue.join)r )TN) r r r r+ r/ r2 rQ r r{ 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 rE rF r r r )r& r( r) r) r* r+ S s
zSimpleQueue.__init__c C s | j | j d S r, )r rd r r. r) r) r* rd \ s
zSimpleQueue.closec C s
| S r, r] r. r) r) r* r^ ` 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 rE rF r0 r) r) r* r2 g s zSimpleQueue.__setstate__c C s: | j | j }W d n1 s&0 Y t|S r, )r r rC rU rV )r& rW r) r) r* rY k s (zSimpleQueue.getc C sX t |}| jd u r"| j| n2| j | j| W d n1 sJ0 Y d S r, )rU r r r rA rb r) r) r* rQ q s
zSimpleQueue.putN)r r r r+ rd r^ r/ r2 rY rQ classmethodtypes GenericAlias__class_getitem__r) r) r) r* r Q s
r ) __all__r r r7 r9 rS r rx r queuer r _multiprocessing r r reductionForkingPicklerrU utilr
r r r
r objectr r~ r r r) r) r) r*
s& z
+