|
@@ -100,7 +100,7 @@ class InboundClient:
|
|
|
time.sleep(3)
|
|
|
self.start()
|
|
|
else:
|
|
|
- # threading.Thread(target=self.process_esl_event, args=(e,)).start()
|
|
|
+ registry.FLASK_ACTIVE_THREADS.set(threading.active_count())
|
|
|
self.choose_thread_pool_executor(e).submit(self.process_esl_event, e)
|
|
|
|
|
|
def choose_thread_pool_executor(self, e):
|
|
@@ -116,7 +116,6 @@ class InboundClient:
|
|
|
return self.executors.get(random_index)
|
|
|
|
|
|
def process_esl_event(self, e):
|
|
|
- registry.FLASK_ACTIVE_THREADS.set(threading.active_count())
|
|
|
# self.logger.info(json.loads(e.serialize('json')))
|
|
|
start_time = time.time()
|
|
|
event_name = EslEventUtil.getEventName(e)
|