@@ -78,14 +78,18 @@ def share_ndarray(array: np.ndarray, buffer: SharedBuffer) -> SharedNDArray:
7878
7979class MemoryPool :
8080 def __init__ (
81- self , smm : SharedMemoryManager , size : int , count : int , alignment_size : int = 8
81+ self ,
82+ smm : SharedMemoryManager ,
83+ block_size : int ,
84+ block_count : int ,
85+ alignment_size : int = 8 ,
8286 ):
83- self .actual_block_size = size
87+ self .actual_block_size = block_size
8488 self .block_size = max (self .actual_block_size , alignment_size )
85- self .block_count = count
89+ self .block_count = block_count
8690 self ._shared_memory = smm .SharedMemory (self .block_size * self .block_count )
87- self ._queue = queue .Queue (count )
88- for i in range (count ):
91+ self ._queue = queue .Queue (block_count )
92+ for i in range (block_count ):
8993 self ._queue .put (i )
9094
9195 def pop (self ) -> SharedBuffer :
@@ -160,7 +164,9 @@ def post_process(
160164 self ._buf_sizes = tuple (map (lambda item : item .nbytes , response ))
161165 for item in response :
162166 self ._memory_pools [item .nbytes ] = MemoryPool (
163- smm = self ._smm , size = item .nbytes , count = self ._memory_pool_block_count
167+ smm = self ._smm ,
168+ block_size = item .nbytes ,
169+ block_count = self ._memory_pool_block_count ,
164170 )
165171 return self .loader .post_process (response )
166172 new_resp = []
0 commit comments