Go by Example: Closing Channels

チャネルを クローズする (Closing) ことは、 もう値を送信しないことを意味します。これは、 チャネルの受け手に完了を伝えるのに便利です。

 
package main
 
import "fmt"

この例では、main() ゴルーチンからワーカーのゴルーチンへ タスクの完了を伝えるために、jobs チャネルを使います。 ワーカータスクがなくなれば、jobs チャネルを close します。

 
func main() {
    jobs := make(chan int, 5)
    done := make(chan bool)

ワーカーのゴルーチンは次の通りです。j, more := <-jobs で jobs チャネルから繰り返し受信します。 この 2 値の形式の受信では、jobs が close され、 チャネルのすべての値がすでに受信されていれば、 more の値が false になります。 ここでは、すべてのタスクが完了したときに、 done チャネルへ通知するために使っています。

 
    go func() {
        for {
            j, more := <-jobs
            if more {
                fmt.Println("received job", j)
            } else {
                fmt.Println("received all jobs")
                done <- true
                return
            }
        }
    }()

これは、jobs チャネルを通して 3 つのジョブを ワーカーへ送信し、その後チャネルをクローズします。

 
    for j := 1; j <= 3; j++ {
        jobs <- j
        fmt.Println("sent job", j)
    }
    close(jobs)
    fmt.Println("sent all jobs")

すでに学んだチャネルの 同期 手法を使って、ワーカーの完了を待ちます。

 
    <-done

クローズしたチャネルから読み込むとすぐさま成功し、 ゼロ値が返ります。2 つ目の戻り値は、チャネルに送信された 値を受信できた場合は true、チャネルがクローズされて ゼロ値になった場合は false になります。

 
    _, ok := <-jobs
    fmt.Println("received more jobs:", ok)
}
 
$ go run closing-channels.go 
sent job 1
received job 1
sent job 2
received job 2
sent job 3
received job 3
sent all jobs
received all jobs
received more jobs: false

クローズされたチャネルのアイデアは、次に学ぶ例である、 チャネルに対する range につながります。

Next example: Range over Channels.

by Mark McGranaghan and Eli Bendersky (translated by @oohira) | feedback | license