← Back
Editing: context.cpython-35.pyc
��Yf�) � @ sW d d l Z d d l Z d d l Z d d l m Z g Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e j � Z Gd d � d e � Z e d d � e e � D� � e _ e j d k r�Gd d � d e j � Z Gd d � d e j � Z Gd d � d e j � Z Gd d � d e � Z Gd d � d e � Z Gd d � d e � Z d! e � d" e � d# e � i Z e e d! � Z nN Gd$ d � d e j � Z Gd% d � d e � Z d" e � i Z e e d" � Z d& d' � Z e j � Z d( d) � Z d* d+ � Z d, d- � Z d S).� N� )�processc @ s e Z d Z d S)� ProcessErrorN)�__name__� __module__� __qualname__� r r �</opt/alt/python35/lib64/python3.5/multiprocessing/context.pyr s r c @ s e Z d Z d S)�BufferTooShortN)r r r r r r r r s r c @ s e Z d Z d S)� TimeoutErrorN)r r r r r r r r s r c @ s e Z d Z d S)�AuthenticationErrorN)r r r r r r r r s r c @ s� e Z d Z e Z e Z e Z e Z e e j � Z e e j � Z d d � Z d d � Z d d d � Z d d � Z d d � Z d d d � Z d d d � Z d d d � Z d d � Z d d d d � Z d d d � Z d d d � Z d d � Z d d f d d d � Z d! d" � Z d# d$ � Z d% d d& d' � Z d% d d( d) � Z d* d+ � Z d, d- � Z d d. d/ � Z d0 d1 � Z d2 d3 � Z! d4 d5 � Z" d d6 d7 � Z# d8 d9 d: � Z$ d8 d; d< � Z% d= d> � Z& d S)?� BaseContextc C s/ t j � } | d k r' t d � � n | Sd S)z(Returns the number of CPUs in the systemNz cannot determine number of cpus)�os� cpu_count�NotImplementedError)�selfZnumr r r r ' s zBaseContext.cpu_countc C s3 d d l m } | d | j � � } | j � | S)z�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. r )� SyncManager�ctx)Zmanagersr � get_context�start)r r �mr r r �Manager/ s zBaseContext.ManagerTc C s d d l m } | | � S)z1Returns two connection object connected by a piper )�Pipe)� connectionr )r Zduplexr r r r r : s zBaseContext.Pipec C s# d d l m } | d | j � � S)z#Returns a non-recursive lock objectr )�Lockr )� synchronizer r )r r r r r r ? s zBaseContext.Lockc C s# d d l m } | d | j � � S)z Returns a recursive lock objectr )�RLockr )r r r )r r r r r r D s zBaseContext.RLockNc C s& d d l m } | | d | j � �S)zReturns a condition objectr )� Conditionr )r r r )r �lockr r r r r I s zBaseContext.Conditionr c C s& d d l m } | | d | j � �S)zReturns a semaphore objectr )� Semaphorer )r r r )r �valuer r r r r N s zBaseContext.Semaphorec C s& d d l m } | | d | j � �S)z"Returns a bounded semaphore objectr )�BoundedSemaphorer )r r! r )r r r! r r r r! S s z BaseContext.BoundedSemaphorec C s# d d l m } | d | j � � S)zReturns an event objectr )�Eventr )r r" r )r r" r r r r" X s zBaseContext.Eventc C s, d d l m } | | | | d | j � �S)zReturns a barrier objectr )�Barrierr )r r# r )r Zparties�actionZtimeoutr# r r r r# ] s zBaseContext.Barrierr c C s& d d l m } | | d | j � �S)zReturns a queue objectr )�Queuer )�queuesr% r )r �maxsizer% r r r r% b s zBaseContext.Queuec C s& d d l m } | | d | j � �S)zReturns a queue objectr )� JoinableQueuer )r& r( r )r r' r( r r r r( g s zBaseContext.JoinableQueuec C s# d d l m } | d | j � � S)zReturns a queue objectr )� SimpleQueuer )r& r) r )r r) r r r r) l s zBaseContext.SimpleQueuec C s/ d d l m } | | | | | d | j � �S)z Returns a process pool objectr )�Pool�context)Zpoolr* r )r Z processesZ initializerZinitargsZmaxtasksperchildr* r r r r* q s zBaseContext.Poolc G s d d l m } | | | � S)zReturns a shared objectr )�RawValue)� sharedctypesr, )r �typecode_or_type�argsr, r r r r, x s zBaseContext.RawValuec C s d d l m } | | | � S)zReturns a shared arrayr )�RawArray)r- r0 )r r. �size_or_initializerr0 r r r r0 } s zBaseContext.RawArrayr c G s/ d d l m } | | | d | d | j � �S)z$Returns a synchronized shared objectr )�Valuer r )r- r2 r )r r. r r/ r2 r r r r2 � s zBaseContext.Valuec C s/ d d l m } | | | d | d | j � �S)z#Returns a synchronized shared arrayr )�Arrayr r )r- r3 r )r r. r1 r r3 r r r r3 � s zBaseContext.Arrayc C s< t j d k r8 t t d d � r8 d d l m } | � d S)z�Check whether this is a fake forked process in a frozen executable. If so then run code specified by commandline and exit. �win32�frozenFr )�freeze_supportN)�sys�platform�getattr�spawnr6 )r r6 r r r r6 � s !zBaseContext.freeze_supportc C s d d l m } | � S)zZReturn package logger -- if it does not already exist then it is created. r )� get_logger)�utilr; )r r; r r r r; � s zBaseContext.get_loggerc C s d d l m } | | � S)z8Turn on logging and add a handler which prints to stderrr )� log_to_stderr)r< r= )r �levelr= r r r r= � s zBaseContext.log_to_stderrc C s d d l m } d S)zVInstall support for sending connections and sockets between processes r )r N)� r )r r r r r �allow_connection_pickling� s z%BaseContext.allow_connection_picklingc C s d d l m } | | � d S)z�Sets 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)r: rA )r � executablerA r r r rA � s zBaseContext.set_executablec C s d d l m } | | � d S)zkSet list of module names to try to load in forkserver process. This is really just a hint. r )�set_forkserver_preloadN)� forkserverrC )r Z module_namesrC r r r rC � s z"BaseContext.set_forkserver_preloadc C sQ | d k r | Sy t | } Wn" t k rB t d | � � Yn X| j � | S)Nzcannot find context for %r)�_concrete_contexts�KeyError� ValueError�_check_available)r �methodr r r r r � s zBaseContext.get_contextFc C s | j S)N)�_name)r � allow_noner r r �get_start_method� s z BaseContext.get_start_methodc C s t d � � d S)Nz+cannot set start method of concrete context)rG )r rI �forcer r r �set_start_method� s z BaseContext.set_start_methodc C s d S)Nr )r r r r rH � s z BaseContext._check_available)'r r r r r r r � staticmethodr Zcurrent_processZactive_childrenr r r r r r r r! r" r# r% r( r) r* r, r0 r2 r3 r6 r; r= r@ rA rC r rL rN rH r r r r r sF r c @ s( e Z d Z d Z e d d � � Z d S)�ProcessNc C s t j � j j | � S)N)�_default_contextr rP �_Popen)� process_objr r r rR � s zProcess._Popen)r r r � _start_methodrO rR r r r r rP � s rP c sa e Z d Z e Z d d � Z d � f d d � Z d d d � Z d d d � Z d d � Z � S) �DefaultContextc C s | | _ d | _ d S)N)rQ �_actual_context)r r+ r r r �__init__� s zDefaultContext.__init__Nc sB | d k r. | j d k r' | j | _ | j St � j | � Sd S)N)rV rQ �superr )r rI )� __class__r r r � s zDefaultContext.get_contextFc C sW | j d k r" | r" t d � � | d k rA | rA d | _ d S| j | � | _ d S)Nz context has already been set)rV � RuntimeErrorr )r rI rM r r r rN � s z DefaultContext.set_start_methodc C s/ | j d k r% | r d S| j | _ | j j S)N)rV rQ rJ )r rK r r r rL � s z DefaultContext.get_start_methodc C sJ t j d k r d g Sd d l m } | j r< d d d g Sd d g Sd S)Nr4 r: r )� reduction�forkrD )r7 r8 r? r[ �HAVE_SEND_HANDLE)r r[ r r r �get_all_start_methods� s z$DefaultContext.get_all_start_methods) r r r rP rW r rN rL r^ r r )rY r rU � s rU c c s% | ] } | d d k r | Vq d S)r �_Nr )�.0�xr r r � <genexpr>� s rb r4 c @ s( e Z d Z d Z e d d � � Z d S)� ForkProcessr\ c C s d d l m } | | � S)Nr )�Popen)Z popen_forkrd )rS rd r r r rR s zForkProcess._PopenN)r r r rT rO rR r r r r rc s rc c @ s( e Z d Z d Z e d d � � Z d S)� SpawnProcessr: c C s d d l m } | | � S)Nr )rd )Zpopen_spawn_posixrd )rS rd r r r rR s zSpawnProcess._PopenN)r r r rT rO rR r r r r re s re c @ s( e Z d Z d Z e d d � � Z d S)�ForkServerProcessrD c C s d d l m } | | � S)Nr )rd )Zpopen_forkserverrd )rS rd r r r rR s zForkServerProcess._PopenN)r r r rT rO rR r r r r rf s rf c @ s e Z d Z d Z e Z d S)� ForkContextr\ N)r r r rJ rc rP r r r r rg s rg c @ s e Z d Z d Z e Z d S)� SpawnContextr: N)r r r rJ re rP r r r r rh s rh c @ s( e Z d Z d Z e Z d d � Z d S)�ForkServerContextrD c C s) d d l m } | j s% t d � � d S)Nr )r[ z%forkserver start method not available)r? r[ r] rG )r r[ r r r rH & s z"ForkServerContext._check_availableN)r r r rJ rf rP rH r r r r ri # s ri r\ r: rD c @ s( e Z d Z d Z e d d � � Z d S)re r: c C s d d l m } | | � S)Nr )rd )Zpopen_spawn_win32rd )rS rd r r r rR 6 s zSpawnProcess._PopenN)r r r rT rO rR r r r r re 4 s c @ s e Z d Z d Z e Z d S)rh r: N)r r r rJ re rP r r r r rh ; s c C s t | t _ d S)N)rE rQ rV )rI r r r �_force_start_methodH s rj c C s t t d d � S)N�spawning_popen)r9 �_tlsr r r r �get_spawning_popenQ s rm c C s | t _ d S)N)rl rk )�popenr r r �set_spawning_popenT s ro c C s, t � d k r( t d t | � j � � d S)NzF%s objects should only be shared between processes through inheritance)rm rZ �typer )�objr r r �assert_spawningW s rr )!r r7 Z threadingr? r �__all__� Exceptionr r r r �objectr Z BaseProcessrP rU �list�dirr8 rc re rf rg rh ri rE rQ rj Zlocalrl rm ro rr r r r r �<module> s@ �("
Save File
Cancel