Erstellen von Slice-Byte-Goroutine hängt

Question

Ich habe ein Upload-Programm, das ich arbeite, und ich bin in ein Problem. Ich habe Routinen, die das Hochladen der Teile in eine große Datei übernehmen. Im Wesentlichen wird die Datei in 100 MB-Chunks aufgeteilt und gleichzeitig hochgeladen, abhängig von der Anzahl gleichzeitiger Prozesse, die Sie in der Konfiguration angeben.

Das Problem, das ich habe, ist, wenn ich einen Puffer erstellen, um die Datei zu lesen und laden Sie die make ([] Byte, 100000000) hängt ... aber nur, wenn es in einer Go-Routine ist. (Ich verwende 100000000, um die Upload-Berechnungen zu vereinfachen)

Hier ist ein Beispiel.

Dies funktioniert: https://play.golang.org/p/tkn8JVir9S

package main 

import (
    "fmt" 
) 

func main() { 
    buffer := make([]byte, 100000000) 
    fmt.Println(len(buffer)) 
} 

Dies gilt nicht: https://play.golang.org/p/H8626OLpqQ

package 

main 

import (
    "fmt" 
) 

func main() { 
    go createBuffer() 
    for { 
    } 

} 

func createBuffer() { 
    buffer := make([]byte, 100000000) 
    fmt.Println(len(buffer)) 
} 

Es hängt nur ... Ich bin nicht sicher, ob es eine Speicherbeschränkung für eine Go-Routine? Ich versuchte zu recherchieren und zu sehen, was ich finden konnte, aber nichts. Irgendwelche Gedanken würden geschätzt werden.

EDIT: Vielen Dank für das Feedback. Ich werde sagen, dass ich das wirkliche Problem nicht sehr gut erklärt habe und versuchen werde, das nächste Mal eine ganzheitliche Sichtweise zu bieten. Am Ende habe ich einen Kanal benutzt, um meine Gorino-Dateien für neue Dateien bereit zu halten. Dies ist für eine DR-Sicherung, die alle 3rd-Party-Dateien hochlädt, für die große Dateien in 100mb-Chunks aufgeteilt werden müssen. Ich denke, ich hätte mich über die Art meines Programms klar sein müssen.

Answer 1

Dieses Programm hängt, weil es in Ihrem Code eine Endlosschleife gibt. Versuchen Sie, den Code einfach so auszuführen, um es selbst zu beweisen. Die Goroutine ist nicht das, was das Aufhängen verursacht.

func main() { 
    for { 
    } 
} 

Wenn Sie nur fmt.Println(..) gedruckt sehen wollen, dann würde ich empfehlen, einen time.Sleep Anruf oder ähnliches haben.

Wenn Sie warten möchten, bis eine Gruppe von Goroutines abgeschlossen ist, dann würde ich this excellent answer genau diese Frage empfehlen.

Answer 2

Package runtime

import "runtime" 

func Gosched

func Gosched() 

Gosched ergibt den Prozessor, so dass andere goroutines auszuführen. Es unterbricht die aktuelle Goroutine nicht, so dass die Ausführung automatisch fortgesetzt wird.

---

Wenn Sie etwas tun seltsame (for {} und 100MB), erhalten Sie seltsame Ergebnisse. Mach etwas Vernünftiges. Zum Beispiel

package main 

import (
    "fmt" 
    "runtime" 
) 

func main() { 
    go createBuffer() 
    for { 
     runtime.Gosched() 
    } 
} 

func createBuffer() { 
    buffer := make([]byte, 100000000) 
    fmt.Println(len(buffer)) 
} 

Ausgang:

100000000 
^Csignal: interrupt