Golang 工作池无输出结果

编程并不是一个机械性的工作，而是需要有思考，有创新的工作，语法是固定的，但解决问题的思路则是依靠人的思维，这就需要我们坚持学习和更新自己的知识。今天golang学习网就整理分享《Golang 工作池无输出结果》，文章讲解的知识点主要包括，如果你对Golang方面的知识点感兴趣，就不要错过golang学习网，在这可以对大家的知识积累有所帮助，助力开发能力的提升。

我试图构建一个简单的 tcp 端口扫描器来练习学习 go 中的并发性。我正在关注这个 youtube 视频（https://www.youtube.com/watch?v=lvgvsspwnd8）指南，了解如何使用通道和 goroutines 在 go 中实现“工作池”。我尝试利用视频中的想法，实现了 tcp scanner 功能，如下所示：

func worker(ports <-chan int, results chan<- string) {
    for p := range ports {
        address := fmt.Sprintf("127.0.0.1:%d", p)
        conn, err := net.Dial("tcp", address)
        if err != nil {
            results <- fmt.Sprintf("Port %d is closed: %s", p, err.Error())
        } else {
            conn.Close()
            results <- fmt.Sprintf("Port %d is open", p)
        }
    }
}

func main() {
    ports := make(chan int, 100)
    results := make(chan string, 100)

    for i := 0; i < cap(ports); i++ {
        go worker(ports, results)
    }

    for j := 1; j <= 65535; j++ {
        ports <- j
    }
    close(ports)

    for k := 1; k <= 65535; k++ {
        fmt.Println(<-results)
    }
    close(results)
}

我希望它能以随机顺序慢慢打印结果，就像 youtube 视频中那样。但控制台上没有输出任何内容。我尝试调试通道，并且工作函数正在从 ports 通道接收端口号，但似乎没有任何内容返回到结果通道。

正确答案

这是因为您在应该听取结果的时候却没有。

写入 ports 的 for 循环将在前 100 个请求后阻塞，因为这是该通道的大小，并且所有 goroutine 将阻塞等待写入 results 通道，因为没有 goroutine 从中读取。

您可以通过在单独的 goroutine 中监听来修复它：

done:=make(chan struct{})
  go func() {
      defer close(done)
      for k := 1; k <= 65535; k++ {
        fmt.Println(<-results)
      }
      close(results)
  }()

 for j := 1; j <= 65535; j++ {
        ports <- j
    }
 close(ports)
 <-done  // Wait for the reader to finish

以上就是《Golang 工作池无输出结果》的详细内容，更多关于的资料请关注golang学习网公众号！