Go通过Channel进行同步和通信

在Go语言中，通道（channel）是一种非常重要的同步和通信机制。通过通道，你可以实现Goroutine之间的数据交换和同步操作。下面是一些使用通道进行同步和通信的基本示例。

1. 简单的发送和接收

package main

import "fmt"

func main() {
    ch := make(chan int) // 创建一个整型通道

    go func() { // 在新Goroutine中发送数据到通道
        ch <- 42
    }()

    value := <-ch // 主Goroutine从通道接收数据
    fmt.Println("Received value:", value) // 输出：Received value: 42
}

在这个例子中，我们创建了一个新的Goroutine来发送数据到通道，然后在主Goroutine中从通道接收数据。

2. 使用select语句处理多个通道

package main

import (
    "fmt"
    "time"
)

func main() {
    ch1 := make(chan string)
    ch2 := make(chan string)

    go func() {
        time.Sleep(1 * time.Second)
        ch1 <- "one"
    }()
    go func() {
        time.Sleep(2 * time.Second)
        ch2 <- "two"
    }()

    for i := 0; i < 2; i++ {
        select {
        case msg1 := <-ch1:
            fmt.Println("Received", msg1, "from channel 1")
        case msg2 := <-ch2:
            fmt.Println("Received", msg2, "from channel 2")
        }
    }
}

这个例子展示了如何使用 select 语句同时监听多个通道。当任意一个通道有数据可用时，程序将立即处理该通道的数据。

3. 使用通道进行同步

package main

import "fmt"

func main() {
    done := make(chan bool)

    go func() {
        fmt.Println("Working...")
        // 假设这里是耗时的操作
        done <- true // 操作完成后，向done通道发送信号
    }()

    <-done // 主Goroutine等待done通道接收到信号
    fmt.Println("Done!")
}

在这个例子中，我们创建了一个名为 done 的通道，并在一个新的Goroutine中执行耗时的操作。当操作完成后，它会向 done 通道发送一个信号。主Goroutine则阻塞在对 done 通道的接收操作上，直到接收到信号后才继续执行。

4. 通道关闭与range循环

package main

import "fmt"

func main() {
    numbers := []int{7, 2, 8, -9, 4, 0}

    ch := make(chan int)
    done := make(chan bool)

    go func() {
        defer close(ch) // 函数结束时关闭通道

        for _, number := range numbers {
            ch <- number
        }

        done <- true // 所有数字已发送完毕
    }()

    // 在主Goroutine中从通道接收数据
    go func() {
        sum := 0
        for num := range ch {
            sum += num
        }
        fmt.Println("Sum of all numbers:", sum)
    }()

    <-done // 等待所有数字都已发送和接收
}

在这个例子中，我们使用了

以上就是一些使用Go通道进行同步和通信的基础示例。在实际应用中，你可能会遇到更复杂的场景，但基本的原理和模式都是相同的。

原文链接: https://www.yukx.com/golang/article/details/2425.html 优科学习网Go通过Channel进行同步和通信