python threading
python threading的用法：class SearchFactory():
lock = Lock()
def __init__(self, server, timeout=3):
self.instances = {}
self.server = server
self.timeout = timeout
def get(self, context):
from models import has_model
if not has_model(context): return None
if context in self.instances:
return self.instances
self.lock.acquire()
try:
#initialize search connections
con = Solr(self.server + context + "/", timeout=self.timeout)
self.instances = con
return self.instances
finally:
self.lock.release()
确保初始化solr正确
页:
[1]