™N âu¦9csy6defd„ƒYZdefd„ƒYZWn( ej o dZdZnXdfd„ƒYZdS( sEmptycsRS(N((s)/usr/lib/python1.5/site-packages/Queue.pysEmptyssFullcs RS(N((s)/usr/lib/python1.5/site-packages/Queue.pysFullss Queue.Emptys Queue.FullsQueuecs³d„Zd„Z%d„Z,d„Z3dd„ZHd„ZPdd„Zfd „Zsd „Zwd „Z {d „Z d „Z ƒd„Z ‡d„Z RS(Ncsik}|i|ƒ|iƒ|_|iƒ|_|iiƒ|iƒ|_dS(svInitialize a queue object with a given maximum size. If maxsize is <= 0, the queue size is infinite. N( sthreadsselfs_initsmaxsizes allocate_locksmutexsesemasacquiresfsema(sselfsmaxsizesthreads)/usr/lib/python1.5/site-packages/Queue.pys__init__s cs@ |iiƒ!|iƒ}"|iiƒ#|SdS(s9Return the approximate size of the queue (not reliable!).N(sselfsmutexsacquires_qsizesnsrelease(sselfsns)/usr/lib/python1.5/site-packages/Queue.pysqsizes cs@%&'|iiƒ(|iƒ})|iiƒ*|SdS(s<Return 1 if the queue is empty, 0 otherwise (not reliable!).N(sselfsmutexsacquires_emptysnsrelease(sselfsns)/usr/lib/python1.5/site-packages/Queue.pysempty%s cs@,-.|iiƒ/|iƒ}0|iiƒ1|SdS(s;Return 1 if the queue is full, 0 otherwise (not reliable!).N(sselfsmutexsacquires_fullsnsrelease(sselfsns)/usr/lib/python1.5/site-packages/Queue.pysfull,s csÎ3:;|o<|iiƒn%=|iidƒ o >t‚n?|iiƒ@|iƒ}A|i|ƒB|oC|i i ƒnD|i ƒ oE|ii ƒnF|ii ƒdS(sPut an item into the queue. If optional arg 'block' is 1 (the default), block if necessary until a free slot is available. Otherwise (block is 0), put an item on the queue if a free slot is immediately available, else raise the Full exception. iN( sblocksselfsfsemasacquiresFullsmutexs_emptys was_emptys_putsitemsesemasreleases_full(sselfsitemsblocks was_emptys)/usr/lib/python1.5/site-packages/Queue.pysput3s   icsHMN|i|dƒSdS(s©Put an item into the queue without blocking. Only enqueue the item if a free slot is immediately available. Otherwise raise the Full exception. iN(sselfsputsitem(sselfsitems)/usr/lib/python1.5/site-packages/Queue.pys put_nowaitHscsÔPWX|oY|iiƒn%Z|iidƒ o [t‚n\|iiƒ]|iƒ}^|iƒ}_|o`|i i ƒna|i ƒ ob|ii ƒnc|ii ƒd|SdS(sRemove and return an item from the queue. If optional arg 'block' is 1 (the default), block if necessary until an item is available. Otherwise (block is 0), return an item if one is immediately available, else raise the Empty exception. iN( sblocksselfsesemasacquiresEmptysmutexs_fullswas_fulls_getsitemsfsemasreleases_empty(sselfsblockswas_fullsitems)/usr/lib/python1.5/site-packages/Queue.pysgetPs   csfkl|idƒSdS(s¬Remove and return an item from the queue without blocking. Only get an item if one is immediately available. Otherwise raise the Empty exception. iN(sselfsget(sselfs)/usr/lib/python1.5/site-packages/Queue.pys get_nowaitfscsst||_ug|_dS(N(smaxsizesselfsqueue(sselfsmaxsizes)/usr/lib/python1.5/site-packages/Queue.pys_initss cswxt|iƒSdS(N(slensselfsqueue(sselfs)/usr/lib/python1.5/site-packages/Queue.pys_qsizewscs{||i SdS(N(sselfsqueue(sselfs)/usr/lib/python1.5/site-packages/Queue.pys_empty{scs0€|idjot|iƒ|ijSdS(Ni(sselfsmaxsizeslensqueue(sselfs)/usr/lib/python1.5/site-packages/Queue.pys_fullscsƒ„|ii|ƒdS(N(sselfsqueuesappendsitem(sselfsitems)/usr/lib/python1.5/site-packages/Queue.pys_putƒscs+‡ˆ|id}‰|id=Š|SdS(Ni(sselfsqueuesitem(sselfsitems)/usr/lib/python1.5/site-packages/Queue.pys_get‡s (s__init__sqsizesemptysfullsputs put_nowaitsgets get_nowaits_inits_qsizes_emptys_fulls_puts_get(s)/usr/lib/python1.5/site-packages/Queue.pysQueues         N(s ExceptionsEmptysFulls TypeErrorsQueue(s)/usr/lib/python1.5/site-packages/Queue.pys?s