はじめに
こんにちは、nukkyです。Go連載7回目を担当させていただきます。
プログラムを書く上ではなかなか避けては通れない非同期処理について今回は記事にしたいと思います。
ゴルーチン
Goにはスレッドより小さい単位「ゴルーチン」が並行して動作する様に設計されています。
go文
ゴルーチンを実行するにはgo文で関数を呼び出します。次のコードをみてください。
1 2 3 4 5 6 7 8 9 10 11 12 | funcsub(){ for{ fmt.Println("sub loop") } } funcmain(){ gosub()// ゴルーチン開始 for{ fmt.Println("main loop") } } |
goの後に関数subを呼び出すことでゴルーチンを開始しています。
ゴルーチンの終了条件
ゴルーチンは、下記の条件で終了されます。
- 関数が終わる
- returnで抜ける
- runtime.Goexit()を実行する
たとえば、Go文のサンプルを以下の様に書き換えた場合、
1 2 3 4 5 6 7 8 9 | funcsub(){ for{ fmt.Println("sub loop") } } funcmain(){ gosub()// ゴルーチン開始 } |
この場合mainが終了した際にmainで実行したゴルーチンは終了されてしまいます。なぜかというとmain関数も1つのゴルーチンの中で実行されており、mainの中で宣言したゴルーチンが実行されるにはmain関数も実行中(終了されていない)でないといけないからです。
WaitGroup
ゴルーチンですが宣言から実行されるまでの間隔は保証されておらずmainでスリープなどしても何秒待てばよいかはわかりません。
そこでsyncパッケージのWaitGroupを使いゴルーチンの終了を待ってみます。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 | import( "fmt" "sync" ) funcsub(){ fmt.Println("sub") deferwg.Done() // 関数終了時にデクリメント } funcmain(){ varwg sync.WaitGroup wg.Add(1)// ゴルーチン起動のたびにインクリメント gosub() // ゴルーチン開始 wg.Wait()// 処理をブロックし、カウンタが0になったら次に進む fmt.Println("Done.") } |
WaitGroupは厳密にどのゴルーチンが終了したかは管理せず 、WaitGroup内のカウンタで実行中か終了かを判断しています。
チャネル
チャネルとは、ゴルーチンとゴルーチンの間でデータの受け渡しを行うためにデザインされたGo特有のデータ構造です。
チャネルの型
チャネルの型名は「chan [データ型]」のように記述します。
1 2 | // int型のチャネル varch chanint |
チャネルには他のデータ型にはない特殊なサブタイプを指定できます。「<-chan」を使用すると受信専用チャネル、「chan<-」を使用すると送信専用チャネルになります。サブタイプを指定しない「chan」は送受信可能な双方向チャネルとして機能します。
チャネルの生成
チャネルはmakeを使って生成します。makeへの2番目の引数を指定することでバッファサイズを指定できます。
1 2 3 4 | // バッファサイズ0のチャネル ch:=make(chanint) // バッファサイズ8のチャネル ch:=make(chanint,8) |
チャネルはキューの性質をもつデータ構造になっており、チャネルのバッファとはキューを格納する領域であるためバッファサイズとはキューのサイズとみなすことができます。キューには「FIFO(先入れ先出し)」の性質があり、先にキューに挿入されたデータを先に取得できるという特性があり、これはデータを取り出す順序が保証されるという性質があります。
チャネルの送受信
チャネルが保持するデータにアクセスするには送信か受信の2パターンのみです、送受信ともに演算子「<-」を使用します。
1 2 3 4 5 6 | ch:=make(chanint,10) // チャネルに整数を送信 ch<-5 // チャネルから整数を受信 i:=<-ch |
チャネルとゴルーチン
チャネルを使用することでゴルーチン間での値のやりとりが可能になります。次のコードを見てください。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 | packagemain import( "fmt" "math/rand" "time" ) funcinit(){ rand.Seed(time.Now().UnixNano()) } funcfrom(ch chan<-int){ ch<-rand.Intn(100) } functo(ch<-chanint){ fmt.Printf("Received %d\n",<-ch)// chに値が入ってくるまで待機 } funcmain(){ ch:=make(chanint) gofrom(ch) goto(ch) time.Sleep(100*time.Millisecond) } |
この様に呼び出し元でチャネルを宣言しゴルーチンに引き渡すことで、チャネルを使用した値のやりとりが可能になります。
チャネルのクローズ
使用しなくなったチャネルはクローズ(close)する。こうすることでクローズ済みのチャネルに値を送信することはできなくなります。
1 | close(ch) |
チャネルをクローズしてもバッファには値が残っており、クローズ済みのチャネルから値を受信しようとすると、チャネルでバッファされている値がなくなるまで受信でき、バッファ内の値を全て受信し尽くした後は、そのチャネルの要素型のゼロ値が返る様になります。
select
次の様な単純なプログラムの場合、変数ch1とch2はチャネル型、変数e1とe2はチャネルが内包するデータ型とした場合、
1 2 | e1:=<-ch1 e2:=<-ch2 |
変数ch1の指すチャネルからデータが受信できない場合、この処理を実行しているゴルーチンは停止してしまいます。
複数のチャネルを扱いながら処理を停止させずに行いたい場合はselectを使います。
1 2 3 4 5 6 7 8 | select{ casee1:=<-ch1: // ch1から受信が成功した場合の処理 casee2:=<-ch2: // ch2から受信が成功した場合の処理 default: fmt.Println("no value") } |
複数のチャネルへの送信、受信処理をゴルーチンを停止させることなくコントロールすることが可能になります。
コンテキスト
Goの典型的な利用例であるWebアプリケーションを考えた場合、Goのサーバにおいてリクエストはそれぞれ個別のゴルーチンで処理されます。リクエストハンドラは新たなゴルーチンを生成しバックエンドのDBや別のサーバにリクエストを投げ結果を得てユーザに対してレスポンスを返すといった流れがあった際に注意すべきなのは、その処理に適切なTimeoutやDeadlineを設定して処理が停滞するのを防ぐこと、例えば別のサーバにリクエストを投げる場合にネットワークの問題でリクエストに時間がかかってしまうことが考えられます。この場合リクエストにTimeoutを設定して早めにレスポンスを返しリトライを促すべきだと思います。
さらに生成したゴルーチンを適切にキャンセルしリソースを解放することも求められます。例えば別のサーバにリクエストを投げる場合に適切なキャンセル処理を行わないとTimeout後もネットワークリソースが使われ続けることになるかもしれないからです。さらにネットワークアクセスに使用したゴルーチンは別のゴルーチンを呼び出しそれがまた別のと呼び出しの連鎖が考えられます。その場合も親のTimeoutに合わせてその子は全て適切にキャンセルされリソースは解放されることが望ましいです。
contextパッケージはキャンセルのためのシグナルをAPIの境界を超えて受け渡すための仕組みです。ある関数から別の関数、親から子へとキャンセルを伝搬させることができます。
基本的な使い方
ゴルーチンを呼び出す元の方でオブジェクトを生成します。「context.Background()」は空のコンテキストを生成します(nilではない)。
1 | ctx:=context.Background() |
これをゴルーチンに引き渡し伝搬させていきます。
1 | gohoge(ctx) |
タイムアウトでキャンセルする場合はWithTimeoutをつかいます。
1 2 | ctx,cancel:=context.WithTimeout(ctx,time.Second)// 1秒後にキャンセル defercancel() |
手動でキャンセルする場合はWithCancelを使います。
1 2 3 | ctx,cancel:=context.WithCancel(ctx) // 処理中略 cancel()// 即キャンセル |
キャンセルされたかの判断はselectでコンテキストのDoneを待ちます。
1 2 3 4 | select{ case<-ctx.Done(): fmt.Println("done:",ctx.Err())// done: context canceled } |
タイムアウトのサンプル
コンテキストのタイムアウトを使用したキャンセルのサンプルになります。
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 | packagemain import( "context" "fmt" "time" ) funcinfiniteLoop(ctx context.Context){ innerCtx,cancel:=context.WithCancel(ctx) defercancel() for{ fmt.Println("Waiting for time out") select{ case<-innerCtx.Done(): fmt.Println("Exit now!") return default: } } } funcmain(){ // コンテキストの生成 ctx:=context.Background() // 5秒後にキャンセル ctx,cancel:=context.WithTimeout(ctx,5*time.Second) defercancel() goinfiniteLoop(ctx) select{ case<-ctx.Done(): fmt.Println(ctx.Err())// context deadline exceeded } } |
実行結果
1 2 3 4 5 6 7 8 9 | Waiting fortime out Waiting fortime out Waiting fortime out . . . Waiting fortime out Exit now! context deadline exceeded |
さいごに
Goの非同期処理について調べましたが、Goは非同期について他の言語よりも取り扱いがしやすい印象を受けました、この記事がGo初心者の方の一助になれれば嬉しいです。
Go記事の連載などは、こちらをご覧ください。