@@ -97,7 +97,12 @@ async def worker():
97
97
loop = """ + self .NEW_LOOP + """
98
98
asyncio.set_event_loop(loop)
99
99
loop.create_task(worker())
100
- loop.run_forever()
100
+ try:
101
+ loop.run_forever()
102
+ finally:
103
+ srv.close()
104
+ loop.run_until_complete(srv.wait_closed())
105
+ loop.close()
101
106
"""
102
107
103
108
proc = await asyncio .create_subprocess_exec (
@@ -141,7 +146,12 @@ def handler_hup(say):
141
146
loop.add_signal_handler(signal.SIGHUP, handler_hup, '!s-hup!')
142
147
asyncio.set_event_loop(loop)
143
148
loop.create_task(worker())
144
- loop.run_forever()
149
+ try:
150
+ loop.run_forever()
151
+ finally:
152
+ srv.close()
153
+ loop.run_until_complete(srv.wait_closed())
154
+ loop.close()
145
155
"""
146
156
147
157
proc = await asyncio .create_subprocess_exec (
@@ -193,7 +203,13 @@ def handler_hup():
193
203
loop.add_signal_handler(signal.SIGUSR2, handler2)
194
204
loop.add_signal_handler(signal.SIGHUP, handler_hup)
195
205
loop.create_task(worker())
196
- loop.run_forever()
206
+ try:
207
+ loop.run_forever()
208
+ finally:
209
+ srv.close()
210
+ loop.run_until_complete(srv.wait_closed())
211
+ loop.close()
212
+
197
213
"""
198
214
199
215
proc = await asyncio .create_subprocess_exec (
@@ -261,7 +277,12 @@ def aio_handler():
261
277
loop.add_signal_handler(signal.SIGUSR1, aio_handler)
262
278
asyncio.set_event_loop(loop)
263
279
loop.create_task(worker())
264
- loop.run_forever()
280
+ try:
281
+ loop.run_forever()
282
+ finally:
283
+ srv.close()
284
+ loop.run_until_complete(srv.wait_closed())
285
+ loop.close()
265
286
print('step3', flush=True)
266
287
print(input(), flush=True)
267
288
"""
0 commit comments