Path: csiph.com!fu-berlin.de!uni-berlin.de!not-for-mail
From: "Frank Millman" <frank@chagford.com>
Newsgroups: comp.lang.python
Subject: Re: asyncio - how to stop background task cleanly
Date: Sun, 7 Feb 2016 10:55:58 +0200
Lines: 65
Message-ID: <mailman.65.1454835375.2317.python-list@python.org>
References: <mailman.32.1454746369.2317.python-list@python.org> <87lh6ys052.fsf@elektro.pacujo.net> <mailman.41.1454767329.2317.python-list@python.org> <87fux5svhk.fsf@elektro.pacujo.net> <8737t5shhp.fsf@elektro.pacujo.net> <n96kjr$mvl$1@ger.gmane.org> <mailman.62.1454829054.2317.python-list@python.org> <87r3gpq7mi.fsf@elektro.pacujo.net>
Mime-Version: 1.0
Content-Type: text/plain; format=flowed; charset="iso-8859-1"; reply-type=original
Content-Transfer-Encoding: 7bit
In-Reply-To: <87r3gpq7mi.fsf@elektro.pacujo.net>
Importance: Normal
Precedence: list
Xref: csiph.com comp.lang.python:102619

"Marko Rauhamaa"  wrote in message news:87r3gpq7mi.fsf@elektro.pacujo.net...
>
> I can't see your complete program, but here's mine, and it seems to be 
> working
>

Thanks, Marko, I really appreciate your assistance.

I wanted to show you my complete program, but as it is quite long I 
distilled it down to its essence, and lo and behold it works!

So now I just have to go through my program and find where it differs - I 
must have a bug somewhere.

For the record, here is my stripped down version.

The main difference from yours is that I want to run a genuine 'loop 
forever', and only shut it down on receipt of some external signal.

I have never been able to get Ctrl+C to work properly on Windows, so I use a 
separate thread that simply waits for Enter.

You will see that if you press Enter after 'done' appears, the program 
closes instantly, but if you press it in between 'start' and 'done', it 
waits for the task to complete before it closes.

Frank

=============================================================

import asyncio, time
import threading

def main():
    loop = asyncio.get_event_loop()
    task = asyncio.async(background_task())
    threading.Thread(target=stop, args=(loop, task)).start()
    loop.run_forever()

@asyncio.coroutine
def background_task():
    try:
        while True:
            print('start')
            time.sleep(2)
            print('done')
            yield from asyncio.sleep(5)
    except asyncio.CancelledError:
        print('cleanup')
    print('DONE')

@asyncio.coroutine
def shutdown(loop, task):
    task.cancel()
    yield from asyncio.wait([task], loop=loop)
    loop.stop()

def stop(loop, task):
    input('Press <enter> to stop\n')
    asyncio.run_coroutine_threadsafe(shutdown(loop, task), loop)

if __name__ == '__main__':
    main()