def apply_async(self, func, args=(), kwds=dict(), callback=None):
        assert not self._closed # No lock here. We assume it's atomic...
        apply_result = ApplyResult(callback=callback)
        job = Job(func, args, kwds, apply_result)
        self._workq.put(job)
        return apply_result
A variant of the apply() method which returns an
dataset/ETHPy150Open serverdensity/sd-agent/checks/libs/thread_pool.py/Pool.apply_async