def run(self):
""""""
while self.active:
try:
task = self.queue.get(timeout=1)
task_type, data = task
代码来源:vnpy/app/data_recorder/engine.py
我想请教下大佬这里关于的多线程的问题
1、在get一个task后,完成一个task后面的代码,才会取出queue中的下一个task
2、无论当前取走的task是否完成,都会在timeout=1后继续取task出来进行处理
想问下我哪个理解是正确的?或者有其他指点请赐教,感谢大佬!