Examples: close the event loop at exit

10 files changed, 23 insertions, 4 deletions

diff --git a/examples/cachesvr.py b/examples/cachesvr.py
index ddb79b6..053f9c2 100644
--- a/examples/cachesvr.py
+++ b/examples/cachesvr.py
@@ -238,7 +238,10 @@ def main():
     svr = loop.run_until_complete(task)
     for sock in svr.sockets:
         logging.info('socket %s', sock.getsockname())
-    loop.run_forever()
+    try:
+        loop.run_forever()
+    finally:
+        loop.close()
 
 
 if __name__ == '__main__':
diff --git a/examples/echo_client_tulip.py b/examples/echo_client_tulip.py
index 9b5d29b..88124ef 100644
--- a/examples/echo_client_tulip.py
+++ b/examples/echo_client_tulip.py
@@ -17,3 +17,4 @@ def echo_client():
 
 loop = asyncio.get_event_loop()
 loop.run_until_complete(echo_client())
+loop.close()
diff --git a/examples/echo_server_tulip.py b/examples/echo_server_tulip.py
index c1ccb9d..8167e54 100644
--- a/examples/echo_server_tulip.py
+++ b/examples/echo_server_tulip.py
@@ -14,4 +14,7 @@ def handle_connection(reader, writer):
 
 loop = asyncio.get_event_loop()
 loop.run_until_complete(echo_server())
-loop.run_forever()
+try:
+    loop.run_forever()
+finally:
+    loop.close()
diff --git a/examples/hello_callback.py b/examples/hello_callback.py
index df889e5..7ccbea1 100644
--- a/examples/hello_callback.py
+++ b/examples/hello_callback.py
@@ -11,4 +11,7 @@ def print_and_repeat(loop):
 if __name__ == '__main__':
     loop = asyncio.get_event_loop()
     print_and_repeat(loop)
-    loop.run_forever()
+    try:
+        loop.run_forever()
+    finally:
+        loop.close()
diff --git a/examples/hello_coroutine.py b/examples/hello_coroutine.py
index 8ad682d..b9347aa 100644
--- a/examples/hello_coroutine.py
+++ b/examples/hello_coroutine.py
@@ -12,4 +12,7 @@ def greet_every_two_seconds():
 
 if __name__ == '__main__':
     loop = asyncio.get_event_loop()
-    loop.run_until_complete(greet_every_two_seconds())
+    try:
+        loop.run_until_complete(greet_every_two_seconds())
+    finally:
+        loop.close()
diff --git a/examples/shell.py b/examples/shell.py
index 8ae30ca..7dc7caf 100644
--- a/examples/shell.py
+++ b/examples/shell.py
@@ -47,3 +47,4 @@ loop = asyncio.get_event_loop()
 loop.run_until_complete(cat(loop))
 loop.run_until_complete(ls(loop))
 loop.run_until_complete(test_call("bash", "-c", "sleep 3", timeout=1.0))
+loop.close()
diff --git a/examples/stacks.py b/examples/stacks.py
index 371d31f..0b7e0b2 100644
--- a/examples/stacks.py
+++ b/examples/stacks.py
@@ -33,6 +33,7 @@ def doit():
     finally:
         for t in Task.all_tasks():
             t.print_stack()
+    l.close()
 
 
 def main():
diff --git a/examples/subprocess_attach_read_pipe.py b/examples/subprocess_attach_read_pipe.py
index a692781..d8a6242 100644
--- a/examples/subprocess_attach_read_pipe.py
+++ b/examples/subprocess_attach_read_pipe.py
@@ -30,3 +30,4 @@ def task():
     print("read = %r" % data.decode())
 
 loop.run_until_complete(task())
+loop.close()
diff --git a/examples/subprocess_attach_write_pipe.py b/examples/subprocess_attach_write_pipe.py
index 017b827..8614877 100644
--- a/examples/subprocess_attach_write_pipe.py
+++ b/examples/subprocess_attach_write_pipe.py
@@ -29,5 +29,7 @@ def task():
 
     stdout, stderr = yield from proc.communicate()
     print("stdout = %r" % stdout.decode())
+    pipe.close()
 
 loop.run_until_complete(task())
+loop.close()
diff --git a/examples/subprocess_shell.py b/examples/subprocess_shell.py
index ca87154..745cb64 100644
--- a/examples/subprocess_shell.py
+++ b/examples/subprocess_shell.py
@@ -80,6 +80,7 @@ def main():
         loop = asyncio.get_event_loop()
     loop.run_until_complete(start(
         'sleep 2; wc', input=[b'foo bar baz\n'*300 for i in range(100)]))
+    loop.close()
 
 
 if __name__ == '__main__':