我在我的程序中使用Queue.Queue
,但是如果有一个类似set
的类型会更好。我需要容器是线程安全的,但我不想被订购。在
def init_query_pool(self):
self._pool = Queue.Queue() // todo: replace Queue.Queue with set
self._new_query_pool()
def _create_threads(self):
sessions = session_util.load_sessions()
for s in sessions:
t = threading.Thread(target=self.gen_qs, args=(s,))
t.start()
def gen_qs(self, session):
params = self._init_params(session)
while True:
qs = self._pool.get()
self._search(session, params, qs)
目前没有回答
相关问题 更多 >
编程相关推荐