ó
P'—^c           @@  sl   d  d l  m Z d  d l m Z m Z d  d l m Z m Z d e f d „  ƒ  YZ d e f d „  ƒ  YZ	 d S(	   i    (   t   absolute_import(   t   Queuest   Pool(   t   AppCaset   Mockt   test_Queuesc           B@  s   e  Z d  „  Z RS(   c         C@  sV   t  ƒ  } t | _ | _ | j _ t | ƒ } | j | ƒ |  j | j	 | j
 ƒ d  S(   N(   R   t   Truet   use_eventloopt   pool_putlockst   pool_clst   uses_semaphoreR   t   createt   assertIst   process_taskt   _process_task_sem(   t   selft   wt   q(    (    sE   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/worker/test_components.pyt   test_create_when_eventloop   s
    	(   t   __name__t
   __module__R   (    (    (    sE   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/worker/test_components.pyR      s   t	   test_Poolc           B@  s   e  Z d  „  Z RS(   c         C@  s€   t  ƒ  } t | ƒ } t  ƒ  } | _ | j | ƒ | j j ƒ  | j | ƒ | j j ƒ  d  | _ | j | ƒ | j | ƒ d  S(   N(   R   R   t   poolt   closet   assert_called_witht	   terminatet   None(   R   R   t   compR   (    (    sE   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/worker/test_components.pyt   test_close_terminate   s    		(   R   R   R   (    (    (    sE   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/worker/test_components.pyR      s   N(
   t
   __future__R    t   celery.worker.componentsR   R   t   celery.tests.caseR   R   R   R   (    (    (    sE   /tmp/pip-unpacked-wheel-gV1wwp/celery/tests/worker/test_components.pyt   <module>   s   
