huaxin_client/code_queue_distribute_manager.py
@@ -1,6 +1,7 @@ """ 代码队列管理 """ import copy class CodeQueueDistributeManager: @@ -43,6 +44,7 @@ # 获取空闲的位置数量 def get_free_queue_count(self): return len(self.queue_list) - len(self.distibuted_code_queue_dict.keys()) # 回调对象分配 class CodeDataCallbackDistributeManager: @@ -88,3 +90,11 @@ # 获取空闲的位置数量 def get_free_queue_count(self): return len(self.callback_list) - len(self.distibuted_code_callback_dict.keys()) def get_distributed_codes(self): """ 获取已经分配的代码 @return: """ codes = self.distibuted_code_callback_dict.keys() return copy.deepcopy(codes)