- r - 以节省内存的方式增长 data.frame
- ruby-on-rails - ruby/ruby on rails 内存泄漏检测
- android - 无法解析导入android.support.v7.app
- UNIX 域套接字与共享内存(映射文件)
以下是给我带来问题的代码。我想要实现的是并行创建那么多表。创建所有表后,我想退出函数。
func someFunction(){
....
gos := 5
proc := make(chan bool, gos)
allDone := make(chan bool)
for i:=0; i<gos; i++ {
go func() {
for j:=i; j<len(tables); j+=gos {
r, err := db.Exec(tables[j])
fmt.Println(r)
if err != nil {
methods.CheckErr(err, err.Error())
}
}
proc <- true
}()
}
go func() {
for i:=0; i<gos; i++{
<-proc
}
allDone <- true
}()
for {
select {
case <-allDone:
return
}
}
}
我正在创建两个 channel 1 以跟踪创建的表数 (proc) 和其他 channel (allDone) 以查看是否全部完成。
当我运行这段代码时,创建表的 go 例程开始执行,但在它完成之前 someFunction 被终止。
但是顺序运行代码没有问题
我的设计模式有什么错误,我该如何改正。
最佳答案
您尝试实现的通常模式使用 WaitGroup
.
我认为您面临的问题是 i
被每个 goroutine 捕获,并且它不断被外循环递增。您的内部循环从 i
开始,并且由于外部循环继续,每个 goroutine 从 5 开始。
尝试将迭代器作为参数传递给 goroutine,以便每次都能获得一个新副本。
func someFunction(){
....
gos := 5
var wg sync.WaitGroup
wg.Add(gos)
for i:=0; i< gos; i++ {
go func(n int) {
defer wg.Done()
for j:=n; j<len(tables); j+=gos {
r, err := db.Exec(tables[j])
fmt.Println(r)
if err != nil {
methods.CheckErr(err, err.Error())
}
}
}(i)
}
wg.Wait();
}
我不确定你想在这里实现什么,每个 goroutine 都在它开始的那个上面的所有表上执行 db.Exec
所以第一个处理所有表,第二个处理除第一个以外的所有内容,依此类推。这是你想要的吗?
关于Go例程不执行,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/52802310/
我最近购买了《C 编程语言》并尝试了 Ex 1-8这是代码 #include #include #include /* * */ int main() { int nl,nt,nb;
早上好!我有一个变量“var”,可能为 0。我检查该变量是否为空,如果不是,我将该变量保存在 php session 中,然后调用另一个页面。在这个新页面中,我检查我创建的 session 是否为空,
我正在努力完成 Learn Python the Hard Way ex.25,但我无法理解某些事情。这是脚本: def break_words(stuff): """this functio
我是一名优秀的程序员,十分优秀!