Did I find the right examples for you? yes no      Crawl my project      Python Jobs

All Samples(1)  |  Call(0)  |  Derive(0)  |  Import(1)

src/i/n/input-lib-HEAD/packages/celery/celery/concurrency/processes/__init__.py   input-lib(Download)
from celery.utils.functional import curry
 
from celery.concurrency.processes.pool import Pool, RUN
 
 
    def stop(self):
        """Gracefully stop the pool."""
        if self._pool is not None and self._pool._state == RUN:
            self._pool.close()
            self._pool.join()