forked from M-Labs/artiq
1
0
Fork 0

worker: add note about correct use of close()

This commit is contained in:
Sebastien Bourdeauducq 2015-06-04 11:30:34 +08:00
parent d73006652b
commit 78f9268277
1 changed files with 5 additions and 0 deletions

View File

@ -75,6 +75,11 @@ class Worker:
@asyncio.coroutine
def close(self):
"""Interrupts any I/O with the worker process and terminates the
worker process.
This method should always be called by the user to clean up, even if
prepare() raises an exception."""
self.closed.set()
yield from self.io_lock.acquire()
try: