σ
O'^c           @@  sΓ  d  d l  m Z d  d l Z d  d l Z d  d l Z d  d l Z d  d l m Z m Z m Z m	 Z	 d  d l m
 Z
 d  d l m Z d  d l m Z d d d	 d
 d d d d d d d d d d d g Z d e j f d     YZ y e j Z Wn e k
 re j Z n Xd e f d     YZ e Z e j Z e j   e   _ d   Z d   Z d e f d     YZ e Z e Z e  d  Z! d e f d     YZ" d    Z# d!   Z$ d d d# d"  Z& e Z' d S($   i    (   t   absolute_importN(   t   Lockt   RLockt	   Semaphoret   BoundedSemaphore(   t   Event(   t   Queue(   t   Pipet   Processt   current_processt   active_childrent   freeze_supportR   R   R   R   t	   ConditionR   R   t   ManagerR   t   Poolt   JoinableQueuet   DummyProcessc           B@  s8   e  Z d d d d i  d   Z d   Z e d    Z RS(   c         C@  sP   t  j j |  | | | | |  d  |  _ t j   |  _ t |  _	 t
   |  _ d  S(   N(   t	   threadingt   Threadt   __init__t   Nonet   _pidt   weakreft   WeakKeyDictionaryt	   _childrent   Falset   _start_calledR	   t   _parent(   t   selft   groupt   targett   namet   argst   kwargs(    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   =   s
    		c         C@  sE   |  j  t   k s t  t |  _ d  |  j  j |  <t j j	 |   d  S(   N(
   R   R	   t   AssertionErrort   TrueR   R   R   R   R   t   start(   R   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR$   D   s    	c         C@  s"   |  j  r |  j   r d Sd  Sd  S(   Ni    (   R   t   is_aliveR   (   R   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   exitcodeJ   s    N(    (   t   __name__t
   __module__R   R   R$   t   propertyR&   (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   ;   s   	c           B@  s3   e  Z e j d  d k r% e j Z n e j j Z RS(   i    i   (   R'   R(   t   syst   version_infot
   _Conditiont	   notifyAllt
   notify_allt   __func__(    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   X   s   c          C@  sL   t    j }  x3 t |   D]% } | j   s |  j | d   q q Wt |   S(   N(   R	   R   t   listR%   t   popR   (   t   childrent   p(    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR
   d   s
    c           C@  s   d  S(   N(    (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   l   s    t	   Namespacec           B@  s   e  Z d    Z d   Z RS(   c         K@  s   |  j  j |  d  S(   N(   t   __dict__t   update(   R   t   kwds(    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   r   s    c         C@  sy   t  |  j j    } g  } x= | D]5 \ } } | j d  s" | j d | | f  q" q" W| j   d t j d |  S(   Nt   _s   %s=%rs   Namespace(%s)s   , (   R0   R5   t   itemst
   startswitht   appendt   sortt   strt   join(   R   R9   t   tempR   t   value(    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   __repr__u   s    
(   R'   R(   R   RA   (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR4   p   s   	c         C@  s   t  j  |  |  S(   N(   t   array(   t   typecodet   sequencet   lock(    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   Array   s    t   Valuec           B@  s>   e  Z e d   Z d   Z d   Z e e e  Z d   Z RS(   c         C@  s   | |  _  | |  _ d  S(   N(   t	   _typecodet   _value(   R   RC   R@   RE   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR      s    	c         C@  s   |  j  S(   N(   RI   (   R   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   _get   s    c         C@  s   | |  _  d  S(   N(   RI   (   R   R@   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   _set   s    c         C@  s    d t  |   j |  j |  j f S(   Ns   <%r(%r, %r)>(   t   typeR'   RH   RI   (   R   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyRA      s    (	   R'   R(   R#   R   RJ   RK   R)   R@   RA   (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyRG      s
   		c           C@  s   t  j t S(   N(   R*   t   modulesR'   (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR      s    c           C@  s   d  S(   N(    (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   shutdown   s    c         C@  s    d d l  m } | |  | |  S(   Ni    (   t
   ThreadPool(   t   billiard.poolRO   (   t	   processest   initializert   initargsRO   (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyR   ‘   s    (    ((   t
   __future__R    R   R*   R   RB   R   R   R   R   R   t   billiard.fiveR   t   billiard.connectionR   t   __all__R   R   R,   t   AttributeErrorR   R   t   currentThreadR	   R   R   R
   R   t   objectR4   t   dictR0   R#   RF   RG   R   RN   R   R   R   (    (    (    s9   /tmp/pip-unpacked-wheel-40MfcW/billiard/dummy/__init__.pyt   <module>"   s>   "					