Goでのgoroutineとchannelについて

Question

以下のようなコード走ります。

func listenChannel(message chan string) {
for out:= range message{
fmt.Println(message)
}
}
func main() {
message := make(chan string)
go listenChannel(message)
message <- "Hello"
}

しかし、このようなコードはdeadlockとなるのですが、どのような違いがあるのでしょうか。

package main

import (
	"fmt"
)

func listenChannel(message chan string) {
	fmt.Println(message)
}
func main() {
	message := make(chan string)
	go listenChannel(message)
	message <- "Hello"
}

Comments

[de9]

本当に上のコードは走りますか？

Answer 1

channel にはバッファという物が設定出来ます。いわゆるキューのサイズです。これが未指定の場合だと1つ入れるだけでバッファがいっぱいになります。バッファがいっぱいの状態でさらに送信しようとするとバッファが溢れて deadlock の panic が発生します。同じように誰も書かない channel を読み取ろうとした場合にも deadlock は発生します。

Go のランタイムはこのとき groutine の存在を確認します。別の goroutine が起動している時は「その channel を読み書きする可能性がある」という事で deadlock を免れます。

goroutine が書き込まないケース

package main

import (
	"time"
)

func listenChannel(message chan string) {
	time.Sleep(5 * time.Second)
	//message <- "Hello"
}

func main() {
	message := make(chan string)
	go listenChannel(message)
	println(<-message)
}

https://play.golang.org/p/zbmMC7tWwW

例えばこのコードは5秒後に deadlock が起きます。listenChannel が終了してしまうと goroutine は1つ(main)だけになり、message を待っているのに message を書きこむ groutine が無くなってしまうので deadlock を起こすという事です。この時、message に既に何か詰まっていれば groutine が終了したとしても、(goroutine の存在を確認する必要がないのですから) deadlock を起こす事はありません。

package main

import (
	"time"
)

func listenChannel(message chan string) {
	time.Sleep(5 * time.Second)
	//message <- "Hello"
}

func main() {
	message := make(chan string, 2)
	message <- "Wow"
	go listenChannel(message)
	println(<-message)
}

https://play.golang.org/p/DjBCUW9o0P

このコードは直ぐに終了します。

main が読み取らないケース

逆に main 側が読み取らない場合を見て下さい。

package main

import (
	"time"
)

func listenChannel(message chan string) {
	message <- "Hello"
}

func main() {
	message := make(chan string)
	go listenChannel(message)
	time.Sleep(5 * time.Second)
	//println(<-message)
}

https://play.golang.org/p/iCgLTs3va4

この場合、5秒後には gouroutine が消えますが main は生きているので channel を読み取る可能性があるという事で deadlock は起きません。

Answer 2

unbufferのchanは送信goroutineと受信goroutineが互いに揃った時始めて値の引き渡しが成立します。
受信を行うgoroutineが居ない事で送信goroutineの待ちは解除される事が無いのでデッドロックします。