Browse Source

异步任务多线程无法找到问题

yf_fyh 2 years ago
parent
commit
1082eb1cc4
1 changed files with 6 additions and 6 deletions
  1. 6 6
      utils/utils.py

+ 6 - 6
utils/utils.py

@@ -128,9 +128,9 @@ class DeviceInfoUtils(object):
         return res_dict
 
     async def plat_device_info(self, url, data):
-        # loop = asyncio.get_event_loop()
-        loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(loop)
+        # loop = asyncio.new_event_loop()
+        # asyncio.set_event_loop(loop)
+        loop = asyncio.get_event_loop(loop)
         res = await loop.run_in_executor(None, self.get_resp, url, data)
         return res
 
@@ -143,9 +143,9 @@ class DeviceInfoUtils(object):
         else:
             data = {"device_id": d_id}
 
-        loop = asyncio.new_event_loop()
-        asyncio.set_event_loop(loop)
-        # loop = asyncio.get_event_loop()
+        # loop = asyncio.new_event_loop()
+        # asyncio.set_event_loop(loop)
+        loop = asyncio.get_event_loop(loop)
         db_task = loop.create_task(self.plat_device_info(bd_url, data))
         sq_task = loop.create_task(self.plat_device_info(sq_url, data))
         loop.run_until_complete(db_task)