当前位置：首页 > 文章列表 > Golang > Go问答 > 根据停止条件，GO 例程永远不会退出 - 无法找到原因

根据停止条件，GO 例程永远不会退出 - 无法找到原因

来源：stackoverflow 2024-05-01 22:48:37 0浏览收藏

小伙伴们对Golang编程感兴趣吗？是否正在学习相关知识点？如果是，那么本文《根据停止条件，GO 例程永远不会退出 - 无法找到原因》，就很适合你，本篇文章讲解的知识点主要包括。在之后的文章中也会多多分享相关知识点，希望对大家的知识积累有所帮助！

问题内容

在这个例子中，我们有一个工人。这里的想法是根据条件模拟所有 go 例程的 clean shutdown 。

在这种情况下，go 例程会根据工人数量进行旋转。每个 go 例程都会读取通道，执行一些工作并将输出发送到 outputchannel。

主 go 例程读取此输出并打印它。为了模拟停止条件，关闭 donechannel。预期的结果是每个 go 例程中的 select 都会选择它并执行 return ，而 return 又会调用 defer println 。实际的输出是它永远不会被调用并且 main 退出。

不知道这背后的原因是什么。

package main

import (
    "log"
    "time"
)

const jobs = 100
const workers = 1

var timeout = time.After(5 * time.Second)

func main() {

    doneChannel := make(chan interface{})
    outputChannel := make(chan int)

    numberStream := generator()

    for i := 1; i <= workers; i++ {
        go worker(doneChannel, numberStream, outputChannel)
    }

    // listen for output
loop:
    for {
        select {
        case i := <-outputChannel:
            log.Println(i)
        case <-timeout:
            // before you timeout cleanup go routines
            break loop
        }
    }

    close(doneChannel)
    time.Sleep(5 * time.Second)
    log.Println("main exited")

}

func generator() <-chan int {
    defer log.Println("generator completed !")
    c := make(chan int)
    go func() {
        for i := 1; i <= jobs; i++ {
            c <- i
        }

        defer close(c)
    }()
    return c
}

func worker(done <-chan interface{}, c <-chan int, output chan<- int) {
    // this will be a go routine
    // Do some work and send results to output Channel.
    // Incase if the done channel is called kill the go routine.

    defer log.Println("go routines exited")

    for {
        select {
        case <-done:
            log.Println("here")
            return
        case i := <-c:
            time.Sleep(1 * time.Second) // worker delay
            output <- i * 100

        }
    }

}