Advertisement

Python 执行一个协程于新线程

阅读量:

1.新线程中处理协程,防止主线程被阻塞.

需特别注意的是,asyncio.call_soon_threadsafe这一机制所调用的对象为常规函数

复制代码
 # coding=utf-8

    
  
    
 import asyncio
    
 import time
    
 import threading
    
  
    
 gLock = threading.Lock()
    
 gStart = time.time()
    
  
    
  
    
 def pinfo(text):
    
     global gLock
    
     gLock.acquire()
    
     print(text)
    
     gLock.release()
    
  
    
  
    
 def startLoop(loop):
    
     asyncio.set_event_loop(loop)
    
     loop.run_forever()
    
  
    
  
    
 def moreWork(name, x):
    
     global gStart
    
     pinfo("moreWork:start name={}  {},  

全部评论 (0)

还没有任何评论哟~