@@ -23,7 +23,7 @@ namespace xpyt
2323 xasync_runner::xasync_runner (py::dict globals)
2424 : xeus::xshell_runner(),
2525 m_global_dict{globals},
26- m_use_busy_loop{true }
26+ m_use_busy_loop{false }
2727 {
2828 std::cout<< " xasync_runner created" << std::endl;
2929 }
@@ -97,7 +97,8 @@ namespace xpyt
9797
9898 def run_main_busy_loop(fd_shell, fd_controller, shell_callback, controller_callback, raw_print):
9999 raw_print("Creating event loop busy loop")
100- loop = asyncio.get_event_loop()
100+ loop = asyncio.new_event_loop()
101+ assign_event_loop = asyncio.set_event_loop(loop)
101102
102103 task_shell = loop.create_task(busy_loop(fd_shell, shell_callback, "shell", raw_print))
103104 task_controller = loop.create_task(busy_loop(fd_controller, controller_callback, "controller", raw_print))
@@ -109,7 +110,8 @@ namespace xpyt
109110 def run_main_non_busy_loop(fd_shell, fd_controller, shell_callback, controller_callback, raw_print):
110111 raw_print("Creating event loop non-busy loop")
111112 # here we create / ensure we have an event loop
112- loop = asyncio.get_event_loop()
113+ loop = asyncio.new_event_loop()
114+ assign_event_loop = asyncio.set_event_loop(loop)
113115 raw_print("Adding readers to event loop")
114116 loop.add_reader(fd_shell, shell_callback)
115117 loop.add_reader(fd_controller, controller_callback)
0 commit comments