|
|
@@ -47,8 +47,8 @@ class InboundClient:
|
|
|
self.executors = {x: concurrent.futures.ThreadPoolExecutor(max_workers=1) for x in range(self.thread_num)}
|
|
|
self.delay_action_executor = concurrent.futures.ThreadPoolExecutor(max_workers=5)
|
|
|
self.delay_action_scheduler = BackgroundScheduler()
|
|
|
- self.delay_action_scheduler.add_job(self.submit_delay_action, 'interval', seconds=1, max_instances=1)
|
|
|
- self.delay_action_scheduler.start()
|
|
|
+ # self.delay_action_scheduler.add_job(self.submit_delay_action, 'interval', seconds=1, max_instances=1)
|
|
|
+ # self.delay_action_scheduler.start()
|
|
|
threading.Thread(target=self.start, args=()).start()
|
|
|
|
|
|
def submit_delay_action(self):
|
