-í
ęś<c       s?  d  k  l Z d k Z d k Z d k Z e i   Z e i   Z d a e i   Z	 e	 i
   d Z d   Z d a d   Z x e e  D] Z e   q Wd GHe	 i
   d GHd f  d	     YZ d
 Z d   Z d GHe	 i
 d  o e d  n e e  Z e a x' e e  D] Z e i e e f  qWe	 i
   d GHd S(   (   s   verboseNi    i
   c    sŻ   t  i   t i   t } t  i   t o" d G|  Gd Gt | d  Gd GHn t	 i
 |  t o d G|  Gd GHn t i   t d a t d j o t i   n t i   d  S(   Ns   tasks   will run fori   s   secs   donei    (   s   rmutexs   acquires   randoms   numtaskss   delays   releases   verboses   idents   rounds   times   sleeps   mutexs   runnings   done(   s   idents   delay(    (    s&   /usr/lib/python2.2/test/test_thread.pys   task s     

"

c      sS   t  i   t d a t o d Gt GHn t i t t f  t d a t  i   d  S(   Ni   s   creating task(	   s   mutexs   acquires
   next_idents   verboses   threads   start_new_threads   tasks   runnings   release(    (    (    s&   /usr/lib/python2.2/test/test_thread.pys   newtask# s     


s!   waiting for all tasks to completes   all tasks dones   barrierc      s   t  Z d   Z d   Z RS(   Nc    sA   | |  _  d |  _ t i   |  _ t i   |  _ |  i i   d  S(   Ni    (   s   ns   selfs   waitings   threads   allocate_locks   checkins   checkouts   acquire(   s   selfs   n(    (    s&   /usr/lib/python2.2/test/test_thread.pys   __init__5 s
    		c    sť   |  i |  i f \ } } | i   |  i d |  _ |  i |  i j o" |  i d |  _ | i   d  Sn | i   | i   |  i d |  _ |  i d j o | i   d  Sn | i   d  S(   Ni   i    (   s   selfs   checkins   checkouts   acquires   waitings   ns   release(   s   selfs   checkouts   checkin(    (    s&   /usr/lib/python2.2/test/test_thread.pys   enter< s    




(   s   __name__s
   __module__s   __init__s   enter(    (    (    s&   /usr/lib/python2.2/test/test_thread.pys   barrier4 s   	i   c    s  xÇ t  t  D]š } |  d j o
 d } n% t i   t i   t } t i	   t
 o" d G|  Gd Gt | d  Gd GHn t i |  t
 o d G|  Gd G| GHn t i   t
 o d G|  Gd G| GHn q Wt i   t d 8a t d j } t i	   | o t i	   n d  S(	   Ni    f0.001s   tasks   will run fori   s   secs   entering barriers   leaving barrier(   s   ranges   numtripss   is   idents   delays   rmutexs   acquires   randoms   numtaskss   releases   verboses   rounds   times   sleeps   bars   enters   mutexs   runnings   finisheds   done(   s   idents   is   finisheds   delay(    (    s&   /usr/lib/python2.2/test/test_thread.pys   task2O s,      


"



s   
*** Barrier Test ***s$   'done' should have remained acquired(   s   test_supports   verboses   randoms   threads   times   allocate_locks   mutexs   rmutexs   runnings   dones   acquires   numtaskss   tasks
   next_idents   newtasks   ranges   is   barriers   numtripss   task2s
   ValueErrors   bars   start_new_thread(   s   numtripss   task2s   tasks   bars   verboses   threads   is   randoms   newtasks   barriers   dones   times   rmutexs   mutexs   numtasks(    (    s&   /usr/lib/python2.2/test/test_thread.pys   ? s>   			
		
 
	 
