Go 언어의 비동기 채널 처리 기술-Golang-php.cn

Go 언어의 비동기 채널 처리 기술

WBOY

풀어 주다： 2023-06-03 15:31:34

원래의

1325명이 탐색했습니다.

비동기 채널(channel)은 Go 언어의 매우 중요한 기능 중 하나입니다. 이를 통해 고루틴 간에 통신하고 동기화할 수 있습니다. 이 통신 방법은 공유 메모리 방법보다 매우 효율적이고 안전합니다. 공유 메모리에 대한 읽기/쓰기 작업에는 경쟁 조건을 피하기 위해 명시적인 잠금이 필요하기 때문입니다. 이 기사에서는 비동기 채널 처리에 사용되는 몇 가지 일반적인 기술에 대해 설명합니다.

버퍼 채널

버퍼 채널은 송신자가 수신자를 기다릴 필요가 없도록 송신 작업과 수신 작업 사이에 특정 수의 요소를 버퍼링하는 비동기 채널입니다. 즉, 버퍼링된 채널을 사용하면 코루틴이 비동기적으로 통신할 수 있습니다.

예를 들어, 다음은 버퍼링된 채널을 사용하는 예입니다.

package main

import "fmt"

func main() {
    ch := make(chan int, 2) // 创建缓冲信道，缓存两个元素
    ch <- 1
    ch <- 2
    fmt.Println(<-ch) // 从信道中读取第一个元素
    fmt.Println(<-ch) // 从信道中读取第二个元素
}

로그인 후 복사

출력은 다음과 같습니다.

1
2

로그인 후 복사

위의 예에서는 두 개의 정수 요소를 캐시하는 버퍼링된 채널 ch를 만듭니다. 그런 다음 ch <- 1 및 ch <- 2 문을 사용하여 두 요소를 채널로 보냅니다. 마지막으로 <-ch를 사용하여 채널에서 두 요소를 두 번 읽습니다. ch，缓存两个整数元素。然后我们使用 ch <- 1和ch <- 2两个语句将两个元素发送到信道中去。最后，我们使用<-ch两次从信道中读取这两个元素。

需要注意的是，如果我们尝试往一个已经满了的缓冲信道里发送元素，那么发送操作就会阻塞，直到信道中有空闲位置为止。类似地，如果我们尝试从一个空的缓冲信道中读取元素，那么读取操作也将阻塞，直到信道中有元素为止。

关闭信道

在使用异步信道时，我们必须注意一些细节。例如，当我们从一个已经关闭的信道里读取数据时，会发生什么呢？

当我们尝试从一个已经关闭的信道中读取数据时，这个读取操作将不再阻塞，而是立即返回一个零值。例如，在下面的示例中我们可以看到当我们从一个已经关闭的信道中读取元素时，将会返回类型的零值：

package main

import "fmt"

func main() {
    ch := make(chan int)
    close(ch)     // 关闭信道
    x, ok := <-ch // 读取信道
    fmt.Println(x, ok) // 输出：0 false
}

로그인 후 복사

需要注意的是，需要在确保有多个协程使用信道时才去关闭它。如果只有一个协程在使用信道，那么我们就不需要去手动关闭信道，因为这样可能会导致其他协程在尝试从发送到这个信道上的数据时引发 panic。

信道的超时机制

有些情况下，我们在等待一个信道的数据时可能会遇到超时问题。例如，当我们从一个网络连接中读取数据时，如果数据的到来时间超过了我们设定的等待时间，这时我们就需要关闭这个连接，以便让其他的协程可以使用这个资源。

在异步信道处理中，我们可以使用select语句自定义超时机制。下面是一个使用 select语句实现信道超时机制的示例：

package main

import (
    "fmt"
    "time"
)

func main() {
    ch := make(chan int)
    go func() {
        time.Sleep(5 * time.Second)
        ch <- 1
    }()
    select {
    case x := <-ch:
        fmt.Println(x)
    case <-time.After(3 * time.Second):
        fmt.Println("timeout!")
    }
}

로그인 후 복사

在上面的示例中，我们使用time.After()函数返回一个time.Timer类型的实例来等待超时。如果信道在超时之前接收到数据，我们就可以从x := <-ch语句得到数据。否则，当超时发生时，<-time.After(3 * time.Second)语句就会立即执行，并输出一个超时相关的信息。

需要注意的是，在使用信道超时机制时，我们也应该注意关闭了哪个信道，以避免在等待信道接收数据时引发 panic。

select 语句

select语句是 Go 语言中的一个非常重要的语言结构，它可以让我们同时等待多个通信操作。当多个通信操作都准备好了，select语句会随机选择一个语句执行。

下面是一个使用select语句的示例，其中我们同时等待一个信道发送和接收操作：

package main

import (
    "fmt"
)

func main() {
    ch1 := make(chan int)
    ch2 := make(chan int)
    go func() {
        ch1 <- 1
    }()
    select {
    case x := <-ch1:
        fmt.Println(x)
    case ch2 <- 2:
        fmt.Println("send 2")
    }
}

로그인 후 복사

在上面的示例中，我们使用go语句在一个新协程中执行ch1 <- 1语句。然后，我们使用select语句同时等待信道ch1和ch2。如果ch1中有元素，我们就可以从x:= <-ch1这个语句中取出它，并将它打印出来。另一方面，如果ch2可以发送元素，那么执行ch2 <- 2并打印输出。

需要注意的是，在使用select语句时，我们不必一定要对所有信道进行接收和发送操作。例如，在上面的示例中我们只对ch1进行了接收操作，而对ch2只进行了发送操作。

总结：

在Go语言中，异步信道处理是一种非常重要的技术。在异步编程时，我们可以使用缓冲信道、关闭信道、超时信道等方式，充分利用信道的高效通信特性。同时，我们也要注意一些技巧，如只关闭正在被多个协程使用的信道、使用select

이미 가득 찬 버퍼 채널에 요소를 보내려고 하면 채널에 여유 공간이 생길 때까지 보내기 작업이 차단된다는 점에 유의해야 합니다. 마찬가지로, 빈 버퍼 채널에서 요소를 읽으려고 하면 채널에 요소가 있을 때까지 읽기 작업도 차단됩니다. 🎜

select

time.After()

time 시간 초과를 기다리는 .Timer

x := <-ch

<-time.After(3 * time.Second)

select

go

ch1 <- 1