1

image_split.py

@@ -3,8 +3,8 @@ import os
 from loguru import logger
 from loguru import logger
 from Helper import RedisCon
 from Helper import RedisCon
 from multiprocessing import Process, Lock
 from multiprocessing import Process, Lock
-import asyncio
-import time
+from asyncio import get_event_loop
+from time import sleep
 import uuid
 import uuid
 import cv2
 import cv2
 import json
 import json
@@ -202,7 +202,7 @@ class ImageSplit:
 
 
 
 
 def process_start(lock, task):
 def process_start(lock, task):
-    loop = asyncio.get_event_loop()
+    loop = get_event_loop()
     keyword = ImageSplit(lock, task)
     keyword = ImageSplit(lock, task)
     # 生产
     # 生产
     loop.run_until_complete(keyword.on_start())
     loop.run_until_complete(keyword.on_start())
@@ -236,8 +236,8 @@ if __name__ == '__main__':
 
 
             for p in l:
             for p in l:
                 p.join()  # 当5 个子进程全部执行完，才会执行主进程
                 p.join()  # 当5 个子进程全部执行完，才会执行主进程
-            time.sleep(3)
+            sleep(3)
         except Exception as e:
         except Exception as e:
             logger.error(e)
             logger.error(e)
             logger.info('等待3秒')
             logger.info('等待3秒')
-            time.sleep(3)
+            sleep(3)