Function clear_async_save_task_queue

python/paddle/framework/io.py:87–94

wait until all async save task to be done.

()

def clear_async_save_task_queue() -> None:
    '''
    wait until all async save task to be done.
    '''
    while len(async_save_queue) > 0:
        task = async_save_queue.pop()
        if task and task.is_alive():
            task.join()


def async_save(