|
@@ -68,13 +68,14 @@ class AcdService:
|
|
|
if v.qsize() <= 0:
|
|
|
self.holdsQueue.pop(k, None)
|
|
|
continue
|
|
|
- all_task.append(self.pool.submit(self.holds_one_queue, k, v))
|
|
|
- wait(all_task, timeout=6, return_when=ALL_COMPLETED)
|
|
|
+ self.holds_one_queue(k, v)
|
|
|
+ # all_task.append(self.pool.submit(self.holds_one_queue, k, v))
|
|
|
+ # wait(all_task, timeout=6, return_when=ALL_COMPLETED)
|
|
|
|
|
|
def add_acd_queue(self, call_info: CallInfo, service_id):
|
|
|
call_info_queue = self.holdsQueue.get(service_id)
|
|
|
if not call_info_queue:
|
|
|
- call_info_queue = Queue(maxsize=10)
|
|
|
+ call_info_queue = Queue()
|
|
|
self.holdsQueue[service_id] = call_info_queue
|
|
|
call_info_queue.put_nowait(call_info.call_id)
|
|
|
|