← Back
Editing: queues.cpython-33.pyc
� �� f- c @ s8 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 m Z m Z m Z d d l 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( u Queueu SimpleQueueu JoinableQueuei N( u Emptyu Full( u Pipe( u Locku BoundedSemaphoreu Semaphoreu Condition( u debugu infou Finalizeu register_after_fork( u assert_spawningc B s | Ee 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(( u Queuei c C s� | d k r t j j } n | | _ t d d � \ | _ | _ t � | _ t j � | _ t j d k ru d | _ n t � | _ t | � | _ d | _ | j � t j d k r� t | t j � n d S( Ni u duplexu win32F( u _multiprocessingu SemLocku SEM_VALUE_MAXu _maxsizeu Pipeu Falseu _readeru _writeru Locku _rlocku osu getpidu _opidu sysu platformu Noneu _wlocku BoundedSemaphoreu _semu _ignore_epipeu _after_forku register_after_forku Queue( u selfu maxsize( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__! s u Queue.__init__c C s> t | � | j | j | j | j | j | j | j | j f S( N( u assert_spawningu _ignore_epipeu _maxsizeu _readeru _writeru _rlocku _wlocku _semu _opid( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__5 s u Queue.__getstate__c C sD | \ | _ | _ | _ | _ | _ | _ | _ | _ | j � d S( N( u _ignore_epipeu _maxsizeu _readeru _writeru _rlocku _wlocku _semu _opidu _after_fork( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__: s 6u Queue.__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( Nu Queue._after_fork()F( u debugu threadingu Conditionu Locku _notemptyu collectionsu dequeu _bufferu Noneu _threadu _jointhreadu Falseu _joincancelledu _closedu _closeu _writeru sendu _sendu _readeru recvu _recvu pollu _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _after_fork? s u Queue._after_forkc 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( u _closedu AssertionErroru _semu acquireu Fullu _notemptyu _threadu Noneu _start_threadu _bufferu appendu notifyu release( u selfu obju blocku timeout( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu putL s u Queue.putc C s | rT | d k rT | j j � z! | j � } | j j � | SWd | j j � Xn� | rm t j � | } n | j j | | � s� t � n zt | r� | t j � } | d k s� | j | � r� t � q� n | j � s� t � n | j � } | j j � | SWd | j j � Xd S( Ni ( u Noneu _rlocku acquireu _recvu _semu releaseu timeu Emptyu _poll( u selfu blocku timeoutu resu deadline( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu getZ s, u Queue.getc C s | j | j j j � S( N( u _maxsizeu _semu _semlocku _get_value( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu qsizev s u Queue.qsizec C s | j � S( N( u _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu emptyz s u Queue.emptyc C s | j j j � S( N( u _semu _semlocku _is_zero( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu full} s u Queue.fullc C s | j d � S( NF( u getu False( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu get_nowait� s u Queue.get_nowaitc C s | j | d � S( NF( u putu False( u selfu obj( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu put_nowait� s u Queue.put_nowaitc C s0 d | _ | j j � | j r, | j � n d S( NT( u Trueu _closedu _readeru closeu _close( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu close� s u Queue.closec C s3 t d � | j s t � | j r/ | j � n d S( Nu Queue.join_thread()( u debugu _closedu AssertionErroru _jointhread( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu join_thread� s u Queue.join_threadc C s= t d � d | _ y | j j � Wn t k r8 Yn Xd S( Nu Queue.cancel_join_thread()T( u debugu Trueu _joincancelledu _jointhreadu cancelu AttributeError( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu cancel_join_thread� s u Queue.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( Nu Queue._start_thread()u targetu argsu nameu QueueFeederThreadu doing self._thread.start()u ... done self._thread.start()u exitpriorityi i Ti����( u debugu _bufferu clearu threadingu Threadu Queueu _feedu _notemptyu _sendu _wlocku _writeru closeu _ignore_epipeu _threadu Trueu daemonu startu _opidu osu getpidu _joincancelledu Finalizeu _finalize_joinu weakrefu refu _jointhreadu _finalize_closeu _close( u selfu created_by_this_process( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _start_thread� s* u Queue._start_threadc C sD t d � | � } | d k r6 | j � t d � n t d � d S( Nu joining queue threadu ... queue thread joinedu ... queue thread already dead( u debugu Noneu join( u twru thread( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _finalize_join� s u Queue._finalize_joinc C sA t d � | j � z | j t � | j � Wd | j � Xd S( Nu telling queue thread to quit( u debugu acquireu appendu _sentinelu notifyu release( u bufferu notempty( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _finalize_close� s u Queue._finalize_closec C s� t d � d d l m } | j } | j } | j } | j } t } t j d k rh | j } | j } n d } y� x� | � z | s� | � n Wd | � Xym xf | � } | | k r� t d � | � d S| d k r� | | � q� | � z | | � Wd | � Xq� Wqt t k rYqt Xqt Wn� t k r�} zr | rZt | d d � t j k rZd Sy3 | � rvt d | � n d d l } | j � Wn t k r�Yn XWYd d } ~ Xn Xd S( Nu$ starting thread to feed data to pipei ( u is_exitingu win32u% feeder thread got sentinel -- exitingu errnoi u error in queue thread: %s( u debugu utilu is_exitingu acquireu releaseu waitu popleftu _sentinelu sysu platformu Noneu IndexErroru Exceptionu getattru errnou EPIPEu infou tracebacku print_exc( u bufferu notemptyu sendu writelocku closeu ignore_epipeu is_exitingu nacquireu nreleaseu nwaitu bpopleftu sentinelu wacquireu wreleaseu obju eu traceback( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _feed� sV ! u Queue._feedNT( u __name__u __module__u __qualname__u __init__u __getstate__u __setstate__u _after_forku Trueu Noneu putu getu qsizeu emptyu fullu get_nowaitu put_nowaitu closeu join_threadu cancel_join_threadu _start_threadu staticmethodu _finalize_joinu _finalize_closeu _feed( u __locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu Queue s$ & c B se | Ee 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( u JoinableQueuei c C s/ t j | | � t d � | _ t � | _ d S( Ni ( u Queueu __init__u Semaphoreu _unfinished_tasksu Conditionu _cond( u selfu maxsize( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__ s u JoinableQueue.__init__c C s t j | � | j | j f S( N( u Queueu __getstate__u _condu _unfinished_tasks( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__ s u JoinableQueue.__getstate__c C s: t j | | d d � � | d d � \ | _ | _ d S( Ni i����i����( u Queueu __setstate__u _condu _unfinished_tasks( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__" s u JoinableQueue.__setstate__c 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( u _closedu AssertionErroru _semu acquireu Fullu _notemptyu _condu _threadu Noneu _start_threadu _bufferu appendu _unfinished_tasksu releaseu notify( u selfu obju blocku timeout( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu put& s u JoinableQueue.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( Nu! task_done() called too many timesF( u _condu acquireu _unfinished_tasksu Falseu ValueErroru _semlocku _is_zerou notify_allu release( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu task_done7 s u JoinableQueue.task_donec C sH | j j � z& | j j j � s2 | j j � n Wd | j j � Xd S( N( u _condu acquireu _unfinished_tasksu _semlocku _is_zerou waitu release( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu joinA s u JoinableQueue.joinNT( u __name__u __module__u __qualname__u __init__u __getstate__u __setstate__u Trueu Noneu putu task_doneu join( u __locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu JoinableQueue s c B sP | Ee Z d Z d d � Z d d � Z d d � Z d d � Z d d � Z d S( u SimpleQueuec C sk t d d � \ | _ | _ t � | _ | j j | _ t j d k rQ d | _ n t � | _ | j � d S( Nu duplexu win32F( u Pipeu Falseu _readeru _writeru Locku _rlocku pollu _pollu sysu platformu Noneu _wlocku _make_methods( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __init__O s u SimpleQueue.__init__c C s | j � S( N( u _poll( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu emptyY s u SimpleQueue.emptyc C s& t | � | j | j | j | j f S( N( u assert_spawningu _readeru _writeru _rlocku _wlock( u self( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __getstate__\ s u SimpleQueue.__getstate__c C s, | \ | _ | _ | _ | _ | j � d S( N( u _readeru _writeru _rlocku _wlocku _make_methods( u selfu state( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu __setstate__` s u SimpleQueue.__setstate__c s� | j j � | j j | j j � � � � � f d d � } | | _ | j d k rg | j j | _ nF | j j � | j j | j j � � � � � f d d � } | | _ d S( Nc s! � � z � � SWd � � Xd S( N( ( ( u racquireu recvu rrelease( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu getg s u& SimpleQueue._make_methods.<locals>.getc s$ � � z � | � SWd � � Xd S( N( ( u obj( u sendu wacquireu wrelease( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu putu s u& SimpleQueue._make_methods.<locals>.put( u _readeru recvu _rlocku acquireu releaseu getu _wlocku Noneu _writeru sendu put( u selfu getu put( ( u racquireu recvu rreleaseu sendu wacquireu wreleaseu; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu _make_methodsd s u SimpleQueue._make_methodsN( u __name__u __module__u __qualname__u __init__u emptyu __getstate__u __setstate__u _make_methods( u __locals__( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu SimpleQueueM s ( u __all__u sysu osu threadingu collectionsu timeu weakrefu errnou queueu Emptyu Fullu _multiprocessingu multiprocessing.connectionu Pipeu multiprocessing.synchronizeu Locku BoundedSemaphoreu Semaphoreu Conditionu multiprocessing.utilu debugu infou Finalizeu register_after_forku multiprocessing.forkingu assert_spawningu objectu Queueu _sentinelu JoinableQueueu SimpleQueue( ( ( u; /opt/alt/python33/lib64/python3.3/multiprocessing/queues.pyu <module> s" ""� 5
Save File
Cancel