卓越飞翔博客卓越飞翔博客

卓越飞翔 - 您值得收藏的技术分享站
技术文章34856本站已运行393

在 for 循环中调用 defer - 是否有更好的方法来延迟从通道读取响应?

在 for 循环中调用 defer - 是否有更好的方法来延迟从通道读取响应?

在 for 循环中调用 defer - 是否有更好的方法来延迟从通道读取响应?这是许多开发者在使用 Go 语言时常遇到的问题。defer 关键字在 Go 语言中用于延迟执行函数,在 for 循环中使用 defer 可以确保每次循环结束后都会执行某些操作。然而,如果需要在每次循环中从通道读取响应,使用 defer 可能并不是最佳的选择。那么,是否有更好的方法来延迟从通道读取响应呢?让我们一起来探讨一下。

问题内容

我正在尝试调用一个在循环中返回通道的函数。然后将该通道附加到切片 channelslice 上。最后,迭代通道切片并打印每个通道的响应。当我这样做时,我的 ide 显示警告:

possible resource leak, 'defer' is called in the 'for' loop

如您所见,我在第二个 for 循环内调用 close(channelslice[i]) 。这是不推荐的吗?另外,这怎么会导致资源泄漏呢?有没有更好的方法来处理关闭或切片通道?

package main


import (
    "fmt"
    "math/rand"
)

func t() chan int {
    c := make(chan int)
    go func() {
        c <- rand.Intn(100)
    }()

    return c
}

func main() {
    channelSlice := make([]chan int, 0)
    for i := 0; i<100; i++ {
        // Keep making concurrent calls
        // Will read responses from the channel later
        channelSlice = append(channelSlice, t())
    }

    for i := 0; i<100; i++ {
        defer close(channelSlice[i]) // Warning thrown by IDE
        fmt.Println(<-channelSlice[i])
    }
}

解决方法

正如@mkopriva指出的,

延迟调用在周围函数退出时执行,当周围非功能块退出时不会调用它们。将循环体封装在闭包中。

这是我所做的:

for i := 0; i<100; i++ {
        func() {
            defer close(channelSlice[i])
            fmt.Println(<-channelSlice[i])
        }()
    }

如您所见,我将 defer 语句包装在 iife(立即调用函数表达式)中。让它成为一个闭包也很好。

这确保了通道现在将被关闭并且不会出现内存泄漏。

卓越飞翔博客
上一篇: json.Unmarshal 文件数据有效,但 json.NewDecoder().Decode() 无效
下一篇: 返回列表
留言与评论(共有 0 条评论)
   
验证码:
隐藏边栏