我無法理解這個(gè)程序for select，所以我需要幫助來解釋這個(gè)程序的順序， done := make(chan interface{}) go func() { time.Sleep(5 * time.Second) close(done) }() workcount := 0loop: for { select { case <-done: break loop default: } workcount++ fmt.Println(workcount) time.Sleep(1 * time.Second) } fmt.Printf("Achieved %v cycles of work before signalled to stop \n", workcount)
1 回答
慕尼黑5688855
TA貢獻(xiàn)1848條經(jīng)驗(yàn) 獲得超2個(gè)贊
// Our communication channel is created
done := make(chan interface{})
// run this function as goroutine
go func() {
// wait/sleep 5 seconds
time.Sleep(5 * time.Second)
// close our communication channel
close(done)
}()
// initialize workcount with 0
workcount := 0
loop:
// loop
for {
// read channel data
select {
// if channel is closed break this loop, break = stop!
case <-done:
break loop
// default do nothing
default:
}
// if our channel doesn't send anything, just add +1 to workcount
workcount++
// print workcount
fmt.Println(workcount)
// wait 1 second before we run this loop again
time.Sleep(1 * time.Second)
}
// so workcount is 5, cuz our goroutine will send term signal after 5 seconds
fmt.Printf("Achieved %v cycles of work before signalled to stop \n", workcount)
解決這個(gè)問題的一個(gè)更干凈的方法是
package main
import (
"fmt"
"time"
)
func main() {
// sends after 5 seconds to this channel https://golang.org/pkg/time/#After
timeout := time.After(5 * time.Second)
// sends each second to this channel https://golang.org/pkg/time/#Tick
tick := time.Tick(1 * time.Second)
// our workcount var
workcount := 0
// for infinite
for {
// waits for data on each channel
select {
// fired if time.After wrote in timeout
case <-timeout:
fmt.Printf("Achieved %v cycles of work before signalled to stop \n", workcount)
return
// fired if time.Tick wrote in tick
case <-tick:
workcount++
fmt.Println(workcount)
}
}
}
您在主函數(shù)中運(yùn)行代碼，因此我們需要返回。我們將使用 return 修復(fù)此代碼
package main
import (
"fmt"
"time"
)
func main() {
// Our communication channel is created
done := make(chan interface{})
// run this function as goroutine
go func() {
// wait/sleep 5 seconds
time.Sleep(5 * time.Second)
// close our communication channel
close(done)
}()
// initialize workcount with 0
workcount := 0
// loop
for {
// read channel data
select {
// if channel is closed break this loop, break = stop!
case <-done:
fmt.Printf("Achieved %v cycles of work before signalled to stop \n", workcount)
return
// default do nothing
default:
}
// if our channel doesn't send anything, just add +1 to workcount
workcount++
// print workcount
fmt.Println(workcount)
// wait 1 second before we run this loop again
time.Sleep(1 * time.Second)
}
}
- 1 回答
- 0 關(guān)注
- 229 瀏覽
添加回答
舉報(bào)
0/150
提交
取消