我有兩個 goroutines：mainworker和 a helper，它為了一些幫助而分拆出來。 helper可能會遇到錯誤，所以我使用通道將錯誤helper從worker.func helper(c chan <- error) (){ //do some work c <- err // send errors/nil on c}這是如何helper()調用的：func worker() error { //do some work c := make(chan error, 1) go helper(c) err := <- c return err}問題：語句是否err := <- c阻塞worker？我不這么認為，因為通道是緩沖的。如果它是阻塞的，我如何使它成為非阻塞的？我的要求是worker讓其調用者繼續進行其余的工作，而無需等待值出現在通道上。謝謝。
3 回答
MMTTMM
TA貢獻1869條經驗 獲得超4個贊
您可以輕松驗證
func helper(c chan<- error) {
time.Sleep(5 * time.Second)
c <- errors.New("") // send errors/nil on c
}
func worker() error {
fmt.Println("do one")
c := make(chan error, 1)
go helper(c)
err := <-c
fmt.Println("do two")
return err
}
func main() {
worker()
}
問：語句 err := <- c 阻塞工作者嗎？我不這么認為，因為通道是緩沖的。
- 答： err := <- c會阻止工人。
問：如果是阻塞的，我如何使它成為非阻塞的？我的要求是讓 worker 及其調用者繼續完成其余的工作，而無需等待值出現在通道上。
A：如果您不想阻止，只需刪除err := <-c. 如果你在最后需要錯誤，只需移動err := <-c到最后。
沒有阻塞就無法讀取通道，如果沒有阻塞就不能再執行此代碼，除非您的代碼處于循環中。
Loop:
for {
select {
case <-c:
break Loop
default:
//default will go through without blocking
}
// do something
}
你見過errgroup或 waitgroup 嗎？
它使用原子、取消上下文和sync.Once 來實現這一點。
https://github.com/golang/sync/blob/master/errgroup/errgroup.go
https://github.com/golang/go/blob/master/src/sync/waitgroup.go
或者你可以直接使用它，運行你的函數，然后在你想要的任何地方等待錯誤。
吃雞游戲
TA貢獻1829條經驗 獲得超7個贊
在您的代碼中，其余工作與幫助程序是否遇到錯誤無關。其余工作完成后，您可以簡單地從頻道接收。
func worker() error {
//do some work
c := make(chan error, 1)
go helper(c)
//do rest of the work
return <-c
}
拉丁的傳說
TA貢獻1789條經驗 獲得超8個贊
我想你需要這個代碼..
運行此代碼
package main
import (
"log"
"sync"
)
func helper(c chan<- error) {
for {
var err error = nil
// do job
if err != nil {
c <- err // send errors/nil on c
break
}
}
}
func worker(c chan error) error {
log.Println("first log")
go func() {
helper(c)
}()
count := 1
Loop:
for {
select {
case err := <- c :
return err
default:
log.Println(count, " log")
count++
isFinished := false
// do your job
if isFinished {
break Loop // remove this when you test
}
}
}
return nil
}
func main() {
wg := sync.WaitGroup{}
wg.Add(1)
go func() {
c := make(chan error, 1)
worker(c)
wg.Done()
}()
wg.Wait()
}
- 3 回答
- 0 關注
- 154 瀏覽
添加回答
舉報
0/150
提交
取消