korsygfhrtzangaiide
Elepffwdsff
/
lib64
/
python2.7
/
Demo
/
threads
/
Upload FileeE
HOME
� V �Qc @ sn d d l Z d d l Z d d d � � YZ d e f d � � YZ d e f d � � YZ d d d � � YZ d S( i����Nt _CoEventc B s> e Z d � Z d � Z d � Z d � Z d � Z d � Z RS( c C s | | _ t j � | _ d S( N( t ft synct eventt e( t selft func( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt __init__I s c C s% | j d k r d Sd | j j Sd S( Ns main coroutines coroutine for func ( R t Nonet func_name( R ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt __repr__M s c C s t | � S( N( t id( R ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt __hash__S s c C s t t | � t | � � S( N( t cmpR ( t xt y( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt __cmp__V s c C s | j j � d S( N( R t post( R ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt resumeY s c C s | j j � | j j � d S( N( R t waitt clear( R ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR \ s ( t __name__t __module__R R R R R R ( ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR H s t Killedc B s e Z RS( ( R R ( ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR ` s t EarlyExitc B s e Z RS( ( R R ( ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR a s t Coroutinec B sP e Z d � Z d � Z d � Z d � Z d d � Z d d � Z d d � Z RS( c C sH t d � | _ | _ i d | j 6| _ d | _ d | _ d | _ d S( Ni ( R R t activet maint invokedbyt killedt valuet terminated_by( R ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR d s c G s7 t | � } d | j | <t j | j | f | � | S( N( R R R t threadt start_new_threadt _start( R R t argst me( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt createk s c G si | j � | j se z, y t | j | � Wn t k r= n XWd | j sa | | _ | j � n Xn d S( N( R R t applyR R R t kill( R R$ R# ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR" q s c C sF | j r t d � n d | _ x! | j j � D] } | j � q. Wd S( Ns kill() called on dead coroutinesi ( R t TypeErrorR t keysR ( R t coroutine( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR' ~ s c C s | j | j | j | � S( N( t tranR R ( R t data( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt back� s c C s | j | j | � S( N( R+ R ( R R, ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt detach� s c C s� | j j | � s% t d | f � n | j rA t d | f � n | | _ | j } | | j | <| | _ | j � | j � | j r� | j | k r� t � n | j d k r� t d | j f � q� n | j S( Ns* .tran target %r is not an active coroutines .tran target %r is killeds %r terminated early( R t has_keyR( R R R R R R R R R R ( R t targetR, R$ ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR+ � s N( R R R R% R" R' R R- R. R+ ( ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyR c s ( ( ( R R R t ExceptionR R R ( ( ( s. /usr/lib64/python2.7/Demo/threads/Coroutine.pyt <module>E s