我有一個(gè)為請(qǐng)求提供服務(wù)的終結(jié)點(diǎn)。在請(qǐng)求流中，終結(jié)點(diǎn)需要生成并發(fā)送電子郵件通知（讓我們命名代碼）。我希望端點(diǎn)異步調(diào)用 。端點(diǎn)不應(yīng)等待 。sendEmail()sendEmail()sendEmail()代碼是這樣的：func (s *server) MyEndpoint(ctx context.Context, request *MyRequest) (MyResponse, error) { // other logic // async sendEmail() // end async // other logic - should not wait for the response from sendEmail return getMyResponse(), nil}我該怎么做？我意識(shí)到這可能是基本的，但我是Go的新手，并希望確保我遵循最佳實(shí)踐。
1 回答
MYYA
TA貢獻(xiàn)1868條經(jīng)驗(yàn) 獲得超4個(gè)贊
使用 go 例程可以執(zhí)行并發(fā)代碼。在您的示例中，您希望在返回時(shí)獲取響應(yīng)。執(zhí)行此操作的一種方法是使用通道。
您可以通過(guò)將一個(gè)通道傳遞給兩個(gè)函數(shù)來(lái)做到這一點(diǎn)，其中一個(gè)生成數(shù)據(jù)，另一個(gè)函數(shù)使用數(shù)據(jù)。這里有一篇關(guān)于頻道的很棒的文章。它看起來(lái)像這樣（注意我在這里使用了interface{}類型，如果你得到了一個(gè)具體的類型，它是更可取的方式）
func (s *server) MyEndpoint(ctx context.Context, request *MyRequest) (MyResponse, error) {
// other logic
// async
c := make(chan interface{})
go sendEmail(c)
// end async
// other logic - should not wait for the response from sendEmail
// getMyResponse must happen only after sendEmail has done
return getMyResponse(c), nil
}
- 1 回答
- 0 關(guān)注
- 107 瀏覽
添加回答
舉報(bào)
0/150
提交
取消