code: def worker_allocator(self, async_loop, to_do, **kwargs):
          
          d = kwargs
          threading.Thread(
              target=self._asyncio_thread, args=(async_loop, to_do, d)
          ).start()
docs: Handler starting the asyncio part.