美文网首页
golang channel 关闭方式

golang channel 关闭方式

作者: 夜空一起砍猩猩 | 来源:发表于2018-08-28 16:44 被阅读0次

golang channel 关闭方式

package main

    import (

    "fmt"

    "strconv"

)

func publishTask(c chan string, count int) {

    for i := 1; i <= count; i++ {

        taskName := "task: " + strconv.Itoa(i)

        c <- taskName //publish a new task

    }

    close(c)

}

func receiveTask(c chan string) {

    closed := false

    for {

        if closed {

            return

        }

        fmt.Println("Waiting for a new task ...")

        select {

        case v, ok := <-c:

            if !ok {

                fmt.Println("c closed!")

                closed = true

            } else {

                fmt.Println("got job :", v)

            }

        }

       }

}

func main() {

    taskChan := make(chan string)

    go publishTask(taskChan, 5)

    receiveTask(taskChan)

}

相关文章

网友评论

      本文标题:golang channel 关闭方式

      本文链接:https://www.haomeiwen.com/subject/cedqwftx.html