Commit c80ca71b by lei

1

parent c89f909f
...@@ -396,6 +396,7 @@ class ToWork: ...@@ -396,6 +396,7 @@ class ToWork:
# 初始化任务 # 初始化任务
async def on_start(self): async def on_start(self):
logger.info('on_start')
# 打开窗口 # 打开窗口
page = await self.open_browser(self.browser_item) page = await self.open_browser(self.browser_item)
if not page: if not page:
...@@ -451,6 +452,7 @@ class ToWork: ...@@ -451,6 +452,7 @@ class ToWork:
def process_start(browser_item, lock): def process_start(browser_item, lock):
loop = asyncio.get_event_loop() loop = asyncio.get_event_loop()
keyword = ToWork(browser_item, lock) keyword = ToWork(browser_item, lock)
logger.info('开始执行任务')
# 生产 # 生产
loop.run_until_complete(keyword.on_start()) loop.run_until_complete(keyword.on_start())
...@@ -473,7 +475,6 @@ if __name__ == '__main__': ...@@ -473,7 +475,6 @@ if __name__ == '__main__':
lock = Lock() lock = Lock()
l = [] l = []
for item in browser_list: for item in browser_list:
logger.info('开始执行2')
p = Process(target=process_start, args=(item, lock)) p = Process(target=process_start, args=(item, lock))
p.start() p.start()
l.append(p) # 将进程加入列表中,这样 5 个子进程就会全部执行 l.append(p) # 将进程加入列表中,这样 5 个子进程就会全部执行
......
No preview for this file type
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment