ó ú2ec@s¼dZddlZddlZddlmZdejfd„ƒYZdada d„Z d„Z d„Z e a ad ejfd „ƒYZdadad „Zd „Zd „ZdS(s¿ threadedprint.py ================ :author: Ian Bicking :date: 12 Jul 2004 Multi-threaded printing; allows the output produced via print to be separated according to the thread. To use this, you must install the catcher, like:: threadedprint.install() The installation optionally takes one of three parameters: default The default destination for print statements (e.g., ``sys.stdout``). factory A function that will produce the stream for a thread, given the thread's name. paramwriter Instead of writing to a file-like stream, this function will be called like ``paramwriter(thread_name, text)`` for every write. The thread name is the value returned by ``threading.current_thread().name``, a string (typically something like Thread-N). You can also submit file-like objects for specific threads, which will override any of these parameters. To do this, call ``register(stream, [threadName])``. ``threadName`` is optional, and if not provided the stream will be registered for the current thread. If no specific stream is registered for a thread, and no default has been provided, then an error will occur when anything is written to ``sys.stdout`` (or printed). Note: the stream's ``write`` method will be called in the thread the text came from, so you should consider thread safety, especially if multiple threads share the same writer. Note: if you want access to the original standard out, use ``sys.__stdout__``. You may also uninstall this, via:: threadedprint.uninstall() TODO ---- * Something with ``sys.stderr``. * Some default handlers. Maybe something that hooks into `logging`. * Possibly cache the results of ``factory`` calls. This would be a semantic change. iÿÿÿÿN(t filemixint PrintCatchercBs†eZd d d ed„Zejd„Zd„Zd„Z d„Z d„Z d„Z d„Z d ejd„Zd ejd „ZRS( cCsÏttd„|||gƒƒdks3tdƒ‚|r\| sPtd|ƒ‚tj}n|rq|j|_n6|r†|j|_n!|r›|j|_n |j |_||_ ||_ ||_ i|_ dS(NcSs |dk S(N(tNone(tx((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pytGtis<You can only provide one of default, factory, or paramwriters:You cannot pass in both default (%r) and leave_stdout=True(tlentfiltertAssertionErrortsyststdoutt _writedefaultt _defaultfunct _writefactoryt _writeparamt _writeerrort_defaultt_factoryt _paramwritert _catchers(tselftdefaulttfactoryt paramwritert leave_stdout((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyt__init__Es&         cCsRtƒj}|j}|j|ƒs7|j||ƒn||}|j|ƒdS(N(tcurrent_threadtnameRthas_keyR twrite(Rtvt currentThreadRtcatcherstcatcher((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR\s    cGsLtjƒj}|j}||kr7|jj|Œn||j|ŒdS(N(t threadingRRRRtseek(RtargsRR ((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR#es   cGsLtjƒj}|j}||kr7|jj|Œn||j|ŒdS(N(R"RRRRtread(RR$RR ((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR%ns   cCs|jj|ƒdS(N(RR(RRR((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR wscCs|j|ƒj|ƒdS(N(RR(RRR((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR zscCs|j||ƒdS(N(R(RRR((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR}scCststd|ƒ‚dS(Ns8There is no PrintCatcher output stream for the thread %r(tFalseR(RRR((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyR€s cCs,|dkr|ƒj}n||j|÷s (t__doc__R"R t paste.utilRt FileMixinRRR+R,R.R0R/R'R(R1R8R:R=R?R>(((sB/usr/local/lib/python2.7/dist-packages/paste/util/threadedprint.pyt=s   P    8