我決定建立創(chuàng)建 CSV 報(bào)告的服務(wù)。使用中：Go 1.12、GORM（作為 PostgreSQL ORM）func main() { ... // init DB connection etc defer db.Close() go fetch(db) for {} // keeps open process}func fetch(db *gotm.DB) { .... // some code counts pages, creates file etc sqlLimit := 20000 // set limit for i := 0; i < pages; i++ { db.Table("reports_bookings"),Debug().Where(sql).Offset(i * sqlLimit).Limit(sqlLimit).Find(&myModels) .... // code: push it to file }}因此，當(dāng)代碼嘗試獲取數(shù)據(jù)時(shí)，它就會(huì)凍結(jié)。例如，如果減少限制并設(shè)置 100，則會(huì)運(yùn)行 SQL 2 次并凍結(jié)。Debug()也沒有顯示任何內(nèi)容。正如我所說，它似乎凍結(jié)了。已加載處理器的一個(gè)核心。沒有 goroutine 也可以正常工作。你能幫我弄清楚為什么它在 goroutine 中不起作用嗎？提前致謝。編輯也許我的方法不好，你可以建議如何解決它。最后，文件應(yīng)該上傳到S3（例如）
1 回答
HUX布斯
TA貢獻(xiàn)1876條經(jīng)驗(yàn) 獲得超6個(gè)贊
退出程序之前需要等待所有 goroutine 完成。
func main() {
... // init DB connection etc
wg := sync.WaitGroup{}
defer db.Close()
wg.Add(1) // number of goroutines
go fetch(db, &wg)
wg.Wait() // wait for goroutines before exiting
}
func fetch(db *gotm.DB, wg *sync.WaitGroup) {
.... // some code counts pages, creates file etc
sqlLimit := 20000 // set limit
for i := 0; i < pages; i++ {
db.Table("reports_bookings"),Debug().Where(sql).Offset(i * sqlLimit).Limit(sqlLimit).Find(&myModels)
.... // code: push it to file
for {} // keeps open process
}
}
否則，你的程序?qū)⒃?goroutine 完成之前退出
- 1 回答
- 0 關(guān)注
- 126 瀏覽
添加回答
舉報(bào)
0/150
提交
取消