お題
表題の通り。
goroutineを使った実装パターンを知りたければ下記を読むといい。
https://mattn.kaoriya.net/software/lang/go/20180531104907.htm
が、パターンはパターンとして、goroutineをそもそも使わないケースから始めて、使うとどうなるか、うまく動かないケースも含めて試してみようと思う。
関連記事Index
開発環境
# OS
$ cat /etc/os-release
NAME="Ubuntu"
VERSION="17.10 (Artful Aardvark)"
# 言語
$ go version
go version go1.10 linux/amd64
実践
$共通に使う関数$
100ミリ秒のスリープを入れつつ５回「ping」を出力するping()関数と同様に「pong」を出力するpong()関数を用意
func ping() {
for i := 0; i < 5; i++ {
fmt.Println("ping")
time.Sleep(100 * time.Millisecond)
}
}
func pong() {
for i := 0; i < 5; i++ {
fmt.Println(" pong")
time.Sleep(100 * time.Millisecond)
}
}
■関数の前に「go」と付けるだけでメイン関数と別の goroutine が生成される
No.01: goroutine使わない版
func main() {
ping()
pong()
}
当然のように５回「ping」の後、５回「pong」を出力（何回やっても結果は同じ）
$ go run main.go
ping
ping
ping
ping
ping
pong
pong
pong
pong
pong
No.02: 先行して実行する関数をgoroutine化
func main() {
go ping()
pong()
}
ping()関数はメイン処理をブロックせずに実行されるようになったため、即座にpong()関数の実行も始まる。
＜１回目＞
$ go run main.go
pong
ping
pong
ping
pong
ping
pong
ping
pong
ping
＜２回目＞
$ go run main.go
pong
ping
ping
pong
ping
pong
ping
pong
ping
pong
＜３回目＞
$ go run main.go
pong
ping
ping
pong
pong
ping
ping
pong
ping
pong
No.03: 後攻の関数をgoroutine化
func main() {
ping()
go pong()
}
後攻の関数がメイン関数をブロックしなくなると、それ以降にメイン関数の処理がないため、メイン関数が終了する。
メイン関数が終了すると、goroutineも終了するため、５回の「ping」を出力したら（「pong」の出力は一切なしで）終了。
$ go run main.go
ping
ping
ping
ping
ping
No.04: 先行・後攻の関数をともにgoroutine化
func main() {
go ping()
go pong()
}
メイン関数をブロックする処理がなくなるのでping()関数ないしpong()関数が出力する前にメイン関数が終了する。
$ go run main.go
■生成した goroutine の終了を待ってメイン関数を終了させる
No.05: 2つのgoroutineの終了をメイン関数で待機（Sleep編）
func main() {
go ping()
go pong()
time.Sleep(3 * time.Second)
}
goroutine 生成から３秒経過したら（goroutineごと）メイン関数が終了
ただし、このやり方は悪手。
$ go run main.go
ping
pong
ping
pong
ping
pong
pong
ping
pong
ping
No.06: 2つのgoroutineの終了をメイン関数で待機（WaitGroup編）
func main() {
wg := &sync.WaitGroup{}
wg.Add(1)
go ping(wg)
wg.Add(1)
go pong(wg)
wg.Wait()
}
func ping(wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 5; i++ {
fmt.Println("ping")
time.Sleep(100 * time.Millisecond)
}
}
func pong(wg *sync.WaitGroup) {
defer wg.Done()
for i := 0; i < 5; i++ {
fmt.Println(" pong")
time.Sleep(100 * time.Millisecond)
}
}
ちゃんとピンポン出る。
$ go run main.go
pong
ping
ping
pong
ping
pong
ping
pong
ping
pong
No.07: 2つのgoroutineの終了をメイン関数で待機（Channel編）
func main() {
ch := make(chan struct{}, 2)
go ping(ch)
go pong(ch)
<-ch
}
func ping(ch chan struct{}) {
for i := 0; i < 5; i++ {
fmt.Println("ping")
time.Sleep(100 * time.Millisecond)
}
ch <- struct{}{}
}
func pong(ch chan struct{}) {
for i := 0; i < 5; i++ {
fmt.Println(" pong")
time.Sleep(100 * time.Millisecond)
}
ch <- struct{}{}
}
$ go run main.go
pong
ping
ping
pong
pong
ping
pong
ping
pong
ping
まとめ
goroutineやChannelが真価を発揮する大分手前の時点だけど、今回はさわりだけ。