B
|
÷öeì ã @ s$ d Z G dd dZG dd dZdS )u
|
代ç éå管ç
|
c @ sB e Zd ZedddZdd Zdd Zdd Zd
|
d Zd d Z dS )ÚCodeQueueDistributeManager)Ú
|
queue_listc C s> g }x(t dt|D ]}| ||| f¡ qW || _i | _d S )Né )ÚrangeÚlenÚappendr Údistibuted_code_queue_dict)Úselfr ÚflistÚi© r úAD:\workspace\trade\huaxin_client\code_queue_distribute_manager.pyÚ__init__ s
|
z#CodeQueueDistributeManager.__init__c C sN t }x"| jD ]}| | j| d ¡ qW x | jD ]}|d |kr2|S q2W d S )Nr )Úsetr Úaddr )r Zdistibuted_queue_indexesÚcodeÚq_infor r r Úget_available_queue s z.CodeQueueDistributeManager.get_available_queuec C s8 || j kr| j |¡S | ¡ }|s*td|| j |< |S )Nu æ å¯ç¨çéå)r Úgetr Ú Exception)r r r r r r Údistribute_queue s
|
|
z+CodeQueueDistributeManager.distribute_queuec C s | j |¡S )N)r r )r r r r r Úget_distributed_queue$ s z0CodeQueueDistributeManager.get_distributed_queuec C s || j kr| j |¡ d S )N)r Úpop)r r r r r Úrelease_distribute_queue' s
|
z3CodeQueueDistributeManager.release_distribute_queuec C s t | jt | j ¡ S )N)r r r Úkeys)r r r r Úget_free_queue_count, s z/CodeQueueDistributeManager.get_free_queue_countN)
|
Ú__name__Ú
|
__module__Ú __qualname__Úlistr r r r r r r r r r r s
|
|
r c @ sB e Zd ZedddZdd Zdd Zdd Zd
|
d Zd d Z dS )Ú!CodeDataCallbackDistributeManager)Ú callback_listc C s4 g }x |D ]}| t||f¡ q
|
W || _i | _d S )N)r Úidr Ú distibuted_code_callback_dict)r r r Úcallbackr r r r 2 s
|
|
z*CodeDataCallbackDistributeManager.__init__c C sN t }x"| jD ]}| | j| d ¡ qW x | jD ]}|d |kr2|S q2W d S )Nr )r r" r r )r Zdistibuted_callbacks_idsr r# r r r Úget_available_callback: s z8CodeDataCallbackDistributeManager.get_available_callbackc C s8 || j kr| j |¡S | ¡ }|s*td|| j |< |S )Nu æ å¯ç¨çåè°å¯¹è±¡)r" r r$ r )r r Z callback_infor r r Údistribute_callbackD s
|
|
z5CodeDataCallbackDistributeManager.distribute_callbackc C s" || j kr| j |¡d S d S d S )Né )r" r )r r r r r Úget_distributed_callbackN s
|
z:CodeDataCallbackDistributeManager.get_distributed_callbackc C s || j kr| j |¡ d S )N)r" r )r r r r r Úrelease_distribute_callbackT s
|
z=CodeDataCallbackDistributeManager.release_distribute_callbackc C s t | jt | j ¡ S )N)r r r" r )r r r r r Y s z6CodeDataCallbackDistributeManager.get_free_queue_countN)
|
r r r r r r$ r% r' r( r r r r r r 0 s
|
|
r N)Ú__doc__r r r r r r Ú<module> s *
|
