我注意到許多 goroutines 仍在運(yùn)行，即使程序應(yīng)該等待它們?nèi)客瓿?。我的理解是添加一個(gè)等待組可以解決這個(gè)問(wèn)題，但它沒(méi)有。if len(tf5) > 0 { SplitUpAndSendEmbedToDiscord(5, tf5) } if len(tf15) > 0 { SplitUpAndSendEmbedToDiscord(15, tf15) } if len(tf30) > 0 { SplitUpAndSendEmbedToDiscord(30, tf30) } if len(tf60) > 0 { SplitUpAndSendEmbedToDiscord(60, tf60) }}// IntradayStratify - go routine to run during market hoursfunc IntradayStratify(ticker string, c chan request.StratNotification, wg *sync.WaitGroup) { defer wg.Done() candles := request.GetIntraday(ticker) for _, tf := range timeframes { chunkedCandles := request.DetermineTimeframes(tf, ticker, candles) if len(chunkedCandles) > 1 { highLows := request.CalculateIntraDayHighLow(chunkedCandles) // logrus.Infof("%s Highlows calculated: %d", ticker, len(highLows)) // Should have more than 2 candles to start detecting patterns now if len(highLows) > 2 { bl, stratPattern := request.DetermineStratPattern(ticker, tf, highLows) if bl { c <- stratPattern } } } // otherwise return an empty channel c <- request.StratNotification{} }}func main() { RunIntradayScanner()}for我期望程序在循環(huán)遍歷符號(hào)后再次變成單線程。相反，stdout 如下所示，看起來(lái) goroutines 仍在返回。結(jié)果應(yīng)該是每行寫著“ Pattern XX found for timeframe ”也將有一個(gè)相應(yīng)的“ Sending to discord ”輸出行。
1 回答
縹緲止盈
TA貢獻(xiàn)2041條經(jīng)驗(yàn) 獲得超4個(gè)贊
每次啟動(dòng) goroutine 后，原始代碼會(huì)阻塞，等待通過(guò)非緩沖通道發(fā)送一個(gè)值，此外，當(dāng)WaitGroup倒計(jì)時(shí)時(shí)通道關(guān)閉，這也關(guān)閉了接收端的通道。
恕我直言，一般規(guī)則是：
不要從接收方關(guān)閉通道，如果通道有多個(gè)并發(fā)發(fā)送方，也不要關(guān)閉通道。
package main
import (
"fmt"
"strings"
)
type StratNotification struct {
Symbol string
}
func GetSymbols() []StratNotification {
return []StratNotification{
{Symbol: "a"},
{Symbol: "b"},
{Symbol: "c"},
{Symbol: "d"},
}
}
func RunIntradayScanner() {
symbols := GetSymbols()
var intradayChannel = make(chan StratNotification)
for _, s := range symbols {
go IntradayStratify(strings.TrimSpace(s.Symbol), intradayChannel)
}
for _ = range symbols {
s := <-intradayChannel
fmt.Println(s)
}
}
func IntradayStratify(ticker string, c chan StratNotification) {
// do some heavy lifting
fmt.Println(ticker)
c <- StratNotification{}
}
func main() {
RunIntradayScanner()
}
- 1 回答
- 0 關(guān)注
- 109 瀏覽
添加回答
舉報(bào)
0/150
提交
取消