任务调度器
Posted ygjzs
tags:
篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了任务调度器相关的知识,希望对你有一定的参考价值。
export default (task, n) => {
// 表示最终队列执行结果
let q = ''
// 对归类进行存储
let Q = {}
task.forEach(item => {
if (Q[item]) {
Q[item]++
} else {
Q[item] = 1
}
})
// 小技巧这里把1作为循环条件
while (1) {
// 任务清单
let keys = Object.keys(Q)
if (!keys[0]) {
break
}
// 声明一个队列n+1个单元
let tmp = []
for (let i = 0; i <= n; i++) {
let max = 0
// 任务名称
let key
// 位置
let pos
keys.forEach((item, idx) => {
if (Q[item] > max) {
max = Q[item]
key = item
pos = idx
}
})
if (key) {
tmp.push(key)
keys.splice(pos, 1)
Q[key]--
if (Q[key] < 1) {
delete Q[key]
}
} else {
break
}
}
q += tmp.join('').padEnd(n + 1, '-')
}
// 边界处理
q = q.replace(/-+$/g, '')
return q.length
}
以上是关于任务调度器的主要内容,如果未能解决你的问题,请参考以下文章
自定义一个简单的Task调度器任务循环调度器TaskScheduler
任务使用内部 Theadpool 或任务调度器,然后新线程如何在任务管理器中显示 [重复]
Spark源码剖析——SparkContext的初始化_创建任务调度器TaskScheduler