'Execute all async jobs and wait for them to finish. By default it will run on 10 threads.
:param size: number of threads to run on.'

def async_do(self, size=10):

    if hasattr(self._session, u'_async_jobs'):
        logging.info((u'Executing    async    %s    jobs    found    in    queue    by    using    %s    threads...' % (len(self._session._async_jobs), size)))
        threaded_requests.map(self._session._async_jobs, size=size)
