当通道接收到新数据时，无限循环将停止

在多模块架构中，当通道接收新数据时，无限循环将停止打印。这可能是因为在接收新数据之前，无限循环被阻塞在发送数据的通道上。当接收器准备好接收数据时，发送通道解除阻塞，导致无限循环退出。要解决此问题，可以将通道发送操作移到协程中，允许无限循环在接收新数据时继续打印。

我有 2 个模块（模块 1 和模块 2），我在模块 1 中生成一些随机数，并通过 main 中定义的通道将其传递给模块 2。当值到达模块 2 时，我希望它在循环中打印，直到新值再次从模块 1 到达。这是代码。

main.go文件内容

package main

import (
    "time"
    "example/module1"
    "example/module2"
)

func main() {
    ints := make(chan []int, 1)
    for {
        select {
        case <- time.after(5 * time.second):
            go module1.generaterandint(ints)
        case  <- module2.done:
            go module2.start(ints)
        }
    }
}

module1的内容如下。

package module1

import (
    "math/rand"
    "time"
)

func generaterandint(a chan []int){
    var rint []int
    for  i:=0;i<1;i++ {
        rand.seed(time.now().unixnano())
        rint = append(rint,  rand.int())
    }
    a <- rint
}

module2 是：

package module2

import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)

var done = make(chan struct{})
var quit = make(chan struct{})

type localdata struct {
    nums []int
    lock sync.rwmutex
}

var store localdata

func init() {
    go func() {
        done <- struct{}{}
        quit <- struct{}{}
    }()
    go printer(0, quit)
}

func printer(id int, quit chan struct{}) {

    for {
        select {
        case <-quit:
            return
        default:
            store.lock.rlock()
            fmt.println("id:", id, "====", store.nums)
            time.sleep(500 * time.millisecond)
            store.lock.runlock()

        }
    }
}

func start(a chan []int) {
    rand.seed(time.now().unixnano())
    d := <-a
    fmt.println("received data", d)
    store.lock.lock()
    go func() {
        quit <- struct{}{}
    }()
    store.nums = d
    store.lock.unlock()
    go printer(rand.int(), quit)
    done <- struct{}{}

}

在最终输出中，我没有看到 printer 函数连续打印切片。它打印一次。我在下面粘贴了示例输出。

id: 0 ==== []
received data [5183630848712612481]
id: 2057228961822266542 ==== [5183630848712612481]
received data [7203870927705193095]
received data [1478549829208931483]
id: 2311909806311895805 ==== [1478549829208931483]
received data [3000658591728341557]

理想的输出应该是：

ID: 0 ==== []
RECEIVED DATA [5183630848712612481]
ID: 2057228961822266542 ==== [5183630848712612481]
ID: 2057228961822266542 ==== [5183630848712612481]
ID: 2057228961822266542 ==== [5183630848712612481]
ID: 2057228961822266542 ==== [5183630848712612481]
ID: 2057228961822266542 ==== [5183630848712612481]
RECEIVED DATA [7203870927705193095]
ID: 3052382001843759201 ==== [7203870927705193095]
ID: 3052382001843759201 ==== [7203870927705193095]
ID: 3052382001843759201 ==== [7203870927705193095]
ID: 3052382001843759201 ==== [7203870927705193095]
ID: 3052382001843759201 ==== [7203870927705193095]
RECEIVED DATA [1478549829208931483]
ID: 3850200927174591249 ==== [1478549829208931483]
ID: 3850200927174591249 ==== [1478549829208931483]
ID: 3850200927174591249 ==== [1478549829208931483]
ID: 3850200927174591249 ==== [1478549829208931483]
ID: 3850200927174591249 ==== [1478549829208931483]
RECEIVED DATA [3000658591728341557]

解决方案

我假设您询问有关在 init() 函数中调用 go Printer(0, quit) 的问题。它只打印整个列表一次的原因如下：

在 init() 函数中，您尝试将数据发送到 Done 和 quit 通道。现在，他们显然会阻塞，直到接收者准备好为止。加载模块后，接收器尚未准备好，因此您进入打印机方法中的 default 情况。因此，它打印该语句一次并进入睡眠状态 500 毫秒。在此期间，main() 启动并为 Done 通道创建接收器。这会解除对此通道的写入阻止，随后也会写入 quit 通道。现在，由于 quit 也有数据，因此 printer 方法中的 select 语句只是返回，不再打印。

理论要掌握，实操不能落！以上关于《当通道接收到新数据时，无限循环将停止》的详细介绍，大家都掌握了吧！如果想要继续提升自己的能力，那么就来关注golang学习网公众号吧！