File "queues.cpython-34.pyc"
Full Path: /home/attunedd/public_html/byp/izo/con7ext_sym404/rintoar.txt/opt/alt/python34/lib64/python3.4/multiprocessing/__pycache__/queues.cpython-34.pyc
File size: 9.83 KB
MIME-type: text/x-bytecode.python
Charset: 8 bit
e f%- @ s, d d d g Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l Z d d l m Z m
Z
d d l Z d d l m
Z
d d l m Z d d l m Z m Z m Z m Z m Z d d
l m Z Gd d d e Z e Z Gd d d e Z Gd
d d e Z d S)Queue SimpleQueue
JoinableQueue N)EmptyFull )
connection)context)debuginfoFinalizeregister_after_fork
is_exiting)ForkingPicklerc @ s e Z d Z d d d Z d d Z d d Z d d Z d
d d d
Z d
d d d Z d d Z d d Z
d d Z d d Z d d Z
d d Z d d Z d d Z d d! Z e d" d# Z e d$ d% Z e d& d' Z d S)(r r c C s | d k r d d l m } n | | _ t j d d \ | _ | _ | j | _ t j
| _ t j
d k r d | _ n | j | _ | j | | _ d | _ | j t j
d k r t | t j n d S)Nr r )
SEM_VALUE_MAXduplexFwin32)Z synchronizer _maxsizer Pipe_reader_writerLock_rlockosgetpid_opidsysplatform_wlockZBoundedSemaphore_sem
_ignore_epipe _after_forkr
r )selfmaxsizectx r% ;/opt/alt/python34/lib64/python3.4/multiprocessing/queues.py__init__$ s
zQueue.__init__c C sA t j | | j | j | j | j | j | j | j | j f S)N)
r assert_spawningr r r r r r r r )r" r% r% r& __getstate__9 s
zQueue.__getstate__c C sD | \ | _ | _ | _ | _ | _ | _ | _ | _ | j d S)N) r r r r r r r r r! )r" stater% r% r& __setstate__> s 6zQueue.__setstate__c C s t d t j t j | _ t j | _ d | _ d | _ d | _
d | _ d | _ | j
j | _ | j j | _ | j j | _ d S)NzQueue._after_fork()F)r
threading Conditionr _notempty collectionsdeque_buffer_thread _jointhread_joincancelled_closed_closer
send_bytes _send_bytesr
recv_bytes _recv_bytespoll_poll)r" r% r% r& r! C s
zQueue._after_forkTNc
C s | j s t | j j | | s. t n | j j z= | j d k rZ | j n | j j | | j j
Wd | j j Xd S)N) r5 AssertionErrorr acquirer r. r2
_start_threadr1 appendnotifyrelease)r" objblocktimeoutr% r% r& putP s
z Queue.putc
C s | r> | d k r> | j | j } Wd QX| j j n | rW t j | } n | j j | | su t n zp | r | t j } | d k s | j | r t q n | j s t n | j } | j j Wd | j j Xt j | S)Nr )
r r: r rB timer> r r< r loads)r" rD rE resZdeadliner% r% r& get^ s&
z Queue.getc C s | j | j j j S)N)r r _semlockZ
_get_value)r" r% r% r& qsizev s z Queue.qsizec C s | j S)N)r< )r" r% r% r& emptyz s z Queue.emptyc C s | j j j S)N)r rK _is_zero)r" r% r% r& full} s z
Queue.fullc C s
| j d S)NF)rJ )r" r% r% r&
get_nowait s zQueue.get_nowaitc C s | j | d S)NF)rF )r" rC r% r% r&
put_nowait s zQueue.put_nowaitc C sD d | _ z | j j Wd | j } | r? d | _ | n Xd S)NT)r5 r closer6 )r" rR r% r% r& rR s z Queue.closec C s3 t d | j s t | j r/ | j n d S)NzQueue.join_thread())r
r5 r= r3 )r" r% r% r& join_thread s
zQueue.join_threadc C s= t d d | _ y | j j Wn t k
r8 Yn Xd S)NzQueue.cancel_join_thread()T)r
r4 r3 ZcancelAttributeError)r" r% r% r& cancel_join_thread s
zQueue.cancel_join_threadc
C s t d | j j t j d t j d | j | j | j | j | j
j | j f d d | _
d | j
_ t d | j
j t d | j t j k } | j r | r t | j
t j t j | j
g d d | _ n t | t j | j | j g d d | _ d S)
NzQueue._start_thread()targetargsnameZQueueFeederThreadTzdoing self._thread.start()z ... done self._thread.start()Z exitpriority
)r
r1 clearr, ZThreadr _feedr. r8 r r rR r r2 Zdaemonstartr r r r4 r _finalize_joinweakrefrefr3 _finalize_closer6 )r" Zcreated_by_this_processr% r% r& r? s*
zQueue._start_threadc C sD t d | } | d k r6 | j t d n
t d d S)Nzjoining queue threadz... queue thread joinedz ... queue thread already dead)r
join)ZtwrZthreadr% r% r& r_ s
zQueue._finalize_joinc
C sA t d | j z | j t | j Wd | j Xd S)Nz telling queue thread to quit)r
r> r@ _sentinelrA rB )buffernotemptyr% r% r& rb s
zQueue._finalize_closec C s t d | j } | j } | j } | j } t }
t j d k rX | j } | j } n d } y x | z | s~ | n Wd | Xy} xv | }
|
|
k r t d | d St j |
}
| d k r | |
q | z | |
Wd | Xq WWqd t
k
rYqd Xqd WWn t k
r} zr | r[t | d d t
j k r[d Sy3 t rwt d | n d d l } | j Wn t k
rYn XWYd d } ~ Xn Xd S)Nz$starting thread to feed data to piper z%feeder thread got sentinel -- exitingerrnor zerror in queue thread: %s)r
r> rB waitpopleftrd r r r dumps
IndexError Exceptiongetattrrg ZEPIPEr r traceback print_exc)re rf r7 Z writelockrR Z ignore_epipeZnacquireZnreleaseZnwaitZbpopleftsentinelZwacquireZwreleaserC ern r% r% r& r] sV
!
z Queue._feed)__name__
__module__ __qualname__r' r) r+ r! rF rJ rL rM rO rP rQ rR rS rU r? staticmethodr_ rb r] r% r% r% r& r " s$
&
c @ sa e Z d Z d d d Z d d Z d d Z d d d
d Z d d
Z d d Z d S)r r c C s; t j | | d | | j d | _ | j | _ d S)Nr$ r )r r' Z Semaphore_unfinished_tasksr- _cond)r" r# r$ r% r% r& r' s zJoinableQueue.__init__c C s t j | | j | j f S)N)r r) rw rv )r" r% r% r& r) # s zJoinableQueue.__getstate__c C s: t j | | d d | d d \ | _ | _ d S)N ry )r r+ rw rv )r" r* r% r% r& r+ & s zJoinableQueue.__setstate__TNc
C s | j s t | j j | | s. t n | j j | j j zJ | j d k rg | j n | j j
| | j j | j j
Wd | j j | j j Xd S)N)r5 r= r r> r r. rw r2 r? r1 r@ rv rB rA )r" rC rD rE r% r% r& rF * s
zJoinableQueue.putc
C si | j j zG | j j d s1 t d n | j j j rS | j j n Wd | j j Xd S)NFz!task_done() called too many times)rw r> rv
ValueErrorrK rN Z
notify_allrB )r" r% r% r& task_done; s
zJoinableQueue.task_donec
C sH | j j z& | j j j s2 | j j n Wd | j j Xd S)N)rw r> rv rK rN rh rB )r" r% r% r& rc E s
zJoinableQueue.join) rr rs rt r' r) r+ rF r{ rc r% r% r% r& r s
c @ sX e Z d Z d d Z d d Z d d Z d d Z d d
Z d d Z d
S)r c C sj t j d d \ | _ | _ | j | _ | j j | _ t j d k rW d | _
n | j | _
d S)Nr Fr ) r r r r r r r; r< r r r )r" r$ r% r% r& r' S s zSimpleQueue.__init__c C s | j S)N)r< )r" r% r% r& rM \ s zSimpleQueue.emptyc C s) t j | | j | j | j | j f S)N)r r( r r r r )r" r% r% r& r) _ s
zSimpleQueue.__getstate__c C s" | \ | _ | _ | _ | _ d S)N)r r r r )r" r* r% r% r& r+ c s zSimpleQueue.__setstate__c C s, | j | j j } Wd QXt j | S)N)r r r9 r rH )r" rI r% r% r& rJ f s
zSimpleQueue.getc C sU t j | } | j d k r1 | j j | n | j | j j | Wd QXd S)N)r rj r r r7 )r" rC r% r% r& rF l s
zSimpleQueue.putN) rr rs rt r' rM r) r+ rJ rF r% r% r% r& r Q s ) __all__r r r, r/ rG r` rg Zqueuer r Z_multiprocessing r r utilr
r r r
r Z reductionr objectr rd r r r% r% r% r& <module>
s" (
5