Go言語の目玉のマルチスレッド

Go言語の特徴の一つとして、容易に軽量な並列処理を実装できるという点があります。

この記事においては、それをなるべく簡単なコードで実行し、最低限どんなコードで構成されるかを見ていきたいと思います。

Goroutine

package main

import (
    "fmt"
    "time"
)

func say() {
    for i := 0; i < 5; i++ {
        time.Sleep(1000 * time.Millisecond)
        fmt.Println(i)
    }
}

func main() {
    go say()
    fmt.Println("この文章が数字より先に表示されます")
    time.Sleep(5000 * time.Millisecond)
    fmt.Println("この文章は5秒後に強制的に表示されます")
}

このコードでは、16行目のsay()メソッドの呼び出しにgoというキーワードを付けることで、マルチスレッドを実現します。

つまり、メインのスレッドではsay()が終わっていなくても処理を次の行へ進めます。

なので、11行目のPrintlnが実行されて0が表示される前に、17行目の文字列が表示されます。

試しに、16行目のgoキーワードを外して実行すると、0から4までの数値が出力された後に16行目の文字列が表示されます。

16行目のPrintのコードが、15行目のsay()が完了されるまで実行されなくなるためです。

また、例えば、18行目のtime.Sleepを削除すると、go say()の内容が完了しない内にコードの終端まで処理が達してしまうため、0から4までの数字が出力されずにプログラムが終了してしまいます。

今回のコードでは、time.Sleepを用いて無理やり同期をとる形をとっていました。

同期をとるもっと確実な方法があり、それがchannelです。

Channel

package main

import (
    "fmt"
    "time"
)

func say(c chan bool) {
    for i := 0; i < 5; i++ {
        time.Sleep(1000 * time.Millisecond)
        fmt.Println(i)
    }
    c <- true
}

func main() {
    channel := make(chan bool)
    go say(channel)

    b := <- channel
    fmt.Println(b)
}