File: //proc/3/root/proc/3/cwd/usr/lib/python2.4/Demo/threads/sync.pyo
mò
‚=5Dc @ sº d k Z d f d „ ƒ YZ d f d „ ƒ YZ d f d „ ƒ YZ d f d „ ƒ YZ d f d
„ ƒ YZ d „ Z d „ Z d
„ Z d „ Z d „ Z
d „ Z e d j o e ƒ n d S( Nt conditionc B sD t Z d d „ Z d „ Z d „ Z d „ Z d „ Z d d „ Z RS( Nc C s² | d j o t i ƒ | _ n7 t | d ƒ o t | d ƒ o
| | _ n
t d ‚ t i ƒ | _ | i i ƒ t i ƒ | _
d | _ d | _ d | _
d | _ d | _ d S( Nt acquiret releases. condition constructor requires a lock argumenti ( t lockt Nonet threadt
allocate_lockt selft mutext hasattrt TypeErrort checkoutR t idlockt idt waitingt pendingt toreleaset releasing( R R ( ( t' /usr/lib/python2.4/Demo/threads/sync.pyt __init__ s
c C s | i i ƒ d S( N( R R R ( R ( ( R R * s c C s | i i ƒ d S( N( R R R ( R ( ( R R - s c C s= | i | i | i } } } | i ƒ p
t d ‚ n | i ƒ | i } | i d | _ | i
ƒ | i
ƒ xB | i ƒ | i ƒ | | i j o Pn | i
ƒ | i
ƒ qq W| i d | _ | i d | _ | i o | i
ƒ n; d | _
| i | i j o
d j n o
d | _ n | i
ƒ | i ƒ d S( Ns1 condition must be .acquire'd when .wait() invokedi i ( R R R R t lockedt
ValueErrorR R
t myidR R R R R ( R R R R R ( ( R t wait0 s.
$
c C s | i d ƒ d S( Ni ( R t broadcast( R ( ( R t signalN s iÿÿÿÿc C sö | d j o t d | f ‚ n | d j o d Sn | i i ƒ | i o0 | i | i | _ d | _ | i d | _ n | d j o | i | _ n t | i | i | ƒ | _ | i o% | i
o d | _
| i i ƒ n | i i ƒ d S( Niÿÿÿÿs .broadcast called with num %ri i (
t numR R R R R R R
R t minR R R ( R R ( ( R R Q s"
( t __name__t
__module__R R R R R R R ( ( ( R R s t barrierc B s t Z d „ Z d „ Z RS( Nc C s" | | _ | | _ t ƒ | _ d S( N( t nR t togoR t full( R R ( ( R R f s c C s_ | i } | i ƒ | i d | _ | i o | i ƒ n | i | _ | i ƒ | i ƒ d S( Ni ( R R! R R R R R R ( R R! ( ( R t enterk s
( R R R R" ( ( ( R R e s t eventc B s5 t Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( Nc C s d | _ t ƒ | _ d S( Ni ( R t stateR t posted( R ( ( R R w s c C s4 | i i ƒ d | _ | i i ƒ | i i ƒ d S( Ni ( R R% R R$ R R ( R ( ( R t post{ s
c C s' | i i ƒ d | _ | i i ƒ d S( Ni ( R R% R R$ R ( R ( ( R t clear s
c C s' | i i ƒ | i } | i i ƒ | S( N( R R% R R$ t answerR ( R R( ( ( R t is_posted† s
c C s9 | i i ƒ | i p | i i ƒ n | i i ƒ d S( N( R R% R R$ R R ( R ( ( R R Œ s
( R R R R& R' R) R ( ( ( R R# v s
t semaphorec B s& t Z d d „ Z d „ Z d „ Z RS( Ni c C s@ | d j o t d | ‚ n | | _ | | _ t ƒ | _ d S( Ni s semaphore count %d; must be >= 1( t countR R t maxcountR t nonzero( R R+ ( ( R R “ s
c C sS | i i ƒ x" | i d j o | i i ƒ q W| i d | _ | i i ƒ d S( Ni i ( R R- R R+ R R ( R ( ( R t pš s
c C sb | i i ƒ | i | i j o t d | i ‚ n | i d | _ | i i ƒ | i i ƒ d S( Ns: .v() tried to raise semaphore count above initial value %ri ( R R- R R+ R, R R R ( R ( ( R t v¡ s
( R R R R. R/ ( ( ( R R* ’ s t mrswc B s> t Z d „ Z d „ Z d „ Z d „ Z d „ Z d „ Z RS( Nc C sR t i ƒ | _ d | _ d | _ d | _ t | i ƒ | _ t | i ƒ | _ d S( Ni (
R R R t rwOKt nrt nwt writingR t readOKt writeOK( R ( ( R R « s c C sM | i i ƒ x | i o | i i ƒ q W| i d | _ | i i ƒ d S( Ni ( R R1 R R3 R5 R R2 R ( R ( ( R t read_in¶ s
c C sl | i i ƒ | i d j o
t d ‚ n | i d | _ | i d j o | i i ƒ n | i i ƒ d S( Ni s, .read_out() invoked without an active readeri ( R R1 R R2 R R6 R R ( R ( ( R t read_out½ s
c C s` | i i ƒ | i d | _ x& | i p
| i o | i i ƒ q Wd | _ | i i ƒ d S( Ni ( R R1 R R3 R4 R2 R6 R R ( R ( ( R t write_inÇ s
c C sv | i i ƒ | i p
t d ‚ n d | _ | i d | _ | i o | i i ƒ n | i i ƒ | i i
ƒ d S( Ns- .write_out() invoked without an active writeri i ( R R1 R R4 R R3 R6 R R5 R R ( R ( ( R t write_outÏ s
c C sy | i i ƒ | i p
t d ‚ n d | _ | i d | _ | i d | _ | i p | i i ƒ n | i i ƒ d S( Ns1 .write_to_read() invoked without an active writeri i (
R R1 R R4 R R3 R2 R5 R R ( R ( ( R t
write_to_readÜ s
( R R R R7 R8 R9 R: R; ( ( ( R R0 ª s
c G sy t i ƒ t d } a t i ƒ t i ƒ t i | ƒ d G| Gd Gt t ƒ Gd GHt i ƒ t i
| | f | ƒ d S( Ni s starting threads --t alive(
t tidR t TIDR
R t ioR< t appendt lenR t start_new_threadt funct args( RC RD R
( ( R t _new_threadï s "<c
C s[ t i ƒ d G| Gd G| G| GHt i ƒ | | d j oå | | } | d } xS t | | ƒ D]B } | | | j o+ | | | | | | <| | <| d } q^ q^ W| | d | | | <| | d <t ƒ } t ƒ } t t | | | d | ƒ t t | | | | ƒ | i ƒ | i ƒ n t i ƒ d G| Gd GHt i | ƒ t i ƒ | i ƒ d S( NR t qsorti s
qsort done( R? R R= t lt rR t at pivott jt ranget iR# t l_subarray_sortedt r_subarray_sortedRE t _qsortR R< t removet finishedR& (
R= RI RG RH RR RO RM RK RN RJ ( ( R RP ÷ s$ )
!
.c C s½ t i ƒ d G| Gd GHt i ƒ x] t d t | ƒ ƒ D]F } t i ƒ t d | ƒ } t i ƒ | | | | | | <| | <q7 Wt i ƒ d G| Gd GHt i | ƒ t i ƒ | i ƒ d S( NR s randomizing arrayi i s randomizing done( R? R R= R RL RA RI RM t wht randintRK R< RQ RR R& ( R= RI RR RM RK ( ( R t
_randarray s ! #!.c C s0 | t t | ƒ ƒ j o t d | f ‚ n d S( Ns a not sorted( RI RL RA R ( RI ( ( R t _check_sort s c C s6 t i ƒ d G| Gd G| GHt i ƒ t ƒ } t t | | ƒ | i ƒ t i ƒ d G| Gd G| GHt i ƒ | i
ƒ t t | d t | ƒ | ƒ | i ƒ t
| ƒ t i ƒ d G| Gd GHt i ƒ | i ƒ t i ƒ d G| Gd GHt i ƒ t i ƒ t i | ƒ t i ƒ | i ƒ | i ƒ | i ƒ d S( NR t randomizingt sortingi s entering barriers leaving barrier( R? R R= RI R R# RR RE RU R R' RP RA RV t barR" R< RQ t doneR& ( R= RI RY RZ RR ( ( R t
_run_one_sort s %
%
!
!!
c C sY d k } | i a d a t i ƒ a t i ƒ a t i ƒ a g a d } g } x/ t | ƒ D]! } | i
t | d d ƒ ƒ q[ Wt | ƒ } t ƒ } x+ t | ƒ D] } t t | | | | ƒ q¢ W| i ƒ d GHt o t d t f ‚ n xY t | ƒ D]K } | | } t | ƒ | d d j o t d | d f ‚ n t | ƒ qù Wd Gt Gd
GHd S( Ni i i i
s* all threads done, and checking results ...s threads still alive at ends length of arrays
screwed ups test passed!s threads created in all( t randomRT R> R R R= R? RS R< t NSORTSt arraysRL RM R@ R RY R# RR RE R[ R R RI RA RV ( R\ R] RR RI RY RM R^ ( ( R t test7 s:
t __main__(
R R R R# R* R0 RE RP RU RV R[ R_ R ( R R R[ RE R0 R_ RP R* RU R# R RV ( ( R t ? s T E
!