mirror of
https://github.com/newnius/YAO-scheduler.git
synced 2025-12-13 07:46:43 +00:00
update
This commit is contained in:
@@ -46,6 +46,7 @@ func (optimizer *Optimizer) feed(job string, utils []int) {
|
|||||||
str := strings.Split(job, "-")
|
str := strings.Split(job, "-")
|
||||||
if len(str) == 2 {
|
if len(str) == 2 {
|
||||||
preCnt := 0
|
preCnt := 0
|
||||||
|
jobName := str[0]
|
||||||
|
|
||||||
sum := 0
|
sum := 0
|
||||||
for i := 0; i < len(utils); i++ {
|
for i := 0; i < len(utils); i++ {
|
||||||
@@ -53,12 +54,12 @@ func (optimizer *Optimizer) feed(job string, utils []int) {
|
|||||||
}
|
}
|
||||||
last := 0
|
last := 0
|
||||||
version := 0
|
version := 0
|
||||||
if t, err := optimizer.jobUtilsGPU[job]; !err {
|
if t, err := optimizer.jobUtilsGPU[jobName]; !err {
|
||||||
last = t
|
last = t
|
||||||
version = optimizer.versions[job]
|
version = optimizer.versions[jobName]
|
||||||
}
|
}
|
||||||
optimizer.jobUtilsGPU[job] = (version*last + sum/len(utils)) / (version + 1)
|
optimizer.jobUtilsGPU[jobName] = (version*last + sum/len(utils)) / (version + 1)
|
||||||
optimizer.versions[job]++
|
optimizer.versions[jobName]++
|
||||||
|
|
||||||
for i := 0; i < len(utils); i++ {
|
for i := 0; i < len(utils); i++ {
|
||||||
if utils[i] > 15 {
|
if utils[i] > 15 {
|
||||||
|
|||||||
Reference in New Issue
Block a user