チャネル

ゴルーチンの間で値を渡す

ch := make(chan int)   // int を流すチャネル
ch <- 42               // 入れる
v := <-ch              // 取り出す

矢印が向きを表します。ch <- はチャネルへ入れる、<-ch はチャネルから取り出す、です。矢印はいつも値の流れる向きを指しています。

待ち合わせの道具でもある

チャネルの本当の役目は、値を運ぶことだけではありません。タイミングを合わせることです。

v := <-ch

この行は、値が入るまでそこで止まります。入った瞬間に動き出します。

前のレッスンで「待たないと結果が消える」問題がありました。チャネルから取り出す行を書けば、そこで待つので消えません。

容量のあるチャネル

ch := make(chan int)      // 容量0
ch := make(chan int, 3)   // 容量3

容量0のチャネルは、入れる側も取り出す側が来るまで待ちます。手渡しに近い動きです。

ch := make(chan int)
ch <- 42   // 取り出す人がいないと、ここで永久に止まる

1人で書いていると、これで固まります。

fatal error: all goroutines are asleep - deadlock!

デッドロックです。全員が誰かを待っていて、誰も進めない状態を Go が検出して教えてくれます。

容量があれば、その数までは待たずに入れられます。

ch := make(chan int, 3)
ch <- 1   // 待たない
ch <- 2   // 待たない

前のレッスンで make(chan int, len(nums)) としたのは、これが理由です。全部入れきってから取り出せるので、順番を気にせずに済みます。

取り出す回数を合わせる

最も間違えやすいのがここです。

入れた数 > 取り出す数   結果が足りない
入れた数 < 取り出す数   永久に待つ。タイムアウト

入れた数をきっちり数えて、同じ回数だけ取り出します。この「数を合わせる」作業が面倒なので、次のレッスンの WaitGroup が用意されています。

range で受け取る

for v := range ch {
	total += v
}

チャネルが閉じられるまで受け取り続けます。閉じるのは送る側です。

close(ch)

閉じ忘れると、range は永久に待ちます。入門のうちは回数を数えて取り出す形で十分なので、close は「そういうものがある」と知っておく程度で構いません。

1. 前半と後半をそれぞれゴルーチンで集計する
2. 結果をチャネルで受け取る
3. 2つの結果を足して返す
4. 0件のときは 0 を返す