我決定建立創建 CSV 報告的服務。使用中：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 }}因此，當代碼嘗試獲取數據時，它就會凍結。例如，如果減少限制并設置 100，則會運行 SQL 2 次并凍結。Debug()也沒有顯示任何內容。正如我所說，它似乎凍結了。已加載處理器的一個核心。沒有 goroutine 也可以正常工作。你能幫我弄清楚為什么它在 goroutine 中不起作用嗎？提前致謝。編輯也許我的方法不好，你可以建議如何解決它。最后，文件應該上傳到S3（例如）
1 回答
HUX布斯
TA貢獻1876條經驗 獲得超6個贊
退出程序之前需要等待所有 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
}
}
否則，你的程序將在 goroutine 完成之前退出
- 1 回答
- 0 關注
- 112 瀏覽
添加回答
舉報
0/150
提交
取消