U
    Íø.e±  ã                   @   s˜   d Z ddlZddlmZ dZdddddd	œZzddlZW n ek
rL   Y n
X d
ed< zej	 
d¡ZW n ek
rz   Y n
X eed< dd„ Zdd„ ZdS )z<Pool implementation abstract factory, and alias definitions.é    N)Úsymbol_by_name)Úget_implementationÚget_available_pool_namesz#celery.concurrency.prefork:TaskPoolz$celery.concurrency.eventlet:TaskPoolz"celery.concurrency.gevent:TaskPoolz celery.concurrency.solo:TaskPool)ZpreforkZeventletZgeventZsoloZ	processesz"celery.concurrency.thread:TaskPoolÚthreadsZCELERY_CUSTOM_WORKER_POOLÚcustomc                 C   s
   t | tƒS )z#Return pool implementation by name.)r   ÚALIASES)Úcls© r	   ú?/tmp/pip-unpacked-wheel-f4liivr4/celery/concurrency/__init__.pyr   )   s    r   c                   C   s   t t ¡ ƒS )z%Return all available pool type names.)Útupler   Úkeysr	   r	   r	   r
   r   .   s    r   )Ú__doc__ÚosZkombu.utils.importsr   Ú__all__r   Úconcurrent.futuresZ
concurrentÚImportErrorÚenvironÚgetr   ÚKeyErrorr   r   r	   r	   r	   r
   Ú<module>   s*   û	