-í
ç¶<c       s"  d  Z  d k Z d k Z d k Z d k Z d k Z e Z [ e i Z e i Z	 [ e i
 Z e i Z e i Z e i Z [ e i Z [ e i Z [ d Z d f  d „  ƒ  YZ e Z d „  Z d e f d „  ƒ  YZ d „  Z d	 e f d
 „  ƒ  YZ d „  Z d e f d „  ƒ  YZ d „  Z d e f d „  ƒ  YZ d „  Z  d e f d „  ƒ  YZ! d a" d d „ Z# e ƒ  Z$ h  Z% h  Z& d e f d „  ƒ  YZ' d „  Z( d e' f d „  ƒ  YZ) d e' f d „  ƒ  YZ* d „  Z+ d e' f d „  ƒ  YZ, d  „  Z- d! „  Z. d" „  Z/ e* ƒ  d# „  Z0 e1 d$ j o e0 ƒ  n d S(%   sL   Proposed new threading module, emulating a subset of Java's threading model.Ni    s   _Verbosec      s   t  Z e d „ Z d „  Z RS(   Nc    s   d  S(   N(    (   s   selfs   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__6 s    c    s   d  S(   N(    (   s   selfs   args(    (    s   /usr/lib/python2.2/threading.pys   _note8 s    (   s   __name__s
   __module__s   Nones   __init__s   _note(    (    (    s   /usr/lib/python2.2/threading.pys   _Verbose5 s   c     s   t  t |  | ƒ Sd  S(   N(   s   applys   _RLocks   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys   RLock@ s    s   _RLockc      sM   t  Z e d „ Z d „  Z d d „ Z d „  Z d „  Z d „  Z d „  Z	 RS(	   Nc    s2   t  i |  | ƒ t ƒ  |  _ t |  _ d |  _ d  S(   Ni    (	   s   _Verboses   __init__s   selfs   verboses   _allocate_locks   _RLock__blocks   Nones   _RLock__owners   _RLock__count(   s   selfs   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__E s    	c    s1   d |  i i |  i o |  i i ƒ  |  i f Sd  S(   Ns   <%s(%s, %d)>(   s   selfs	   __class__s   __name__s   _RLock__owners   getNames   _RLock__count(   s   self(    (    s   /usr/lib/python2.2/threading.pys   __repr__K s    i   c    sh   t  ƒ  } |  i | j o |  i d |  _ d Sn |  i i | ƒ } | o | |  _ d |  _ n | Sd  S(   Ni   (	   s   currentThreads   mes   selfs   _RLock__owners   _RLock__counts   _RLock__blocks   acquires   blockings   rc(   s   selfs   blockings   mes   rc(    (    s   /usr/lib/python2.2/threading.pys   acquireQ s    	 		 c    sC   t  ƒ  } |  i d |  _ } | o t |  _ |  i i ƒ  n d  S(   Ni   (	   s   currentThreads   mes   selfs   _RLock__counts   counts   Nones   _RLock__owners   _RLock__blocks   release(   s   selfs   mes   count(    (    s   /usr/lib/python2.2/threading.pys   releasec s    	 	c    s/   | \ } } |  i i ƒ  | |  _ | |  _ d  S(   N(   s   counts   owners   selfs   _RLock__blocks   acquires   _RLock__counts   _RLock__owner(   s   selfs   .2s   counts   owner(    (    s   /usr/lib/python2.2/threading.pys   _acquire_restorer s   		c    s?   |  i } d |  _ |  i } t |  _ |  i i ƒ  | | f Sd  S(   Ni    (   s   selfs   _RLock__counts   counts   _RLock__owners   owners   Nones   _RLock__blocks   release(   s   selfs   counts   owner(    (    s   /usr/lib/python2.2/threading.pys   _release_savey s     				c    s   |  i t ƒ  j Sd  S(   N(   s   selfs   _RLock__owners   currentThread(   s   self(    (    s   /usr/lib/python2.2/threading.pys	   _is_ownedƒ s    (
   s   __name__s
   __module__s   Nones   __init__s   __repr__s   acquires   releases   _acquire_restores   _release_saves	   _is_owned(    (    (    s   /usr/lib/python2.2/threading.pys   _RLockC s   				
c     s   t  t |  | ƒ Sd  S(   N(   s   applys
   _Conditions   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys	   Condition‡ s    s
   _Conditionc      s\   t  Z e e d „ Z d „  Z d „  Z d „  Z d „  Z e d „ Z d d „ Z	 d	 „  Z
 RS(
   Nc    sÊ   t  i |  | ƒ | t j o t ƒ  } n | |  _ | i |  _ | i	 |  _	 y | i
 |  _
 Wn t j
 o n Xy | i |  _ Wn t j
 o n Xy | i |  _ Wn t j
 o n Xg  |  _ d  S(   N(   s   _Verboses   __init__s   selfs   verboses   locks   Nones   RLocks   _Condition__locks   acquires   releases   _release_saves   AttributeErrors   _acquire_restores	   _is_owneds   _Condition__waiters(   s   selfs   locks   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__Œ s&    	c    s   d |  i t |  i ƒ f Sd  S(   Ns   <Condition(%s, %d)>(   s   selfs   _Condition__locks   lens   _Condition__waiters(   s   self(    (    s   /usr/lib/python2.2/threading.pys   __repr__¥ s    c    s   |  i i ƒ  d  S(   N(   s   selfs   _Condition__locks   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   _release_save¨ s    c    s   |  i i ƒ  d  S(   N(   s   selfs   _Condition__locks   acquire(   s   selfs   x(    (    s   /usr/lib/python2.2/threading.pys   _acquire_restore« s    c    s0   |  i i d ƒ o |  i i ƒ  d Sn d Sd  S(   Ni    i   (   s   selfs   _Condition__locks   acquires   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys	   _is_owned® s    c 	   s  t  ƒ  } t ƒ  } | i ƒ  |  i i | ƒ |  i ƒ  } zÑ | t j o | i ƒ  n³ t ƒ  | } d } xf d o^ | i d ƒ } | o Pn | t ƒ  } | d j o Pn t | d | d ƒ } t | ƒ ql W| o. y |  i i | ƒ Wn t j
 o n Xn Wd  |  i | ƒ Xd  S(   Nf0.00050000000000000001i   i    i   f0.050000000000000003(   s   currentThreads   mes   _allocate_locks   waiters   acquires   selfs   _Condition__waiterss   appends   _release_saves   saved_states   timeouts   Nones   _times   endtimes   delays   gotits	   remainings   mins   _sleeps   removes
   ValueErrors   _acquire_restore(	   s   selfs   timeouts   mes   delays   gotits   waiters   saved_states   endtimes	   remaining(    (    s   /usr/lib/python2.2/threading.pys   waitµ s>    	 	

  	 i   c    sœ   t  ƒ  } |  i } | |  } | o d  Sn |  i d |  | | d j o d p d ƒ x? | D]7 } | i ƒ  y | i	 | ƒ Wn t
 j
 o n Xq] Wd  S(   Ns"   %s.notify(): notifying %d waiter%si   s   ss    (   s   currentThreads   mes   selfs   _Condition__waiterss   ns   waiterss   _notes   waiters   releases   removes
   ValueError(   s   selfs   ns   mes   _Condition__waiterss   waiters   waiters(    (    s   /usr/lib/python2.2/threading.pys   notifyß s     	 	
  
c    s   |  i t |  i ƒ ƒ d  S(   N(   s   selfs   notifys   lens   _Condition__waiters(   s   self(    (    s   /usr/lib/python2.2/threading.pys	   notifyAllñ s    (   s   __name__s
   __module__s   Nones   __init__s   __repr__s   _release_saves   _acquire_restores	   _is_owneds   waits   notifys	   notifyAll(    (    (    s   /usr/lib/python2.2/threading.pys
   _ConditionŠ s   				*c     s   t  t |  | ƒ Sd  S(   N(   s   applys
   _Semaphores   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys	   Semaphoreõ s    s
   _Semaphorec      s,   t  Z d e d „ Z d d „ Z d „  Z RS(   Ni   c    s/   t  i |  | ƒ t t ƒ  ƒ |  _ | |  _ d  S(   N(	   s   _Verboses   __init__s   selfs   verboses	   Conditions   Locks   _Semaphore__conds   values   _Semaphore__value(   s   selfs   values   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__ü s     c    sp   d } |  i i ƒ  xE |  i d j o | o Pn |  i i ƒ  q W|  i d |  _ d } |  i i ƒ  | Sd  S(   Ni    i   (   s   rcs   selfs   _Semaphore__conds   acquires   _Semaphore__values   blockings   waits   release(   s   selfs   blockings   rc(    (    s   /usr/lib/python2.2/threading.pys   acquires       c    s;   |  i i ƒ  |  i d |  _ |  i i ƒ  |  i i ƒ  d  S(   Ni   (   s   selfs   _Semaphore__conds   acquires   _Semaphore__values   notifys   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   releases
     (   s   __name__s
   __module__s   Nones   __init__s   acquires   release(    (    (    s   /usr/lib/python2.2/threading.pys
   _Semaphoreø s   c     s   t  t |  | ƒ Sd  S(   N(   s   applys   _BoundedSemaphores   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys   BoundedSemaphores    s   _BoundedSemaphorec      s&   t  Z d  Z d e d „ Z d „  Z RS(   s6   Semaphore that checks that # releases is <= # acquiresi   c    s    t  i |  | | ƒ | |  _ d  S(   N(   s
   _Semaphores   __init__s   selfs   values   verboses   _initial_value(   s   selfs   values   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__$s    c    s1   |  i |  i j o t d ‚ n t i |  ƒ Sd  S(   Ns!   Semaphore released too many times(   s   selfs   _Semaphore__values   _initial_values
   ValueErrors
   _Semaphores   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   release(s    (   s   __name__s
   __module__s   __doc__s   Nones   __init__s   release(    (    (    s   /usr/lib/python2.2/threading.pys   _BoundedSemaphore"s    c     s   t  t |  | ƒ Sd  S(   N(   s   applys   _Events   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys   Event.s    s   _Eventc      s;   t  Z e d „ Z d „  Z d „  Z d „  Z e d „ Z RS(   Nc    s/   t  i |  | ƒ t t ƒ  ƒ |  _ d |  _ d  S(   Ni    (   s   _Verboses   __init__s   selfs   verboses	   Conditions   Locks   _Event__conds   _Event__flag(   s   selfs   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__5s    c    s   |  i Sd  S(   N(   s   selfs   _Event__flag(   s   self(    (    s   /usr/lib/python2.2/threading.pys   isSet:s    c    s4   |  i i ƒ  d |  _ |  i i ƒ  |  i i ƒ  d  S(   Ni   (   s   selfs   _Event__conds   acquires   _Event__flags	   notifyAlls   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   set=s    	c    s'   |  i i ƒ  d |  _ |  i i ƒ  d  S(   Ni    (   s   selfs   _Event__conds   acquires   _Event__flags   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   clearCs    	c    s=   |  i i ƒ  |  i o |  i i | ƒ n |  i i ƒ  d  S(   N(   s   selfs   _Event__conds   acquires   _Event__flags   waits   timeouts   release(   s   selfs   timeout(    (    s   /usr/lib/python2.2/threading.pys   waitHs    (   s   __name__s
   __module__s   Nones   __init__s   isSets   sets   clears   wait(    (    (    s   /usr/lib/python2.2/threading.pys   _Event1s
   			s	   Thread-%dc    s   t  d a  |  t  Sd  S(   Ni   (   s   _counters   template(   s   template(    (    s   /usr/lib/python2.2/threading.pys   _newnamePs     
s   Threadc      s¡   t  Z d Z e e e f  h  e d „ Z d „  Z d „  Z d „  Z d „  Z d „  Z	 d „  Z
 d	 „  Z e d
 „ Z d „  Z d „  Z d „  Z d „  Z d „  Z RS(   Ni    c    s„   t  i |  | ƒ | |  _ t | p t ƒ  ƒ |  _	 | |  _ | |  _ |  i ƒ  |  _ d |  _ d |  _ t t ƒ  ƒ |  _ d |  _ d  S(   Ni    i   (   s   _Verboses   __init__s   selfs   verboses   targets   _Thread__targets   strs   names   _newnames   _Thread__names   argss   _Thread__argss   kwargss   _Thread__kwargss   _set_daemons   _Thread__daemonics   _Thread__starteds   _Thread__stoppeds	   Conditions   Locks   _Thread__blocks   _Thread__initialized(   s   selfs   groups   targets   names   argss   kwargss   verbose(    (    s   /usr/lib/python2.2/threading.pys   __init__as     					c    s   t  ƒ  i ƒ  Sd  S(   N(   s   currentThreads   isDaemon(   s   self(    (    s   /usr/lib/python2.2/threading.pys   _set_daemonos    c    sd   d } |  i o
 d } n |  i o
 d } n |  i o | d } n d |  i i |  i | f Sd  S(   Ns   initials   starteds   stoppeds    daemons   <%s(%s, %s)>(   s   statuss   selfs   _Thread__starteds   _Thread__stoppeds   _Thread__daemonics	   __class__s   __name__s   _Thread__name(   s   selfs   status(    (    s   /usr/lib/python2.2/threading.pys   __repr__ss     




c    sE   t  i ƒ  |  t |  <t  i ƒ  t |  i f  ƒ d |  _ t d ƒ d  S(   Ni   f9.9999999999999995e-07(	   s   _active_limbo_locks   acquires   selfs   _limbos   releases   _start_new_threads   _Thread__bootstraps   _Thread__starteds   _sleep(   s   self(    (    s   /usr/lib/python2.2/threading.pys   start~s       


	c    s+   |  i o t |  i |  i |  i ƒ n d  S(   N(   s   selfs   _Thread__targets   applys   _Thread__argss   _Thread__kwargs(   s   self(    (    s   /usr/lib/python2.2/threading.pys   runŠs    
c    sÅ   z› d |  _ t i ƒ  |  t t ƒ  <t |  =t i ƒ  y |  i ƒ  WnU t	 j
 o nD t
 ƒ  } t d | ƒ t i i d |  i ƒ  | i ƒ  f ƒ n XWd  |  i ƒ  y |  i ƒ  Wn n XXd  S(   Ni   s   files   Exception in thread %s:
%s
(   s   selfs   _Thread__starteds   _active_limbo_locks   acquires   _actives
   _get_idents   _limbos   releases   runs
   SystemExits	   _StringIOs   ss
   _print_excs   _syss   stderrs   writes   getNames   getvalues   _Thread__stops   _Thread__delete(   s   selfs   s(    (    s   /usr/lib/python2.2/threading.pys   __bootstrapŽs.    	

  	* 
c    s4   |  i i ƒ  d |  _ |  i i ƒ  |  i i ƒ  d  S(   Ni   (   s   selfs   _Thread__blocks   acquires   _Thread__stoppeds	   notifyAlls   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   __stop­s    	c    s"   t  i ƒ  t t ƒ  =t  i ƒ  d  S(   N(   s   _active_limbo_locks   acquires   _actives
   _get_idents   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   __delete³s    

c    sž   |  i i ƒ  | t j o$ x |  i o |  i i ƒ  q WnP t ƒ  | } x? |  i o3 | t ƒ  } | d j o Pn |  i i | ƒ qN W|  i i
 ƒ  d  S(   Ni    (   s   selfs   _Thread__blocks   acquires   timeouts   Nones   _Thread__stoppeds   waits   _times   deadlines   delays   release(   s   selfs   timeouts   delays   deadline(    (    s   /usr/lib/python2.2/threading.pys   join¸s(            c    s   |  i Sd  S(   N(   s   selfs   _Thread__name(   s   self(    (    s   /usr/lib/python2.2/threading.pys   getNameÓs     c    s   t  | ƒ |  _ d  S(   N(   s   strs   names   selfs   _Thread__name(   s   selfs   name(    (    s   /usr/lib/python2.2/threading.pys   setName×s     c    s   |  i o |  i Sd  S(   N(   s   selfs   _Thread__starteds   _Thread__stopped(   s   self(    (    s   /usr/lib/python2.2/threading.pys   isAliveÛs     c    s   |  i Sd  S(   N(   s   selfs   _Thread__daemonic(   s   self(    (    s   /usr/lib/python2.2/threading.pys   isDaemonßs     c    s   | |  _ d  S(   N(   s   daemonics   selfs   _Thread__daemonic(   s   selfs   daemonic(    (    s   /usr/lib/python2.2/threading.pys	   setDaemonãs      (   s   __name__s
   __module__s   _Thread__initializeds   Nones   __init__s   _set_daemons   __repr__s   starts   runs   _Thread__bootstraps   _Thread__stops   _Thread__deletes   joins   getNames   setNames   isAlives   isDaemons	   setDaemon(    (    (    s   /usr/lib/python2.2/threading.pys   Thread]s   											c     s   t  |  | Ž  Sd  S(   N(   s   _Timers   argss   kwargs(   s   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys   Timerês    s   _Timerc      s/   t  Z d  Z g  h  d „ Z d „  Z d „  Z RS(   s²   Call a function after a specified number of seconds:

    t = Timer(30.0, f, args=[], kwargs={})
    t.start()
    t.cancel() # stop the timer's action if it's still waiting
    c    sA   t  i |  ƒ | |  _ | |  _ | |  _ | |  _ t ƒ  |  _ d  S(   N(	   s   Threads   __init__s   selfs   intervals   functions   argss   kwargss   Events   finished(   s   selfs   intervals   functions   argss   kwargs(    (    s   /usr/lib/python2.2/threading.pys   __init__õs    				c    s   |  i i ƒ  d S(   s(   Stop the timer if it hasn't finished yetN(   s   selfs   finisheds   set(   s   self(    (    s   /usr/lib/python2.2/threading.pys   cancelýs     c    sO   |  i i |  i ƒ |  i i ƒ  o |  i |  i |  i Ž  n |  i i ƒ  d  S(   N(	   s   selfs   finisheds   waits   intervals   isSets   functions   argss   kwargss   set(   s   self(    (    s   /usr/lib/python2.2/threading.pys   runs    (   s   __name__s
   __module__s   __doc__s   __init__s   cancels   run(    (    (    s   /usr/lib/python2.2/threading.pys   _Timerís    	s   _MainThreadc      s#   t  Z d „  Z d „  Z d „  Z RS(   Nc    sZ   t  i |  d d ƒd |  _ t i ƒ  |  t t ƒ  <t i ƒ  d  k	 } | i
 |  i ƒ d  S(   Ns   names
   MainThreadi   (   s   Threads   __init__s   selfs   _Thread__starteds   _active_limbo_locks   acquires   _actives
   _get_idents   releases   atexits   registers   _MainThread__exitfunc(   s   selfs   atexit(    (    s   /usr/lib/python2.2/threading.pys   __init__s    	

	c    s   d Sd  S(   Ni    (    (   s   self(    (    s   /usr/lib/python2.2/threading.pys   _set_daemons    c    sN   |  i ƒ  t ƒ  } | o n x | o | i ƒ  t ƒ  } q! W|  i ƒ  d  S(   N(   s   selfs   _Thread__stops   _pickSomeNonDaemonThreads   ts   joins   _Thread__delete(   s   selfs   t(    (    s   /usr/lib/python2.2/threading.pys
   __exitfuncs    
	 
 (   s   __name__s
   __module__s   __init__s   _set_daemons   _MainThread__exitfunc(    (    (    s   /usr/lib/python2.2/threading.pys   _MainThread
s   			c     s?   x4 t  ƒ  D]) }  |  i ƒ  o
 |  i ƒ  o |  Sn q
 Wt Sd  S(   N(   s	   enumerates   ts   isDaemons   isAlives   None(   s   t(    (    s   /usr/lib/python2.2/threading.pys   _pickSomeNonDaemonThread%s
    
 s   _DummyThreadc      s&   t  Z d „  Z d „  Z e d „ Z RS(   Nc    sG   t  i |  d t d ƒ ƒd |  _ t i ƒ  |  t t ƒ  <t i	 ƒ  d  S(   Ns   names   Dummy-%di   (
   s   Threads   __init__s   selfs   _newnames   _Thread__starteds   _active_limbo_locks   acquires   _actives
   _get_idents   release(   s   self(    (    s   /usr/lib/python2.2/threading.pys   __init__5s
    	
c    s   d Sd  S(   Ni   (    (   s   self(    (    s   /usr/lib/python2.2/threading.pys   _set_daemon<s    c    s   d  S(   N(    (   s   selfs   timeout(    (    s   /usr/lib/python2.2/threading.pys   join?s    (   s   __name__s
   __module__s   __init__s   _set_daemons   Nones   join(    (    (    s   /usr/lib/python2.2/threading.pys   _DummyThread3s   		c      s0   y t  t ƒ  SWn t j
 o t ƒ  Sn Xd  S(   N(   s   _actives
   _get_idents   KeyErrors   _DummyThread(    (    (    s   /usr/lib/python2.2/threading.pys   currentThreadEs    c     s2   t  i ƒ  t t ƒ t t ƒ }  t  i ƒ  |  Sd  S(   N(   s   _active_limbo_locks   acquires   lens   _actives   _limbos   counts   release(   s   count(    (    s   /usr/lib/python2.2/threading.pys   activeCountLs    

c     s2   t  i ƒ  t i ƒ  t i ƒ  }  t  i ƒ  |  Sd  S(   N(   s   _active_limbo_locks   acquires   _actives   valuess   _limbos   actives   release(   s   active(    (    s   /usr/lib/python2.2/threading.pys	   enumerateRs    

c     s  d t  f d „  ƒ  Y} d t f d „  ƒ  Y} d t f d „  ƒ  Y} d }	 d }
 d	 }  | |
 ƒ } g  } xE t
 |	 ƒ D]7 } | | |  ƒ } | i d
 | d ƒ | i | ƒ qs W| | |  |	 ƒ } x" | D] } | i ƒ  t d ƒ qÈ W| i ƒ  x | D] } | i ƒ  q÷ W| i ƒ  d  S(   Ns   BoundedQueuec      s#   t  Z d „  Z d „  Z d „  Z RS(   Nc    sS   t  i |  ƒ t ƒ  |  _ t |  i ƒ |  _ t |  i ƒ |  _ | |  _ g  |  _	 d  S(   N(
   s   _Verboses   __init__s   selfs   RLocks   mons	   Conditions   rcs   wcs   limits   queue(   s   selfs   limit(    (    s   /usr/lib/python2.2/threading.pys   __init__ds    	c    s•   |  i i ƒ  x; t |  i ƒ |  i j o! |  i d | ƒ |  i i	 ƒ  q W|  i i
 | ƒ |  i d | t |  i ƒ ƒ |  i i ƒ  |  i i ƒ  d  S(   Ns   put(%s): queue fulls    put(%s): appended, length now %d(   s   selfs   mons   acquires   lens   queues   limits   _notes   items   wcs   waits   appends   rcs   notifys   release(   s   selfs   item(    (    s   /usr/lib/python2.2/threading.pys   putls     	c    s   |  i i ƒ  x* |  i o |  i d ƒ |  i i ƒ  q W|  i d } |  i d =|  i d | t |  i ƒ ƒ |  i	 i
 ƒ  |  i i ƒ  | Sd  S(   Ns   get(): queue emptyi    s   get(): got %s, %d left(   s   selfs   mons   acquires   queues   _notes   rcs   waits   items   lens   wcs   notifys   release(   s   selfs   item(    (    s   /usr/lib/python2.2/threading.pys   getws     
(   s   __name__s
   __module__s   __init__s   puts   get(    (    (    s   /usr/lib/python2.2/threading.pys   BoundedQueuebs   		s   ProducerThreadc      s   t  Z d „  Z d „  Z RS(   Nc    s)   t  i |  d d ƒ| |  _ | |  _ d  S(   Ns   names   Producer(   s   Threads   __init__s   selfs   queues   quota(   s   selfs   queues   quota(    (    s   /usr/lib/python2.2/threading.pys   __init__…s    	c    sj   d k  l  } d } xP | |  i j  o? | d } |  i i d |  i ƒ  | f ƒ t | ƒ  d ƒ q Wd  S(   N(   s   randomi    i   s   %s.%df1.0000000000000001e-05(   s   randoms   counters   selfs   quotas   queues   puts   getNames   _sleep(   s   selfs   randoms   counter(    (    s   /usr/lib/python2.2/threading.pys   runŠs     
 (   s   __name__s
   __module__s   __init__s   run(    (    (    s   /usr/lib/python2.2/threading.pys   ProducerThreadƒs   	s   ConsumerThreadc      s   t  Z d „  Z d „  Z RS(   Nc    s)   t  i |  d d ƒ| |  _ | |  _ d  S(   Ns   names   Consumer(   s   Threads   __init__s   selfs   queues   count(   s   selfs   queues   count(    (    s   /usr/lib/python2.2/threading.pys   __init__•s    	c    s@   x9 |  i d j o( |  i i ƒ  } | GH|  i d |  _ q Wd  S(   Ni    i   (   s   selfs   counts   queues   gets   item(   s   selfs   item(    (    s   /usr/lib/python2.2/threading.pys   runšs
     (   s   __name__s
   __module__s   __init__s   run(    (    (    s   /usr/lib/python2.2/threading.pys   ConsumerThread“s   	i   i   i   s   Producer-%di   f9.9999999999999995e-07(   s   _Verboses   BoundedQueues   Threads   ProducerThreads   ConsumerThreads   NPs   QLs   NIs   Qs   Ps   ranges   is   ts   setNames   appends   Cs   starts   _sleeps   join(   s   NIs   Cs   ProducerThreads   is   BoundedQueues   Ps   ConsumerThreads   Qs   ts   NPs   QL(    (    s   /usr/lib/python2.2/threading.pys   _test`s.    !  

 s   __main__(2   s   __doc__s   syss   times   threads	   tracebacks   StringIOs   _syss   _times   sleeps   _sleeps   start_new_threads   _start_new_threads   allocate_locks   _allocate_locks	   get_idents
   _get_idents   errors   ThreadErrors	   print_excs
   _print_excs	   _StringIOs   _VERBOSEs   _Verboses   Locks   RLocks   _RLocks	   Conditions
   _Conditions	   Semaphores
   _Semaphores   BoundedSemaphores   _BoundedSemaphores   Events   _Events   _counters   _newnames   _active_limbo_locks   _actives   _limbos   Threads   Timers   _Timers   _MainThreads   _pickSomeNonDaemonThreads   _DummyThreads   currentThreads   activeCounts	   enumerates   _tests   __name__()   s	   tracebacks   _BoundedSemaphores   currentThreads   _Timers   _tests	   Semaphores	   _StringIOs   activeCounts   _pickSomeNonDaemonThreads   _sleeps	   enumerates   ThreadErrors   _start_new_threads   BoundedSemaphores
   _print_excs   _Events   _RLocks   _active_limbo_locks	   Conditions   _Verboses   _DummyThreads   Threads
   _Conditions
   _get_idents   RLocks   syss   Timers
   _Semaphores   _newnames   threads   StringIOs   _limbos   Locks   _actives   _MainThreads   _syss   _times   _allocate_locks   times   Events   _VERBOSE(    (    s   /usr/lib/python2.2/threading.pys   ? sf   													 		D	k	'										S