hb3SSKrSSKrSSKrSSKrSSKJr /rSrSSKJ r J r J r J r J r JrJr "SS5r"SS \R"5r"S S \5r\"S \"\555\l\R,S :wa"SS\R"5r"SS\R"5r"SS\R"5r"SS\5r"SS\5r"SS\5r\"5\"5\"5S.r\"\S5rO4"SS\R"5r"SS\5rS\"50r\"\S5rSr\R@"5r!S r"S!r#S"r$g)#N)processzIforce_execv is not supported as the billiard C extension is not installed) ProcessErrorBufferTooShort TimeoutErrorAuthenticationErrorTimeLimitExceededSoftTimeLimitExceededWorkerLostErrorc\rSrSr\r\r\r\r\r\ r \ r \ "\ R5r \ "\ R5r\"\S5(aSrOSrSrS$SjrSrSrS%S jrS&S jrS&S jrS rS'SjrS(SjrS(SjrSrS)SjrSrSr Sr!Sr"Sr#Sr$S%Sjr%Sr&Sr'Sr(S%Sjr)S*Sjr*S%S jr+S!r,S"r-S#r.Sr/g )+ BaseContext$ cpu_countcL[R"5nUc [S5eU$)z(Returns the number of CPUs in the systemcannot determine number of cpus)osrNotImplementedError)selfnums 8D:\TimeStamps\venv\Lib\site-packages\billiard/context.pyrBaseContext.cpu_count2s#,,.C{)*KLL cd[RS:Xa[[RS5nOS[R;d[RS:XaUSn[RS:XaSU-n[R"U5n[UR55nSSS5 O[R"S5nWS :aU$[S 5e![ [ 4a SnN'f=f!,(df  N9=f![ a SnNJf=f![ [[4a SnNgf=f) Nwin32NUMBER_OF_PROCESSORSrbsddarwinz/sbin/sysctl -n hw.ncpuz/usrSC_NPROCESSORS_ONLNrr) sysplatformintrenviron ValueErrorKeyErrorpopenreadsysconfOSErrorAttributeErrorr)rrcommps rrr:s||w&bjj)?@AC#,,&#,,(*B0<<8+!D=D$1!!&&(m( **%:;Cax )*KLL)#H-C(!C #G^<CsSC7D C2'D1DC/.C/2 D<DD DDD/.D/cZSSKJn U"UR5S9nUR5 U$)zReturns a manager associated with a running server process The managers methods such as `Lock()`, `Condition()` and `Queue()` can be used to create shared objects. r) SyncManagerctx)managersr- get_contextstart)rr-ms rManagerBaseContext.ManagerTs( * D,,. /  rc SSKJn U"XU5$)z1Returns two connection object connected by a piper)Pipe) connectionr7)rduplex rnonblock wnonblockr7s rr7BaseContext.Pipe_s$Fy11rc6SSKJn U"UR5S9$)z#Returns a non-recursive lock objectr)Lockr.) synchronizer>r1)rr>s rr>BaseContext.Lockds%((*++rc6SSKJn U"UR5S9$)zReturns a recursive lock objectr)RLockr.)r?rBr1)rrBs rrBBaseContext.RLocki&))+,,rNc6SSKJn U"XR5S9$)zReturns a condition objectr) Conditionr.)r?rFr1)rlockrFs rrFBaseContext.Conditionns*#3#3#566rc6SSKJn U"XR5S9$)zReturns a semaphore objectr) Semaphorer.)r?rJr1)rvaluerJs rrJBaseContext.Semaphoress*$4$4$677rc6SSKJn U"XR5S9$)z"Returns a bounded semaphore objectr)BoundedSemaphorer.)r?rNr1)rrKrNs rrNBaseContext.BoundedSemaphorexs1+;+;+=>>rc6SSKJn U"UR5S9$)zReturns an event objectr)Eventr.)r?rQr1)rrQs rrQBaseContext.Event}rDrc8SSKJn U"XX0R5S9$)zReturns a barrier objectr)Barrierr.)r?rTr1)rpartiesactiontimeoutrTs rrTBaseContext.Barriers(w5E5E5GHHrc6SSKJn U"XR5S9$)Returns a queue objectr)Queuer.)queuesr[r1)rmaxsizer[s rr[BaseContext.Queues!W"2"2"455rc6SSKJn U"XR5S9$)rZr) JoinableQueuer.)r\r`r1)rr]r`s rr`BaseContext.JoinableQueues)W*:*:*<==rc6SSKJn U"UR5S9$)rZr) SimpleQueuer.)r\rcr1)rrcs rrcBaseContext.SimpleQueues't//122rcLSSKJn U"XX4XVUXU XU XUUUR5S9$)zReturns a process pool objectr)Pool)context)poolrgr1)r processes initializerinitargsmaxtasksperchildrW soft_timeoutlost_worker_timeout max_restartsmax_restart_freq on_process_upon_process_downon_timeout_seton_timeout_cancelthreads semaphoreputlocks allow_restartrgs rrgBaseContext.Pools< IH+> M#5F- ,,. 0 0rc SSKJn U"U/UQ76$)zReturns a shared objectr)RawValue) sharedctypesr|)rtypecode_or_typeargsr|s rr|BaseContext.RawValues*(0400rcSSKJn U"X5$)zReturns a shared arrayr)RawArray)r}r)rr~size_or_initializerrs rrBaseContext.RawArrays*(>>rchSSKJn URSS5nU"U/UQ7UUR5S.6$)z$Returns a synchronized shared objectr)ValuerGTrGr/)r}rgetr1)rr~rkwargsrrGs rrBaseContext.Values?'zz&$'%--4))+- -rc^SSKJn URSS5nU"XUUR5S9$)z#Returns a synchronized shared arrayr)ArrayrGTr)r}rrr1)rr~rrrrrGs rrBaseContext.Arrays3'zz&$'%))+- -rcv[RS:Xa%[[SS5(aSSKJn U"5 ggg)z{Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. rfrozenFr)freeze_supportN)rr getattrspawnr)rrs rrBaseContext.freeze_supports0 <<7 "wsHe'D'D -  (E "rcSSKJn U"5$)zJReturn package logger -- if it does not already exist then it is created. r) get_logger)utilr)rrs rrBaseContext.get_loggers %|rcSSKJn U"U5$)z8Turn on logging and add a handler which prints to stderrr) log_to_stderr)rr)rlevelrs rrBaseContext.log_to_stderrs'U##rcSSKJn g)zFInstall support for sending connections and sockets between processes r)r8N)r8)rr8s rallow_connection_pickling%BaseContext.allow_connection_picklings !rc SSKJn U"U5 g)zSets the path to a python.exe or pythonw.exe binary used to run child processes instead of sys.executable when using the 'spawn' start method. Useful for people embedding Python. r)set_executableN)rr)r executablers rrBaseContext.set_executables *z"rc SSKJn U"U5 g)z[Set list of module names to try to load in forkserver process. This is really just a hint. r)set_forkserver_preloadN) forkserverr)r module_namesrs rr"BaseContext.set_forkserver_preloads 7|,rc|UcU$[UnUR5 U$![a [SU-5ef=f)Nzcannot find context for %r)_concrete_contextsr$r#_check_available)rmethodr/s rr1BaseContext.get_contextsS >K D$V,C   D9FBC C Ds ";cUR$N)_namer allow_nones rget_start_methodBaseContext.get_start_methods zzrc[S5e)Nz+cannot set start method of concrete context)r#)rrs rset_start_methodBaseContext.set_start_methodsFGGrc:UR5=(d SS:H$)Nfork)rrs rforking_is_enabledBaseContext.forking_is_enableds%%'16f<rBrFrJrNrQrTr[r`rcrgr|rrrrrrrrrr1rrrrr__static_attributes__rerrr r $sL#NL-)1%O"7#:#:;O"7#:#:;Or;  M4 2 , - 7 8 ? - I 6 > 3 ?A?C48EIBF;@ 01 ? --$ !#-H=: rr c(\rSrSrSr\S5rSrg)Processi Nc\[R5RRU5$r)_default_contextr1r_Popen) process_objs rrProcess._Popens"++-55<<[IIrrerrrr _start_methodrrrrerrrr sMJJrrcP^\rSrSr\rSrSU4SjjrS SjrS SjrSr Sr U=r $) DefaultContexticXlSUlgr)r_actual_context)rrhs r__init__DefaultContext.__init__s '#rc>Uc*URcURUlUR$[[U]U5$r)rrsuperrr1)rr __class__s rr1DefaultContext.get_contexts@ >##+'+'<'<$'' ':6B BrcURbU(d [S5eUcU(aSUlgURU5Ulg)Nzcontext has already been set)r RuntimeErrorr1)rrrs rrDefaultContext.set_start_method$sA    +E=> > >e#'D #//7rczURcU(agURUlURR$r)rrrrs rrDefaultContext.get_start_method,s4    '#'#8#8D ##)))rcn[RS:XaS/$SSKJn UR(a/SQ$SS/$)Nrrr reductionrrrr)rr rrHAVE_SEND_HANDLErrs rget_all_start_methods$DefaultContext.get_all_start_methods3s3 <<7 "9  #))66((r)rrrr) rrrrrrr1rrrr __classcell__)rs@rrrs'G$C8*))rrc#:# UHoSS:wdM Uv M g7f)r_Nre).0xs r r=sL)r.ss   b b RJg!!J&)[&)PL^)<LL <<7&g))&&w**&&G//&k{JKJ ') &&8&@A&w**&{ &&8&ABB1  r