LoginSignup
345
201

More than 3 years have passed since last update.

@ta1m1kam

Goのgoroutine, channelをちょっと攻略！

Last updated at Posted at 2019-04-11

Goのgoroutine, channelがわからない

マルチスレッドってなんやねん！
go ステートメントってなんやねん！
<- なんやねんこれ！意味不明

これをやりましょう → Go by Example
やっていれば、なんとなくわかってくる。かも

以下は Go by Exampleを少し変更を加えて実行した例です。

Goroutineとは

Tour of go によると

goroutine (ゴルーチン)は、Goのランタイムに管理される軽量なスレッドです。

まず、スレッドがちゃんと理解してない

スレッド：一連のプログラムの流れ

シングルスレッド：1つのスレッドだけからなるプログラム
マルチスレッド：1つのプログラムで複数のスレッドを同時に実行する

マルチスレッド最強やんけ！ずっとこれ使えば小早川セナじゃん！
→ 実際には、しっかり理解して使わないとパフォーマンスが低下したり、デッドロックが生じる可能性がある。

マルチスレッドはこんなときに使う

Goroutinesを理解しよう

goroutineは、軽量のスレッドである。
goステートメントで関数を指定することで、並行実行される。 ※並列実行ではない。

ex) 関数fが並行実行される。

func f(value string) {
    for i := 0; i < 3; i++ {
        fmt.Println(value)
        time.Sleep(3 * time.Second)
    }
}

func main() {
    go f("goroutineを使って実行")
    f("普通に実行")
    fmt.Println("done")
}

こんなふうに出力が混ざった状態になる。

普通に実行
goroutineを使って実行
goroutineを使って実行
普通に実行
普通に実行
goroutineを使って実行
done

試したい方どうぞ → The Go Playground

Channelsを理解しよう

チャネルは、並行実行されるgoroutine間を接続するパイプ(トンネル)のイメージ。つまり、並行実行している関数から値を受信する。(あるgoroutineから別のgoroutineへ値を渡す。)

channel.png

make(chan 型)で新しいチャネルを作成できる
channel <- 構文で、チャネルへ値を 送信 します。
<-channel 構文で、チャネルから値を 受信 します
つまり、上の例では、messageというパイプを使って、無名関数からmsgへ"ping"を渡している。
"ping"という値がmessageトンネルを通ってmsgへ届く

Goはデフォルトで、送る側と受ける側が準備できるまで、 送受信はブロックされる。
このため、同期処理的なものを書かなくても、"ping"がmsgに渡されるまで、待ってくれる


func main() {
  messages := make(chan string)
  go func() { messages <- "Hello" }()

  msg := <-messages
  fmt.Println(msg)
}

出力

Hello

チャネルはバッファとして使える。

  • バッファ: 一時的に記憶する場所

バッファが詰まるとチャネルへの送信をブロックする
バッファが空のときは、チャネルの受信をブロックする

ex)

package main

import "fmt"

func main() {
    ch := make(chan int, 2)
    ch <- 1
    ch <- 2 

    fmt.Println(<-ch)
    fmt.Println(<-ch)
}

出力

1
2

デッドロックが起こるように書き換え

  ch <- 1
  ch <- 2   
  ch <- 3

  fmt.Println(<-ch)
  fmt.Println(<-ch)
  fmt.Println(<-ch)

fatal error: all goroutines are asleep - deadlock!

Buffering

バッファリングされたチャネルは、対応する受信側がいなくても決められた量までなら 値を送信することができる
make(chan string, 2)によって2つまでバッファリングするチャネルを作っている。

func main() {
  messages := make(chan string, 2)

  messages <- "Hello"
  messages <- "World"

  fmt.Println(<-messages)
  fmt.Println(<-messages)
}

出力

Hello
World

Directions

チャネルを関数の引数として使うと送信か受信のどちらを意図しているか指定(わかりやすく)することができる。
directions.png

func ping(pings chan<- string, msg string) {
    pings <- msg
}

// この `pong` 関数は、1 つ目のチャネルを受信専用で (`pings`)、
// 2 つ目のチャネルを送信専用で (`pongs`) 受け取ります。
func pong(pings <-chan string, pongs chan<- string) {
    msg := <-pings
    pongs <- msg
}

func main() {
    pings := make(chan string, 1)
    pongs := make(chan string, 1)
    ping(pings, "Hello")
    pong(pings, pongs)
    fmt.Println(<-pongs)
}

出力

Hello

Select

selectを利用することで、複数のチャネル操作を待つことができる。
受信したものから、画面に表示される。

2つのチャンネルに対して selectをする例

