‡Æ »Mö9csodZy0defd„ƒYZdefd„ƒYZWnej odZdZnXdfd„ƒYZd S( s'A multi-producer, multi-consumer queue.sEmptycsRS(N((s"/mit/python/lib/python2.0/Queue.pysEmptyssFullcsRS(N((s"/mit/python/lib/python2.0/Queue.pysFullss Queue.Emptys Queue.FullsQueuecs‰dd„Zd„Zd„Zd„Zdd„Zd„Zdd „Zd „Zd „Zd „Z d „Z d„Z d„Z d„Z RS(NcsTdk}|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"/mit/python/lib/python2.0/Queue.pys__init__s   ics.|iiƒ|iƒ}|iiƒ|SdS(s9Return the approximate size of the queue (not reliable!).N(sselfsmutexsacquires_qsizesnsrelease(sselfsns"/mit/python/lib/python2.0/Queue.pysqsizes    cs.|iiƒ|iƒ}|iiƒ|SdS(s<Return 1 if the queue is empty, 0 otherwise (not reliable!).N(sselfsmutexsacquires_emptysnsrelease(sselfsns"/mit/python/lib/python2.0/Queue.pysempty%s    cs.|iiƒ|iƒ}|iiƒ|SdS(s;Return 1 if the queue is full, 0 otherwise (not reliable!).N(sselfsmutexsacquires_fullsnsrelease(sselfsns"/mit/python/lib/python2.0/Queue.pysfull,s    cs¤|o|iiƒn|iidƒ o t‚n|iiƒ|iƒ}|i|ƒ|o|i i ƒn|i ƒ o|ii ƒn|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"/mit/python/lib/python2.0/Queue.pysput3s    ics|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"/mit/python/lib/python2.0/Queue.pys put_nowaitHscs§|o|iiƒn|iidƒ o t‚n|iiƒ|iƒ}|iƒ}|o|i i ƒn|i ƒ o|ii ƒn|ii ƒ|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"/mit/python/lib/python2.0/Queue.pysgetPs     cs|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"/mit/python/lib/python2.0/Queue.pys get_nowaitfscs||_g|_dS(N(smaxsizesselfsqueue(sselfsmaxsizes"/mit/python/lib/python2.0/Queue.pys_initss cst|iƒSdS(N(slensselfsqueue(sselfs"/mit/python/lib/python2.0/Queue.pys_qsizewscs |i SdS(N(sselfsqueue(sselfs"/mit/python/lib/python2.0/Queue.pys_empty{scs*|idjot|iƒ|ijSdS(Ni(sselfsmaxsizeslensqueue(sselfs"/mit/python/lib/python2.0/Queue.pys_fullscs|ii|ƒdS(N(sselfsqueuesappendsitem(sselfsitems"/mit/python/lib/python2.0/Queue.pys_putƒscs|id}|id=|SdS(Ni(sselfsqueuesitem(sselfsitems"/mit/python/lib/python2.0/Queue.pys_get‡s  (s__init__sqsizesemptysfullsputs put_nowaitsgets get_nowaits_inits_qsizes_emptys_fulls_puts_get(s"/mit/python/lib/python2.0/Queue.pysQueues           N(s__doc__s ExceptionsEmptysFulls TypeErrorsQueue(s"/mit/python/lib/python2.0/Queue.pys?s