如何使用 Channels 让 goroutine 相互通信

欢迎各位小伙伴来到golang学习网，相聚于此都是缘哈哈哈！今天我给大家带来《如何使用 Channels 让 goroutine 相互通信》，这篇文章主要讲到等等知识，如果你对Golang相关的知识非常感兴趣或者正在自学，都可以关注我，我会持续更新相关文章！当然，有什么建议也欢迎在评论留言提出！一起学习！

我是 golang 新手，正在尝试使用 goroutine，以便它们可以在它们之间进行通信。我有一些代码启动一个具有操作 1 的 goroutine，我称之为跳舞。当它完成时，它会向另一个 goroutine 发出信号，该 goroutine 执行另一个操作2，比如说睡眠。

你可以将一个force dance参数传递给dance goroutine，但如果它已经处于dance状态，它就会休眠。

package main

import (
    "fmt"
    "time"
)

func main(){
    test("notdancing", true)
    time.sleep(10*time.second)
}
func dance()error{
    fmt.println("tapping my feet")
    time.sleep(10*time.second)
    return nil
}
func test(status string, forcedance bool) {

这在以下情况下不起作用

//startsleep := make(chan bool)

为什么通道需要提供缓冲区长度才能正常工作？我尝试不设置缓冲区长度，但它说如果我不传递 1 作为第二个参数，所有 goroutine 都会休眠。

startdance := make(chan bool, 1)
    startSleep := make(chan bool, 1)

    if status == "dancing" && forceDance {
        select {
        case startSleep <-true:
            fmt.Println("Would start to sleep now")
        default:
            fmt.Println("Sleep Already started. No need to force")
        }
    }

    if status != "dancing" {
        fmt.Println("Startingdance")
        startdance <- true
    }

    go func() {
        <-startdance
        err := dance()
        if err == nil {
            select {
            case startSleep <- true:
                fmt.Println("Starting Sleeping, dancing completed")
            default:
                fmt.Println("Already started Sleeping")
            }
        } else {
            fmt.Println("Not in a mood to dance today")
        }
    }()

    go func() {
        <-startSleep
        if forceDance {
            fmt.Println("Force sleep because forcing to dance while already dancing")
        }
    }()

}

我非常感谢对代码的任何更正以及使用这种方法的陷阱。

解决方案

在无缓冲通道的情况下（未指定大小时），它无法保存值，因为它没有大小。因此，通过通道写入/传输数据时必须有读取器在场，否则将阻塞调用。

func main() {
    startdance := make(chan bool)
    startdance <- true
}

但是，当您在上面的代码中指定大小（例如 1）时，就不会出现死锁，因为它将有空间来保存数据。 ((https://robertbasic.com/blog/buffered-vs-unbuffered-channels-in-golang/) .)(https://www.golang-book.com/books/intro/10) 您可以查看上述网站以更好地了解通道和并发

package main

import (
    "fmt"
    "time"
)

func main() {
    startDance := make(chan bool)
    startSleep := make(chan bool)
    forceSleep := make(chan bool)
    go startDance1(startDance, forceSleep, startSleep)
    go performSleep(startSleep, startDance)
    startDance <- true
    fmt.Println("now dance is started ")
    forceSleep <- true
    select {}
}

func startDance1(startDance chan bool, forceSleep chan bool, startSleep chan bool) {

    fmt.Println("waiting to start dance")
    select {
    case <-startDance:
        fmt.Println("staring dance")
    }

    for {
        select {
        case <-startDance:
            fmt.Println("starting dance")
        case <-forceSleep:
            fmt.Println("aleardy dancing going to sleep")
            select {
            case startSleep <- true:

            default:
            }
        default:
            //this is just to show working this
            // i added default or else this will go into deadlock
            fmt.Println("dancing")
            time.Sleep(time.Second * 1)
        }
    }
}

func performSleep(startSleep chan bool, startDance chan bool) {
    select {
    case <-startSleep:
        fmt.Println("staring sleep")
    }
    fmt.Println("sleeping for 5 seconds ")
    time.Sleep(time.Second * 5)
    select {
    case startDance <- true:
        fmt.Println("started dance")
    default:
        fmt.Println("failed to start dance ")
    }
}

上面的代码比您的代码稍有改进（我尝试根据您的要求进行制作）。我建议你读一些书来了解更多关于 go 并发的知识（https://www.golang-book.com/books/intro/10_

到这里，我们也就讲完了《如何使用 Channels 让 goroutine 相互通信》的内容了。个人认为，基础知识的学习和巩固，是为了更好的将其运用到项目中，欢迎关注golang学习网公众号，带你了解更多关于的知识点！