func main() {

    c1 := make(chan string)
    c2 := make(chan string)

    go func() {
        time.Sleep(2 * time.Second)
        c2 <- "two"
    }()
    go func() {
        time.Sleep(1 * time.Second)
        c1 <- "one"
    }()

    for i := 0; i < 2; i++ {
        select {
        case msg1 := <-c1:
            fmt.Println("received", msg1)
        case msg2 := <-c2:
            fmt.Println("received", msg2)
        }
    }
}

出力

received one
received two

Timeouts

selectは最初に受信したものを処理するため、<-Time.Afterのほうが処理がはやければ、そちらの処理が走ります。
selectタイムアウトパターンを使用するためにはチャンネル経由でやりとりする必要がある。

func main() {
  c1 := make(chan string, 1)
    go func() {
        time.Sleep(2 * time.Second)
        c1 <- "result 1"
    }()

    select {
    case res := <-c1:
        fmt.Println(res)
    case <-time.After(1 * time.Second):
        fmt.Println("timeout 1")
    }
}

出力

timeout 1

Closing Channels

jobsチャネルをcloseします。
closeするとmoreの値がfalseになり、doneがtrueになります。
チャネルをクローズすることは、もう値を送信しないことを意味し、チャネルの受け手に完了を伝えるのに便利です。

func main() {
    jobs := make(chan int, 5)
    done := make(chan bool)

    go func() {
        for {
            j, more := <-jobs
            if more {
                fmt.Println("received job", j)
            } else {
                fmt.Println("received all jobs")
                done <- true
                return
            }
        }
    }()

    for j := 1; j <= 5; j++ {
        jobs <- j
        fmt.Println("sent job", j)
    }
    close(jobs)
    fmt.Println("sent all jobs")

    <-done
}

出力

sent job 1
sent job 2
received job 1
received job 2
sent job 3
sent job 4
sent job 5
sent all jobs
received job 3
received job 4
received job 5
received all jobs

Timers

将来のある時点や一定間隔で繰り返し、ある部分を実行したい際に利用する
タイマーは待ち時間を指定すると、その時間にチャネルが処理を実施します。
例では、5秒経過すると一定の処理を実施します。

func main() {
    start := time.Now()
    timer1 := time.NewTimer(5 * time.Second)
    <-timer1.C
    fmt.Println("It's time!")
    end := time.Now();
    fmt.Printf("%f秒\n",(end.Sub(start)).Seconds())
}

出力

It's time!
5.001331秒

Ticker

ティッカーは一定間隔で何かを実行した際に使用します。
ティッカーは、ticker.Stop()により停止するとそのチャネルから値を受信しなくなる

func main() {
    ticker := time.NewTicker(500 * time.Millisecond)
    go func() {
        for t := range ticker.C {
            fmt.Println("Tick at", t)
        }
    }()

    time.Sleep(1600 * time.Millisecond)
    ticker.Stop()
    fmt.Println("Ticker stopped")
}

出力

Tick at 2019-04-11 15:08:11.070217 +0900 JST m=+0.503669133
Tick at 2019-04-11 15:08:11.571622 +0900 JST m=+1.005080664
Tick at 2019-04-11 15:08:12.072034 +0900 JST m=+1.505498210
Ticker stopped

Worker Pools

workerは3つ分並列実行されます。
5つのジョブが送信されるため5秒分のタスクを実行します。
しかし、worker関数のtime.Sleepで5秒分のタスクを実行する似にかかわらず、2秒しかかかりません。
これは、3つのworkerが並列実行しているためです。

func worker(id int, jobs <-chan int, results chan<- int) {
    for j := range jobs {
        fmt.Println("worker", id, "started  job", j)
        time.Sleep(time.Second)
        fmt.Println("worker", id, "finished job", j)
        results <- j * 2
    }
}

func main() {
    start := time.Now()

    jobs := make(chan int, 100)
    results := make(chan int, 100)

    for w := 1; w <= 3; w++ {
        go worker(w, jobs, results)
    }

    for j := 1; j <= 5; j++ {
        jobs <- j
    }
    close(jobs)

    for a := 1; a <= 5; a++ {
        <-results
    }

    end := time.Now();
    fmt.Printf("%f秒\n",(end.Sub(start)).Seconds())
}

出力

worker 3 started  job 1
worker 1 started  job 2
worker 2 started  job 3
worker 1 finished job 2
worker 3 finished job 1
worker 3 started  job 4
worker 1 started  job 5
worker 2 finished job 3
worker 3 finished job 4
worker 1 finished job 5
2.006739秒

Worker Poolまで試せば、並列処理の速さがわかるはず！5秒の処理が2秒に！！

図とかのイメージはあっているのか...？

参考

GoのChannelを使いこなせるようになるための手引 - Qiita

並行処理、並列処理のあれこれ - Qiita

Go by Example: Goroutines

345
201
2

Register as a new user and use Qiita more conveniently

  1. You get articles that match your needs
  2. You can efficiently read back useful information
  3. You can use dark theme
What you can do with signing up
Sign upLogin
345
201