go - 并发 |协程 |语言 |缓冲阅读器

Question

相信我要么误解了 go 例程的工作方式，要么误解了缓冲阅读器的工作方式，要么两者兼而有之。

期待 goroutine 的异步执行(一个带有 for 循环的缓冲读取器读取缓冲区，等待来自服务器的消息)

尝试METHOD A在客户端拨通服务器之前调用go xyz()；所以 xyz() 创建缓冲区并开始在后台读取。然后，客户端拨通服务器；服务器发回消息；客户端正在读取缓冲区，因此它获取消息并打印到控制台

实际发生了什么 客户端向服务器发送消息，但在读取服务器可能的回复时没有从缓冲区中获取任何内容；所以它同时运行，因为我知道 for 循环没有停止，但它让下一行代码执行(客户端向服务器发送消息)。

但是当 METHOD B 我调用xyz() 不是并发并且在客户端调用服务器之后，所有事情都按预期工作。客户端从服务器获取消息并打印到控制台。

---

方法A，我们有顺序:

///////////// 第 1 步和第 2 步在 go xyz() 调用的 goroutine 中>

1. 创建缓冲读取器
2. for 循环 -- 从服务器读取消息缓冲区 -- 打印出来

3. 客户端调用服务器

   去 xyz(conn, p)

   fmt.Fprintf(conn, "给我一个散列来处理...")

---

方法B，我们有顺序:

///////////// 第 2 步和第 3 步在 xyz() 调用的 goroutine 中

1. 客户端调用服务器
2. 创建缓冲阅读器

3. for循环——从服务器读取消息缓冲区——打印出来

   fmt.Fprintf(conn, "给我一个散列来处理...")

   xyz(conn, p)

---

---

---

客户端.go

package main
import (
    "fmt"
    "net"
    "bufio"
)

func xyz(conn net.Conn, p []byte) {
  rd := bufio.NewReader(conn)
  for {
    _, err := rd.Read(p)
    if err == nil {
      fmt.Printf("SERVER : %s\n", p)
    } else {
        fmt.Printf("Some error %v\n", err)
    }
  }
}

func main() {
    p :=  make([]byte, 2048)
    conn, err := net.Dial("udp", "127.0.0.1:1234")
    if err != nil {
        fmt.Printf("Some error %v", err)
        return
    }

    go xyz(conn, p)
    fmt.Fprintf(conn, "Give me a hash to work on ...")
}

---

server.go

package main
import (
    "fmt"
    "net"
)


func sendResponse(conn *net.UDPConn, addr *net.UDPAddr, hash string) {
    _,err := conn.WriteToUDP([]byte("Hello, here is the hash  - " + hash), addr)
    if err != nil {
        fmt.Printf("Couldn't send response %v", err)
    }
}


func main() {
    hash := "36";
    p := make([]byte, 2048)
    addr := net.UDPAddr{
        Port: 1234,
        IP: net.ParseIP("127.0.0.1"),
    }
    ser, err := net.ListenUDP("udp", &addr)
    if err != nil {
        fmt.Printf("Some error %v\n", err)
        return
    }
    for {
        _, remoteaddr, err := ser.ReadFromUDP(p)
        fmt.Printf("CLIENT : %v : %s\n", remoteaddr, p)
        if err !=  nil {
            fmt.Printf("Some error  %v", err)
            continue
        }
        go sendResponse(ser, remoteaddr, hash)
    }
}

Answer 1

The Go Programming Language Specification

Go statements

A "go" statement starts the execution of a function call as an independent concurrent thread of control, or goroutine, within the same address space.

... unlike with a regular call, program execution does not wait for the invoked function to complete.

client.go 启动 goroutine xyz，然后继续运行到终止程序的 main 函数的末尾。该程序不会等待 xyz goroutine 运行或完成。