快捷導(dǎo)航

go如何終止多個for select循環(huán)嵌套的方法

更新時間：2024年01月12日 11:22:54 作者：ProblemTerminator

當(dāng)您想從嵌套循環(huán)中中斷,從select內(nèi)部終止循環(huán)時,標(biāo)記的中斷非常有用,本文主要介紹了go如何終止多個for select循環(huán)嵌套的方法,具有一定的參考價值,感興趣的可以了解一下

分類說明

for select循環(huán)嵌套，如何終止？上代碼：

    stop := make(chan struct{})
    go func() {
        for i := 1; i < 3; i++ {
            fmt.Println("writed ", i)
            time.Sleep(time.Second * 1)
        }

        close(stop)
        fmt.Println("stop closed.")
    }()

    go func() {
    stop1:
        for {
            select {
            case <-stop:
                fmt.Println("recv 1")
                break stop1
            default:

                fmt.Println("A 1 default...")

                for {
                    select {
                    case <-stop:
                        fmt.Println("recv 2")
                        break stop1
                    default:
                        fmt.Println("A 2 default...")
                        time.Sleep(time.Second * 1)
                    }
                }
            }
        }

        fmt.Println("A 結(jié)束")
    }()

    fmt.Println("已關(guān)閉", stop == nil)
    for i := 1; i < 10; i++ {
        time.Sleep(time.Second * 1)
        fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())
    }

如上，內(nèi)外均監(jiān)聽了stop，內(nèi)層接受到信號后直接終止stop1，全流程正常結(jié)束。效果如下：
speed running:

已關(guān)閉 false
A 1 default...
A 2 default...
writed 1
A 2 default...
writed 2
ch==nil: false num= 3
ch==nil: false num= 3
A 2 default...
stop closed.
recv 2
A 結(jié)束
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1

換成先終止內(nèi)層也可：

    stop := make(chan struct{})
    go func() {
        for i := 1; i < 3; i++ {

            fmt.Println("writed ", i)
            time.Sleep(time.Second * 1)
        }

        close(stop)
        fmt.Println("stop closed.")
    }()

    go func() {
    stop1:
        for {
            select {
            case <-stop: // 這里也可收到信號
                fmt.Println("recv 1")
                break stop1
            default:

                fmt.Println("A 1 default...")
            stop2:
                for {
                    select {
                    case <-stop: // 這里可收到信號
                        fmt.Println("recv 2")
                        break stop2 // 換成終止內(nèi)層
                    default:
                        fmt.Println("A 2 default...")
                        time.Sleep(time.Second * 1)
                    }
                }

                fmt.Println("A 2 stop...")
            }
        }

        fmt.Println("A 結(jié)束")
    }()

    fmt.Println("已關(guān)閉", stop == nil)
    for i := 1; i < 10; i++ {
        time.Sleep(time.Second * 1)
        fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())
    }

如上代碼，在內(nèi)層先終止自己的邏輯stop2，外層也隨之終止，正常結(jié)束。效果如下：

speed running:

已關(guān)閉 false
writed 1
A 1 default...
A 2 default...
writed 2
ch==nil: false num= 3
A 2 default...
A 2 default...
ch==nil: false num= 3
stop closed.
recv 2
A 2 stop...
recv 1
A 結(jié)束
ch==nil: false num= 2
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1
ch==nil: false num= 1

如果不是基于關(guān)閉操作而是寫入呢，內(nèi)層和外層都能收到嗎？答：只會接收一次。

stop := make(chan struct{})
    go func() {
        for i := 1; i < 3; i++ {
            //ch <- i
            fmt.Println("writed ", i)
            time.Sleep(time.Second * 1)
        }

        stop <- struct{}{}// close(stop)
        fmt.Println("stop writed.")
    }()

    go func() {
    stop1:
        for {
            select {
            case <-stop: // 這里未收到信號
                fmt.Println("recv 1")
                break stop1
            //case data := <-ch:
            //    fmt.Println("A  data=", data)
            default:

                fmt.Println("A 1 default...")
            stop2:
                for {
                    select {
                    case <-stop: // 這里可收到信號
                        fmt.Println("recv 2")
                        break stop2 // 換成終止內(nèi)層
                    default:
                        fmt.Println("A 2 default...")
                        time.Sleep(time.Second * 1)
                    }
                }

                fmt.Println("A 2 stop...")
            }
        }

        fmt.Println("A 結(jié)束")
    }()

    fmt.Println("stop == nil: ", stop == nil)
    for i := 1; i < 10; i++ {
        time.Sleep(time.Second * 1)
        fmt.Println("ch==nil: ", stop == nil, "   num=", runtime.NumGoroutine())
    }

    close(stop)
    fmt.Println("stop已關(guān)閉, ", stop == nil)

speed running:

stop == nil: false
writed 1
A 1 default...
A 2 default...
A 2 default...
writed 2
ch==nil: false num= 3
recv 2
A 2 stop...
A 1 default...
A 2 default...
stop writed.
ch==nil: false num= 3
ch==nil: false num= 2
A 2 default...
A 2 default...
ch==nil: false num= 2
ch==nil: false num= 2
A 2 default...
A 2 default...
ch==nil: false num= 2
A 2 default...
ch==nil: false num= 2
ch==nil: false num= 2
A 2 default...
A 2 default...
ch==nil: false num= 2
stop已關(guān)閉, false