class ThreadUrl(threading.Thread):
def __init__(self, main_queue, source1_queue, source2_queue, source3_queue, source4_queue):
threading.Thread.__init__(self)
self.main_queue = main_queue
self.source1_queue = source1_queue
self.source2_queue = source2_queue
self.source3_queue = source3_queue
self.source4_queue = source4_queue
def run(self):
while True:
# 从任务队列里取出任务
sql_dict = self.main_queue.get()
sql = sql_dict.get('a')
if sql is not None:
self.source1_queue.put(sql)
self.main_queue.task_done()
else:
sql = sql_dict.get('b')
if sql is not None:
self.source2_queue.put(sql)
self.main_queue.task_done()
else:
sql = sql_dict.get('c')
if sql is not None:
self.source3_queue.put(sql)
self.main_queue.task_done()
else:
sql = sql_dict.get('d')
if sql is not None:
self.source4_queue.put(sql)
self.main_queue.task_done()
类似这种形式。
迷茫2017-04-18 09:51:41
임팩트는 크지 않고, 그 작은 성과보다 명확한 구조가 더 중요한 경우가 많습니다. 최적화하려면 타사 도구(Pypy 등)를 사용할 수 있습니다.
黄舟2017-04-18 09:51:41
주로 보기 흉하고 우아하지 않은 코드이기 때문입니다.
다른 항목은 계속으로 대체될 수 있습니다.
성능 측면에서 threading.Thread를 사용하시겠습니까?