给你两个 下标从 0 开始 的整数数组 servers
和 tasks
,长度分别为 n
和 m
。servers[i]
是第 i
台服务器的 权重 ,而 tasks[j]
是处理第 j
项任务 所需要的时间(单位:秒)。
你正在运行一个仿真系统,在处理完所有任务后,该系统将会关闭。每台服务器只能同时处理一项任务。第 0
项任务在第 0
秒可以开始处理,相应地,第 j
项任务在第 j
秒可以开始处理。处理第 j
项任务时,你需要为它分配一台 权重最小 的空闲服务器。如果存在多台相同权重的空闲服务器,请选择 下标最小 的服务器。如果一台空闲服务器在第 t
秒分配到第 j
项任务,那么在 t + tasks[j]
时它将恢复空闲状态。
如果没有空闲服务器,则必须等待,直到出现一台空闲服务器,并 尽可能早 地处理剩余任务。 如果有多项任务等待分配,则按照 下标递增 的顺序完成分配。
如果同一时刻存在多台空闲服务器,可以同时将多项任务分别分配给它们。
构建长度为 m
的答案数组 ans
,其中 ans[j]
是第 j
项任务分配的服务器的下标。
返回答案数组 ans
。
示例 1:
输入:servers = [3,3,2], tasks = [1,2,3,2,1,2] 输出:[2,2,0,2,1,2] 解释:事件按时间顺序如下: - 0 秒时,第 0 项任务加入到任务队列,使用第 2 台服务器处理到 1 秒。 - 1 秒时,第 2 台服务器空闲,第 1 项任务加入到任务队列,使用第 2 台服务器处理到 3 秒。 - 2 秒时,第 2 项任务加入到任务队列,使用第 0 台服务器处理到 5 秒。 - 3 秒时,第 2 台服务器空闲,第 3 项任务加入到任务队列,使用第 2 台服务器处理到 5 秒。 - 4 秒时,第 4 项任务加入到任务队列,使用第 1 台服务器处理到 5 秒。 - 5 秒时,所有服务器都空闲,第 5 项任务加入到任务队列,使用第 2 台服务器处理到 7 秒。
示例 2:
输入:servers = [5,1,4,3,2], tasks = [2,1,2,4,5,2,1] 输出:[1,4,1,4,1,3,2] 解释:事件按时间顺序如下: - 0 秒时,第 0 项任务加入到任务队列,使用第 1 台服务器处理到 2 秒。 - 1 秒时,第 1 项任务加入到任务队列,使用第 4 台服务器处理到 2 秒。 - 2 秒时,第 1 台和第 4 台服务器空闲,第 2 项任务加入到任务队列,使用第 1 台服务器处理到 4 秒。 - 3 秒时,第 3 项任务加入到任务队列,使用第 4 台服务器处理到 7 秒。 - 4 秒时,第 1 台服务器空闲,第 4 项任务加入到任务队列,使用第 1 台服务器处理到 9 秒。 - 5 秒时,第 5 项任务加入到任务队列,使用第 3 台服务器处理到 7 秒。 - 6 秒时,第 6 项任务加入到任务队列,使用第 2 台服务器处理到 7 秒。
提示:
servers.length == n
tasks.length == m
1 <= n, m <= 2 * 105
1 <= servers[i], tasks[j] <= 2 * 105
方法一:优先队列(小根堆)
定义两个优先级队列,分别表示空闲服务器、使用中的服务器。其中:空闲服务器 idle
依据权重、下标排序;而使用中的服务器 busy
依据结束时间、权重、下标排序。
遍历任务:
- 若有使用中的服务器小于任务开始时间,将其加入到空闲服务器队列
idle
中; - 若当前有空闲服务器,那么在空闲队列
idle
中取出权重最小的服务器,将其加入使用中的队列busy
中; - 若当前没有空闲服务器,那么在使用队列
busy
中找出最早结束时间且权重最小的服务器,重新加入使用中的队列busy
中。
相似题目:2402. 会议室 III
class Solution:
def assignTasks(self, servers: List[int], tasks: List[int]) -> List[int]:
idle, busy = [], []
for i, weight in enumerate(servers):
heappush(idle, (weight, i))
res = []
for start, cost in enumerate(tasks):
while busy and busy[0][0] <= start:
_, s, i = heappop(busy)
heappush(idle, (s, i))
if idle:
s, i = heappop(idle)
heappush(busy, (start + cost, s, i))
else:
t, s, i = heappop(busy)
heappush(busy, (t + cost, s, i))
res.append(i)
return res
class Solution {
public int[] assignTasks(int[] servers, int[] tasks) {
int m = tasks.length, n = servers.length;
PriorityQueue<int[]> idle
= new PriorityQueue<>((a, b) -> a[0] == b[0] ? a[1] - b[1] : a[0] - b[0]);
PriorityQueue<int[]> busy = new PriorityQueue<>((a, b) -> {
if (a[0] == b[0]) {
return a[1] == b[1] ? a[2] - b[2] : a[1] - b[1];
}
return a[0] - b[0];
});
for (int i = 0; i < n; ++i) {
idle.offer(new int[] {servers[i], i});
}
int[] res = new int[m];
int j = 0;
for (int start = 0; start < m; ++start) {
int cost = tasks[start];
while (!busy.isEmpty() && busy.peek()[0] <= start) {
int[] item = busy.poll();
idle.offer(new int[] {item[1], item[2]});
}
if (!idle.isEmpty()) {
int[] item = idle.poll();
res[j++] = item[1];
busy.offer(new int[] {start + cost, item[0], item[1]});
} else {
int[] item = busy.poll();
res[j++] = item[2];
busy.offer(new int[] {item[0] + cost, item[1], item[2]});
}
}
return res;
}
}