Table des matières
Contenu de la question
Solution de contournement
Maison développement back-end Golang Impasse en attendant le tuyau io.Copie dans Goroutine

Impasse en attendant le tuyau io.Copie dans Goroutine

Feb 15, 2024 pm 03:10 PM

在 Goroutine 中等待管道 io.Copy 时发生死锁

L'impasse lors de l'attente du pipeline io.La copie dans Goroutine est un problème courant. Lorsque nous attendons la fin de io.Copy dans un Goroutine, si le tube n'est pas correctement fermé, cela provoquera un blocage. Dans ce cas, Goroutine continuera d'attendre les données et ne pourra pas poursuivre l'exécution. La solution à ce problème consiste à fermer manuellement le tube une fois l'exécution de io.Copy terminée pour garantir que la Goroutine puisse se terminer correctement. L'éditeur PHP Apple a présenté en détail les causes et les solutions à ce problème, dans l'espoir de vous aider à mieux gérer ce type de situation de blocage.

Contenu de la question

Dans le code ci-dessous, la fonction pour io.copy 的调用永远不会返回;它只是无限期地阻塞,导致死锁。仅当使用 io.pipeio.reader 连接到 os.stdout io.writer 时,才会发生此行为。但是,我需要使用管道,因为在我的完整代码中,我使用 io.multiwriterio.pipes 将一个 io.reader 连接到许多需要 io.reader.

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

func main() {

    read := strings.newreader("abcdefghij")

    pipereader, pipewriter := io.pipe()

 

    var wg sync.waitgroup

    wg.add(1)

    go func() {

        println("start copy")

        _, err := io.copy(os.stdout, pipereader)

        if err != nil {

            println(err.error())

        }

        println("end copy")

        wg.done()

    }()

 

    _, err := io.copy(pipewriter, read)

    if err != nil {

        println(err.error())

    }

 

    wg.wait()

}

Copier après la connexion

Sortie :

1

2

3

4

5

6

7

8

9

10

11

12

13

14

15

16

17

18

19

20

21

22

23

24

25

26

27

28

29

30

31

32

33

Start copy

abcdefghij

fatal error: all goroutines are asleep - deadlock!

 

goroutine 1 [semacquire]:

sync.runtime_Semacquire(0xc0000b0018?)

    /usr/local/go-faketime/src/runtime/sema.go:62 +0x25

sync.(*WaitGroup).Wait(0x4969c8?)

    /usr/local/go-faketime/src/sync/waitgroup.go:139 +0x52

main.main()

    /tmp/sandbox4108076976/prog.go:31 +0x23c

 

goroutine 18 [select]:

io.(*pipe).read(0xc0000a6120, {0xc0000b6000, 0x8000, 0xc00009e101?})

    /usr/local/go-faketime/src/io/pipe.go:57 +0xb1

io.(*PipeReader).Read(0x10?, {0xc0000b6000?, 0xc00009e1e0?, 0x4f75a0?})

    /usr/local/go-faketime/src/io/pipe.go:136 +0x25

io.copyBuffer({0x496aa8, 0xc00009e1e0}, {0x4969a8, 0xc0000a4018}, {0x0, 0x0, 0x0})

    /usr/local/go-faketime/src/io/io.go:427 +0x1b2

io.Copy(...)

    /usr/local/go-faketime/src/io/io.go:386

os.genericReadFrom(0xb000000006018ab?, {0x4969a8, 0xc0000a4018})

    /usr/local/go-faketime/src/os/file.go:162 +0x67

os.(*File).ReadFrom(0xc0000a4008, {0x4969a8, 0xc0000a4018})

    /usr/local/go-faketime/src/os/file.go:156 +0x1b0

io.copyBuffer({0x496a28, 0xc0000a4008}, {0x4969a8, 0xc0000a4018}, {0x0, 0x0, 0x0})

    /usr/local/go-faketime/src/io/io.go:413 +0x14b

io.Copy(...)

    /usr/local/go-faketime/src/io/io.go:386

