Skip to content

Commit aa710f3

Browse files
committed
fix
1 parent 9a3d817 commit aa710f3

File tree

1 file changed

+11
-3
lines changed

1 file changed

+11
-3
lines changed

lightllm/server/router/req_queue/base_queue.py

Lines changed: 11 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -35,10 +35,18 @@ def all_contain(self, id_list: List[int]):
3535
return all([_id in self.waiting_req_id_list for _id in id_list])
3636

3737
def arrange(self, id_list: List[int]):
38-
id2index_list = {}
38+
rid2req = {}
39+
remaining_req_list = []
40+
new_waiting_req_list = []
3941
for index, req in enumerate(self.waiting_req_list):
40-
id2index_list[req.request_id] = index
41-
self.waiting_req_list = [self.waiting_req_list[id2index_list[id]] for id in id_list]
42+
rid2req[req.request_id] = index
43+
for id in id_list:
44+
new_waiting_req_list.append(self.waiting_req_list[rid2req[id]])
45+
del rid2req[id]
46+
for _, req in rid2req.items():
47+
remaining_req_list.append(req)
48+
del rid2req
49+
self.waiting_req_list = new_waiting_req_list
4250

4351
def pop_list(self, req_list):
4452
id2index_list = {}

0 commit comments

Comments
 (0)