我對(duì) Golang 有點(diǎn)陌生，正在嘗試開發(fā)一個(gè)將圖像異步上傳到 imgur 的程序。但是我的代碼遇到了一些困難。所以這是我的任務(wù)；func uploadT(url string,c chan string, d chan string) { var subtask string subtask=upload(url) var status string var url string if subtask!=""{ status = "Success!" url =subtask } else { status = "Failed!" url =subtask } c<-url d<-status}這是我用于異步上傳的 POST 請(qǐng)求循環(huán)；c:=make(chan string, len(js.Urls))d:=make(chan string, len(js.Urls))wg:=sync.WaitGroup{}for i := range js.Urls{ wg.Add(1) go uploadTask(js.Urls[i],c,d) //Below commented out code is slowing down the routine therefore, I commented out. //Needs to be working as well, however, it can work if I put this on task as well. I think I'm kinda confused with this one as well //pol=append(pol,retro{Url:<-c,Status:<-d})}<-c<-dwg.Done()FinishedTime := time.Now().UTC().Format(time.RFC3339)qwe=append(qwe,outputURLs{ jobID:jobID, retro:pol, CreateTime: CreateTime, FinishedTime: FinishedTime, })fmt.Println(jobID)所以我覺得我的渠道和套路不行。它確實(shí)在上傳任務(wù)之前打印出 jobID。而且上傳對(duì)于異步上傳來(lái)說(shuō)似乎太慢了。我知道代碼有點(diǎn)亂，對(duì)此感到抱歉。非常感謝任何幫助！提前致謝！
2 回答
Cats萌萌
TA貢獻(xiàn)1805條經(jīng)驗(yàn) 獲得超9個(gè)贊
你實(shí)際上沒有WaitGroup正確使用。每次你調(diào)用wg.Done()它實(shí)際上是從前一個(gè)中減去 1wg.Add以確定給定的任務(wù)已完成。最后，您需要wg.Wait()同步等待所有任務(wù)。WaitGroups通常用于并行運(yùn)行多個(gè)任務(wù)的扇出使用。
根據(jù)您的代碼示例，最簡(jiǎn)單的方法是將 傳入wg您的任務(wù)，然后在任務(wù)內(nèi)部uploadT調(diào)用。wg.Done()請(qǐng)注意，您還需要使用指針而不是結(jié)構(gòu)值。
下一個(gè)實(shí)現(xiàn)細(xì)節(jié)是在循環(huán)外調(diào)用wg.Wait()，因?yàn)槟阆胱枞钡剿腥蝿?wù)都完成，因?yàn)槟愕乃腥蝿?wù)都在運(yùn)行，go這使得它異步。如果你不這樣做wg.Wait()，它會(huì)像你說(shuō)的那樣立即記錄jobID。讓我知道是否清楚。
作為樣板，它應(yīng)該看起來(lái)像這樣
func task(wg *sync.WaitGroup) {
wg.Done()
}
wg := &sync.WaitGroup{}
for i := 0; i < 10; i++ {
wg.Add(1)
go task(wg)
}
wg.Wait()
// do something after the task is done
fmt.Println("done")
我要注意的另一件事是，在您當(dāng)前的代碼示例中，您正在使用通道，但您沒有對(duì)推送到通道中的值做任何事情，因此您可以從技術(shù)上刪除它們。
翻閱古今
TA貢獻(xiàn)1780條經(jīng)驗(yàn) 獲得超5個(gè)贊
你的代碼有點(diǎn)混亂。但是，如果我理解正確你正在嘗試做什么，你正在處理一個(gè)請(qǐng)求列表，并希望返回每個(gè)請(qǐng)求的 url 和狀態(tài)以及每個(gè)請(qǐng)求完成的時(shí)間。并且您想并行處理這些。
您根本不需要使用 WaitGroups。當(dāng)您只想運(yùn)行一堆任務(wù)而不關(guān)心結(jié)果，只想知道一切何時(shí)完成時(shí)，WaitGroups 非常有用。但如果你要返回結(jié)果，渠道就足夠了。
這是一個(gè)示例代碼，可以執(zhí)行我認(rèn)為您正在嘗試執(zhí)行的操作
package main
import (
"time"
"fmt"
)
type Result struct {
URL string
Status string
Finished string
}
func task(url string, c chan string, d chan string) {
time.Sleep(time.Second)
c <- url
d <- "Success"
}
func main() {
var results []Result
urls := []string{"url1", "url2", "url3", "url4", "url5"}
c := make(chan string, len(urls))
d := make(chan string, len(urls))
for _, u := range urls {
go task(u, c, d)
}
for i := 0; i < len(urls); i++ {
res := Result{}
res.URL = <-c
res.Status = <-d
res.Finished = time.Now().UTC().Format(time.RFC3339)
results = append(results, res)
}
fmt.Println(results)
}
你可以在操場(chǎng)上試試https://play.golang.org/p/N3oeA7MyZ8L
也就是說(shuō)，這有點(diǎn)脆弱。您正在制作與網(wǎng)址列表大小相同的頻道。這對(duì)于一些 url 來(lái)說(shuō)效果很好，但是如果你有一個(gè)包含一百萬(wàn)個(gè) url 的列表，你將創(chuàng)建一個(gè)相當(dāng)大的頻道。您可能希望將通道緩沖區(qū)大小固定為某個(gè)合理的值，并在發(fā)送請(qǐng)求之前檢查通道是否已準(zhǔn)備好進(jìn)行處理。這樣你就可以避免一次發(fā)出一百萬(wàn)個(gè)請(qǐng)求。
- 2 回答
- 0 關(guān)注
- 130 瀏覽
添加回答
舉報(bào)
0/150
提交
取消