我有一个调度程序工作人员,我从列表的长度开始循环查找作业数,但是循环时有一些未调用的索引
var members = []Member{
{ID: 1, Is: true},
{ID: 2, Is: false},
{ID: 3, Is: true},
}
numOfWorker := 2
var durationDelay time.Duration = 5000
do, _ := worker.NewDispatcher(numOfWorker)
ch := make(chan worker.MainJob, len(members))
go func(jobs int) {
for i := 0; i < jobs; i++ {
newJob := &worker.NewJob{
Final: ch,
Do: func() worker.MainJob {
return worker.MainJob{ID: i , Message: "test"}
},
}
do.Dispatch(newJob, durationDelay)
}
do.Await()
close(ch)
}(len(members))
for v := range ch {
fmt.Println(v)
}
当我打印ch
我懂了:{1 test}
{3 test}
{3 test}
所以索引0和2不被调用,索引3是从哪里来的?成员的长度是3,所以叫做0 1 2
我在这里犯错吗?将newJob中的
Do
发送worker.MainJob的结果到Final
像这样Final <- Do()
最后是chan worker.MainJob
,而Do
是一个返回worker.MainJob
的函数
最佳答案
您需要隐藏循环变量。
https://github.com/golang/go/wiki/CommonMistakes#using-reference-to-loop-iterator-variable
for i := 0; i < jobs; i++ {
i := i
newJob := &worker.NewJob{
Final: ch,
Do: func() worker.MainJob {
return worker.MainJob{ID: i , Message: "test"}
},
}
do.Dispatch(newJob, durationDelay)
}
关于go - 从列表的大小循环,但在goroutine中未调用某些索引,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/64083596/