GoLang并发-主例程始终处于空闲状态

各位小伙伴们，大家好呀！看看今天我又给各位带来了什么文章？本文标题是《GoLang并发-主例程始终处于空闲状态》，很明显是关于Golang的文章哈哈哈，其中内容主要会涉及到等等，如果能帮到你，觉得很不错的话，欢迎各位多多点评和分享！

我是 golang 的新手。尝试学习并发。使用通道分叉后的连接点概念现在让我很困扰。这是我已有的代码

package main

import (
    "fmt"
    "net/http"

    "github.com/vijay-psg587/golang/golang-srv/src/modules/test-dir-dont-use/concurrency/status-checker/models"
)

func printchanneldata(str string, url chan models.urlcheckermodel) {
    
    fmt.println("data in channel is: ", str)
    resp, err := http.get(str)
    if err != nil {

        url <- models.urlcheckermodel{
            statuscode: 500,
            url:        str,
            message:    err.error(),
        }

    } else {
        

        url <- models.urlcheckermodel{
            statuscode: 200,
            url:        str,
            message:    resp.status,
        }
    }

}

func main() {
    fmt.println("main started...")
    

    links := []string{"http://google.com", "http://golang.org", "http://amazon.com"}

    op := make(chan models.urlcheckermodel)
    defer close(op)
    for i := 0; i < len(links); i++ {
        // call to goroutine

        go func(str string) {
            printchanneldata(str, op)
        }(links[i])

        

    }

    for data := range op {

        fmt.println("data receveied:", data)
    }

    fmt.println("main ended...")
}

现在，当我执行此操作时，我的 go 函数不会结束。它获取数据

main started...
data in channel is:  http://amazon.com
data in channel is:  http://google.com
data in channel is:  http://golang.org

data receveied: {200 http://google.com 200 ok}

data receveied: {200 http://golang.org 200 ok}

data receveied: {200 http://amazon.com 200 ok}

三个围棋例程开始并运行，但永远不会结束。根本不回到主例程

现在，如果我进行这样的更改，（在连接点）

// for data := range op {

    //  fmt.println("data receveied:", data)
    // }
    fmt.println("data received:", <-op)
    fmt.println("data received:", <-op)
    fmt.println("data received:", <-op)

而不是 for 循环，然后我获取数据并且主 go 例程也结束。不确定我在哪里犯了错误以及为什么主例程从未被调用

Main started...
Data in channel is:  http://amazon.com
Data in channel is:  http://golang.org
Data in channel is:  http://google.com
data received: {200 http://google.com 200 OK}
data received: {200 http://golang.org 200 OK}
data received: {200 http://amazon.com 200 OK}
Main ended...

正确答案

当在 go 中的通道上使用 for range 时，迭代器将继续阻塞，直到底层通道关闭。

x := make(chan int, 2)
x <- 1
x <- 2
close(x) // without this, the following loop will never stop

for i := range x {
  print(i)
}

在您的情况下，使用 defer 意味着只有在父方法退出后（即循环完成后）才会关闭通道，这会导致死锁。

通常，当使用扇出/扇入模型时，您将使用类似 sync.WaitGroup 的内容来协调关闭通道/继续。

就您而言，这可能类似于以下内容：

links := []string{"http://google.com", "http://golang.org", "http://amazon.com"}

op := make(chan models.urlcheckermodel)
var wg sync.waitgroup

for i := 0; i < len(links); i++ {
    wg.add(1)
    go func(str string) {
        defer wg.done()
        printchanneldata(str, op)
    }(links[i])
}

go func() {
  wg.wait()
  close(op)
}()

for data := range op {
    fmt.println("data receveied:", data)
}

您的频道是无缓冲的，因此，main.go 中的代码将无限运行，等待发生某些事情，因为代码无法继续，因为无缓冲的频道是同步的，任何正在该频道上侦听的人都只能停止当它收到一个值时进行侦听（在这种情况下，因为有时请求到达或永远不会到达需要一些时间，代码将在 main.go 内无限运行）。

您有两个选择：

• 或者您可以将频道的缓冲区定义为列表的大小 url 并使您的代码真正异步和并发。

  op := make(chan models.urlcheckermodel, len(links))

• 或者您将必须创建多个通道，每个通道对应一个 url，因此 当每一个都被处理时，该值被加载并关闭 您在搜索方法中的频道。

  links := []string{"http://google.com", "http://golang.org", "http://amazon.com"}
  
   for i := 0; i < len(links); i++ {
      // call to goroutine
      op := make(chan models.URLCheckerModel)
  
      go func(str string) {
         printChannelData(str, op)
  
         fmt.Println(<-op)
      }(links[i])
  }
  
  
  
  func printChannelData(str string, url chan models.URLCheckerModel) {
     fmt.Println("Data in channel is: ", str)
     resp, err := http.Get(str)
     if err != nil {
         url <- models.URLCheckerModel{
             StatusCode: 500,
             URL:        str,
             Message:    err.Error(),
        }
    } else {
        url <- models.URLCheckerModel{
            StatusCode: 200,
            URL:        str,
            Message:    resp.Status,
       }
   }
  
      close(url)
   }

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《GoLang并发-主例程始终处于空闲状态》文章吧，也可关注golang学习网公众号了解相关技术文章。