main.main.func1()

    /tmp/sandbox4108076976/prog.go:18 +0x71

created by main.main

    /tmp/sandbox4108076976/prog.go:16 +0x1d3

Copier après la connexion

Voici le lien du terrain de jeu vers le code : https://goplay.tools/snippet/70ubgiz8ftv

Existe-t-il un moyen d'éviter les impasses tout en préservant io.pipe ?

Solution de contournement

Fermez l'extrémité d'écriture du tuyau lorsque vous avez terminé :

1

2

3

4

5

_, err := io.Copy(pipeWriter, read)

pipeWriter.Close()

if err != nil {

    println(err.Error())

}

Copier après la connexion

Sinon, le lecteur attendra indéfiniment.

Ce qui précède est le contenu détaillé de. pour plus d'informations, suivez d'autres articles connexes sur le site Web de PHP en chinois!

Déclaration de ce site Web
Le contenu de cet article est volontairement contribué par les internautes et les droits d'auteur appartiennent à l'auteur original. Ce site n'assume aucune responsabilité légale correspondante. Si vous trouvez un contenu suspecté de plagiat ou de contrefaçon, veuillez contacter admin@php.cn

Article chaud

Musée de deux points: Guide de localisation de Bungle Wasteland
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD
Repo: Comment relancer ses coéquipiers
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌

Article chaud

Musée de deux points: Guide de localisation de Bungle Wasteland
4 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Combien de temps faut-il pour battre Split Fiction?
3 Il y a quelques semaines By DDD
Repo: Comment relancer ses coéquipiers
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌
Hello Kitty Island Adventure: Comment obtenir des graines géantes
3 Il y a quelques semaines By 尊渡假赌尊渡假赌尊渡假赌

Tags d'article chaud

Bloc-notes++7.3.1

Bloc-notes++7.3.1

Éditeur de code facile à utiliser et gratuit

SublimeText3 version chinoise

SublimeText3 version chinoise

Version chinoise, très simple à utiliser

Envoyer Studio 13.0.1

Envoyer Studio 13.0.1

Puissant environnement de développement intégré PHP

Dreamweaver CS6

Dreamweaver CS6

Outils de développement Web visuel

SublimeText3 version Mac

SublimeText3 version Mac

Logiciel d'édition de code au niveau de Dieu (SublimeText3)

GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement? GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement? Mar 03, 2025 pm 05:17 PM

GO Language Pack Import: Quelle est la différence entre le soulignement et sans soulignement?

Comment écrire des objets et des talons simulés pour les tests en Go? Comment écrire des objets et des talons simulés pour les tests en Go? Mar 10, 2025 pm 05:38 PM

Comment écrire des objets et des talons simulés pour les tests en Go?

Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego? Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego? Mar 03, 2025 pm 05:22 PM

Comment mettre en œuvre le transfert d'informations à court terme entre les pages du cadre Beego?

Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go? Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go? Mar 10, 2025 pm 03:20 PM

Comment puis-je définir des contraintes de type personnalisé pour les génériques en Go?

Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO? Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO? Mar 10, 2025 pm 05:36 PM

Comment puis-je utiliser des outils de traçage pour comprendre le flux d'exécution de mes applications GO?

Comment puis-je utiliser des liners et des outils d'analyse statique pour améliorer la qualité et la maintenabilité de mon code GO? Comment puis-je utiliser des liners et des outils d'analyse statique pour améliorer la qualité et la maintenabilité de mon code GO? Mar 10, 2025 pm 05:38 PM

Comment puis-je utiliser des liners et des outils d'analyse statique pour améliorer la qualité et la maintenabilité de mon code GO?

Comment écrire des fichiers dans GO Language de manière pratique? Comment écrire des fichiers dans GO Language de manière pratique? Mar 03, 2025 pm 05:15 PM

Comment écrire des fichiers dans GO Language de manière pratique?

Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go? Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go? Mar 03, 2025 pm 05:18 PM

Comment convertir la liste des résultats de la requête MySQL en une tranche de structure personnalisée dans le langage Go?

See all articles