; "Ic@sdZddddddddd d d d d ddddddddddddgZdZddlZddlZddlmZmZmZGdde Z Gd d e Z Gd!d e Z Gd"d#e Z ddlZd$Zd<d%Zd&Zd'Zd(Zdd)Zd*Zd+Zd,Zdd-Zd.d/Zd.d0Zd1Zdd2Zdd3Zddd=d4Z d5Z!d6Z"d7Z#d8Z$ej%d9kod:Z&ed;g7ZndS(>u0.70a1uProcessucurrent_processuactive_childrenufreeze_supportuManageruPipeu cpu_countu log_to_stderru get_loggeruallow_connection_picklinguBufferTooShortu TimeoutErroruLockuRLocku SemaphoreuBoundedSemaphoreu ConditionuEventuQueueu JoinableQueueuPooluValueuArrayuRawValueuRawArrayu"R. Oudkerk (r.m.oudkerk@gmail.com)iN(uProcessucurrent_processuactive_childrencBs|EeZdS(N(u__name__u __module__(u __locals__((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu ProcessErrorEs u ProcessErrorcBs|EeZdS(N(u__name__u __module__(u __locals__((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuBufferTooShortHs cBs|EeZdS(N(u__name__u __module__(u __locals__((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu TimeoutErrorKs cBs|EeZdS(N(u__name__u __module__(u __locals__((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuAuthenticationErrorNs uAuthenticationErrorcCs'ddlm}|}|j|S(u Returns a manager associated with a running server process The managers methods such as `Lock()`, `Condition()` and `Queue()` can be used to create shared objects. i(u SyncManager(umultiprocessing.managersu SyncManagerustart(u SyncManagerum((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuManagerWs  cCsddlm}||S(u; Returns two connection object connected by a pipe i(uPipe(umultiprocessing.connectionuPipe(uduplexuPipe((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuPipecsc Cstjdko>yttjd}Wqttfk od}YqXntjdko@yttjdj}Wqtk od}YqXn:ytj d}Wn#tt t fk od}YnX|dko|St dd S( u2 Returns the number of CPUs in the system uwin32uNUMBER_OF_PROCESSORSiudarwinusysctl -n hw.ncpuuSC_NPROCESSORS_ONLNiucannot determine number of cpusN( usysuplatformuintuosuenvironu ValueErroruKeyErrorupopenureadusysconfuOSErroruAttributeErroruNotImplementedError(unum((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu cpu_countjs"  cCsBtjdko.ttddoddlm}|ndS(u Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. uwin32ufrozeni(ufreeze_supportNF(usysuplatformugetattruFalseumultiprocessing.forkingufreeze_support(ufreeze_support((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyufreeze_supports#cCsddlm}|S(uR Return package logger -- if it does not already exist then it is created i(u get_logger(umultiprocessing.utilu get_logger(u get_logger((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu get_loggerscCsddlm}||S(uB Turn on logging and add a handler which prints to stderr i(u log_to_stderr(umultiprocessing.utilu log_to_stderr(ulevelu log_to_stderr((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu log_to_stderrscCsddlm}dS(uO Install support for sending connections and sockets between processes i(u reductionN(umultiprocessingu reduction(u reduction((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuallow_connection_picklingscCsddlm}|S(u- Returns a non-recursive lock object i(uLock(umultiprocessing.synchronizeuLock(uLock((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuLockscCsddlm}|S(u) Returns a recursive lock object i(uRLock(umultiprocessing.synchronizeuRLock(uRLock((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuRLockscCsddlm}||S(u$ Returns a condition object i(u Condition(umultiprocessing.synchronizeu Condition(ulocku Condition((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu ConditionsicCsddlm}||S(u$ Returns a semaphore object i(u Semaphore(umultiprocessing.synchronizeu Semaphore(uvalueu Semaphore((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu SemaphorescCsddlm}||S(u, Returns a bounded semaphore object i(uBoundedSemaphore(umultiprocessing.synchronizeuBoundedSemaphore(uvalueuBoundedSemaphore((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuBoundedSemaphorescCsddlm}|S(u! Returns an event object i(uEvent(umultiprocessing.synchronizeuEvent(uEvent((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuEventscCsddlm}||S(u Returns a queue object i(uQueue(umultiprocessing.queuesuQueue(umaxsizeuQueue((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuQueuescCsddlm}||S(u Returns a queue object i(u JoinableQueue(umultiprocessing.queuesu JoinableQueue(umaxsizeu JoinableQueue((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu JoinableQueuescCs ddlm}||||S(u' Returns a process pool object i(uPool(umultiprocessing.pooluPool(u processesu initializeruinitargsuPool((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuPoolscGsddlm}|||S(u! Returns a shared object i(uRawValue(umultiprocessing.sharedctypesuRawValue(utypecode_or_typeuargsuRawValue((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuRawValuescCsddlm}|||S(u Returns a shared array i(uRawArray(umultiprocessing.sharedctypesuRawArray(utypecode_or_typeusize_or_initializeruRawArray((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuRawArrayscOs ddlm}||||S(u. Returns a synchronized shared object i(uValue(umultiprocessing.sharedctypesuValue(utypecode_or_typeuargsukwdsuValue((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuValuescKs ddlm}||||S(u- Returns a synchronized shared array i(uArray(umultiprocessing.sharedctypesuArray(utypecode_or_typeusize_or_initializerukwdsuArray((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuArraysuwin32cCsddlm}||dS(u Sets the path to a python.exe or pythonw.exe binary used to run child processes on Windows instead of sys.executable. Useful for people embedding Python. i(uset_executableN(umultiprocessing.forkinguset_executable(u executableuset_executable((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyuset_executablesuset_executableT(('u __version__u__all__u __author__uosusysumultiprocessing.processuProcessucurrent_processuactive_childrenu Exceptionu ProcessErroruBufferTooShortu TimeoutErroruAuthenticationErroru_multiprocessinguManageruTrueuPipeu cpu_countufreeze_supportu get_loggeruNoneu log_to_stderruallow_connection_picklinguLockuRLocku Conditionu SemaphoreuBoundedSemaphoreuEventuQueueu JoinableQueueuPooluRawValueuRawArrayuValueuArrayuplatformuset_executable(((u5/mit/python/lib/python3.0/multiprocessing/__init__.pyu+sL