[root@master ansible]# ansible node1 -B  -P   -m yum -a "name=ansible" -vv

Using /etc/ansible/ansible.cfg as config file

META: ran handlers

192.168.77.129 | SUCCESS => {

    "ansible_job_id": "23974611070.37468",

    "changed": true,

    "finished": ,

    "results_file": "/root/.ansible_async/23974611070.37468",

    "started":

}

[root@master ansible]# ansible node1 -m async_status -a "jid=23974611070.37468"

192.168.77.129 | SUCCESS => {

    "ansible_job_id": "23974611070.37468",

    "changed": false,

    "finished": ,

    "msg": "",

    "rc": ,

    "results": [

        "ansible-2.3.1.0-1.el6.noarch providing ansible is already installed"

    ]

}

# asynctest.yml

---

- hosts: node1

  tasks:

   - shell: sleep 100 && hostname

     async: 100

     poll: 0

     register: result

   - debug: var=result

   - async_status: jid={{ result.ansible_job_id }}

     register: job_result

     until: job_result.finished

     retries: 30

def run_model(self, module_name, module_args, task_time=None, poll=None):
    """
    run module from andible ad-hoc.
    module_name: ansible module_name
    module_args: ansible module args
    task_time: 这个任务执行时间的上限值。即任务执行所用时间如果超出这个时间，则认为任务失败。这个需要大于0，等于 0 的时候不支持异步（默认值）。
    poll: 任务异步执行时轮询的时间间隔。如果poll为0，就相当于一个不关心结果的任务。
    """
    self.ips_cov_str()

    if task_time and poll:
        play_source = dict(
            name="Ansible Play",
            hosts=self.ips,
            gather_facts='no',
            tasks=[dict(action=dict(module=module_name, args=module_args), async=task_time, poll=poll)]
        )
    else:
        play_source = dict(
            name="Ansible Play",
            hosts=self.ips,
            gather_facts='no',
            tasks=[dict(action=dict(module=module_name, args=module_args))]
        )
    play = Play().load(play_source, variable_manager=self.variable_manager, loader=self.loader)
　　.......