examples: close the event loop

vstinner · vstinner · commit eaa0eb342628 · 2014-01-28T23:40:51.000+01:00
diff --git a/examples/cacheclt.py b/examples/cacheclt.py
@@ -175,10 +175,13 @@ def main():
     if args.tls:
         sslctx = test_utils.dummy_ssl_context()
     cache = CacheClient(args.host, args.port, sslctx=sslctx, loop=loop)
-    loop.run_until_complete(
-        asyncio.gather(
-            *[testing(i, cache, loop) for i in range(args.ntasks)],
-            loop=loop))
+    try:
+        loop.run_until_complete(
+            asyncio.gather(
+                *[testing(i, cache, loop) for i in range(args.ntasks)],
+                loop=loop))
+    finally:
+        loop.close()
 
 
 @asyncio.coroutine
diff --git a/examples/simple_tcp_server.py b/examples/simple_tcp_server.py
@@ -143,8 +143,11 @@ def recv():
         yield from asyncio.sleep(0.5)
 
     # creates a client and connects to our server
-    msg = loop.run_until_complete(client())
-    server.stop(loop)
+    try:
+        msg = loop.run_until_complete(client())
+        server.stop(loop)
+    finally:
+        loop.close()
 
 
 if __name__ == '__main__':
diff --git a/examples/tcp_echo.py b/examples/tcp_echo.py
@@ -110,4 +110,7 @@ def start_server(loop, host, port):
         else:
             start_client(loop, args.host, args.port)
 
-        loop.run_forever()
+        try:
+            loop.run_forever()
+        finally:
+            loop.close()
diff --git a/examples/timing_tcp_server.py b/examples/timing_tcp_server.py
@@ -157,8 +157,11 @@ def recv():
         yield from asyncio.sleep(0.5)
 
     # creates a client and connects to our server
-    msg = loop.run_until_complete(client())
-    server.stop(loop)
+    try:
+        msg = loop.run_until_complete(client())
+        server.stop(loop)
+    finally:
+        loop.close()
 
 
 if __name__ == '__main__':
diff --git a/examples/udp_echo.py b/examples/udp_echo.py
@@ -95,4 +95,7 @@ def start_client(loop, addr):
         else:
             start_client(loop, (args.host, args.port))
 
-        loop.run_forever()
+        try:
+            loop.run_forever()
+        finally:
+            loop.close()
