Goroutineとselectとchannelを使って共同作業

田中君：1作業あたり1秒
鈴木君：1作業あたり1秒

ルール
- 作業6個分になったら仕事終了
- 仕事が終了するまでにかかった時間を計測する

田中君だけで作業をした場合 (鈴木君のgoroutineをコメントアウト）

package main

import (
    "fmt"
    "time"
)

var total_work = []string{}

func tanaka(ch chan string) {
    for {
        time.Sleep(1 * time.Second)
        ch <- "作業"
    }
}

func suzuki(ch chan string) {
    for {
        time.Sleep(1 * time.Second)
        ch <- "作業"
    }
}

func main() {
    start_time := time.Now()
    c1 := make(chan string)
    c2 := make(chan string)
    go tanaka(c1)
    // go suzuki(c2)

    for {
        fmt.Println(total_work)
        if len(total_work) >= 6 {
            elapsed_time := time.Since(start_time)
            fmt.Printf("経過時間 : %v\n", elapsed_time)
            break
        }
        select {
        case unit_work1 := <-c1:
            total_work = append(total_work, unit_work1)
            fmt.Println(unit_work1)
        case unit_work2 := <-c2:
            fmt.Println(unit_work2)
            total_work = append(total_work, unit_work2)
        }
    }
}

実行結果

[]
作業
[作業]
作業
[作業 作業]
作業
[作業 作業 作業]
作業
[作業 作業 作業 作業]
作業
[作業 作業 作業 作業 作業]
作業
[作業 作業 作業 作業 作業 作業]
経過時間 : 6.0380414s

田中君と鈴木君が共同作業した場合

package main

import (
    "fmt"
    "time"
)

var total_work = []string{}

func tanaka(ch chan string) {
    for {
        time.Sleep(1 * time.Second)
        ch <- "作業"
    }
}

func suzuki(ch chan string) {
    for {
        time.Sleep(1 * time.Second)
        ch <- "作業"
    }
}

func main() {
    start_time := time.Now()
    c1 := make(chan string)
    c2 := make(chan string)
    go tanaka(c1)
    go suzuki(c2)

    for {
        fmt.Println(total_work)
        if len(total_work) >= 6 {
            elapsed_time := time.Since(start_time)
            fmt.Printf("経過時間 : %v\n", elapsed_time)
            break
        }
        select {
        case unit_work1 := <-c1:
            total_work = append(total_work, unit_work1)
            fmt.Println(unit_work1)
        case unit_work2 := <-c2:
            fmt.Println(unit_work2)
            total_work = append(total_work, unit_work2)
        }
    }
}

実行結果

[]
作業
[作業]     
作業       
[作業 作業]
作業
[作業 作業 作業]     
作業
[作業 作業 作業 作業]
作業
[作業 作業 作業 作業 作業]
作業
[作業 作業 作業 作業 作業 作業]
経過時間 : 3.0256638s