Все рутины спят при выполнении рутины в любом случае - PullRequest
Новая
       5

Все рутины спят при выполнении рутины в любом случае

0 голосов
/ 05 июня 2018

Я получаю следующую ошибку, и я не понимаю, почему:

Send: Query Herefatal error: all goroutines are asleep - deadlock!

Вы можете видеть, как я вызываю функцию routine, созданную с помощью goroutine.У меня действительно нет больше деталей, чтобы предоставить. 

package main

import (
    "fmt"
    "net"
    "sync"
)

const (
    udphost       = "127.0.0.1"
    udpport       = ":150"
    StopCharacter = "\r\n\r\n"
)

var wg sync.WaitGroup

func routine() {
    defer wg.Done()
    // establish connection address parts
    schemaUri := udphost + udpport
    udpAddr, err := net.ResolveUDPAddr("udp4", schemaUri)

    // make connection
    conn, err := net.DialUDP("udp", nil, udpAddr)
    fmt.Printf("%v", conn)

    // defer close
    defer conn.Close()

    // handle connection errors
    if err != nil {
        fmt.Println("Erorr Establishing UDP Connection")
        return
    }

    // input query
    message := "Query Here"

    // Write query to server
    conn.Write([]byte(message))
    conn.Write([]byte(StopCharacter))
    fmt.Printf("Send: %s", message)

    // Read response from server
    buffr := make([]byte, 1024)
    buffw := make([]byte, 1024)
    n, _, _, _, _ := conn.ReadMsgUDP(buffr, buffw)

    fmt.Printf("Receive: %s", n)

    // parse message
    msg := string(buffr[0:n])
    fmt.Println(msg)
}

func main() {
    wg.Add(1) 
    go routine()
    wg.Wait() 
}

1 Ответ

0 голосов
/ 05 июня 2018

Попробуйте 

func main(){
 var wg &sync.WaitGroup
 wg.Add(1)
 go routine(wg)
 ...
 wg.Wait()
}
func routine(wg *sync.WaitGroup){
 ...
 defer wg.Done()
}
...