先輩からお題が出されたので、忘れないように記載しておく

お題

Sleep関数を2秒以内に50回実施して、停止した最大、最小、平均ミリ秒数を表示してください

package main

import (
    "math/rand"
    "time"
    "fmt"
)

 func Sleep(i chan int) {
    r := rand.Intn(500) + 100 // 止まるミリ秒数の定義.ランダム数
    time.Sleep(time.Duration(r) * time.Millisecond) // 止まるミリ秒数の定義
    fmt.Printf("I Slept %d millseconds. \n", r)
    i <- r
}

func main() {
    rand.Seed(time.Now().UnixNano())
    // Sleep関数を2秒以内に50回実施して、停止した最大、最小、平均ミリ秒数を表示してください
}

自分の回答

package main

import (
    "math/rand"
    "time"
    "fmt"
    "sync"
    "strconv"
)

func Sleep(i chan int) {
    r := rand.Intn(500) + 100 // 止まるミリ秒数の定義.ランダム数
    time.Sleep(time.Duration(r) * time.Millisecond) // 止まるミリ秒数の定義
    fmt.Printf("I Slept %d millseconds. \n", r)
    i <- r
}

func max(a []int) int {
    max := a[0]
    for _, i := range a {
        if i > max {
            max = i
        }
    }
    return max
}

func min(a []int) int {
    min := a[0]
    for _, i := range a {
        if i < min {
            min = i
        }
    }
    return min
}

func avg(a []int) int {
    len := len(a)
    sum := 0
    for _, i := range a {
        sum += i
    }
    return sum / len
}

func main() {
    rand.Seed(time.Now().UnixNano())
    // Sleep関数を2秒以内に50回実施して、停止した最大、最小、平均ミリ秒数を表示してください

    // チャネルを用意
    ch := make(chan int)
    finished := make(chan int)

    // Sleep関数を50回、並列処理で実行
    wg := &sync.WaitGroup{}
    for i := 0 ; i < 50 ; i++ {
        wg.Add(1)
        go func() {
            Sleep(ch)
            wg.Done()
        }()
    }

    // 全ての並行処理が完了するのを待つ、完了次第、本スレッドに通知
    go func(){
        wg.Wait()
        finished <- 1
    }()

    // 本スレッドで、並列で実行した結果を受け取る
    results := []int{}
    LOOP:
        for {
            select {
            case v := <- ch:
                results = append(results, v)
            case <- finished:
                break LOOP
            }
        }

    // 結果の集計
    fmt.Println("件数：" + strconv.Itoa(len(results)))
    fmt.Println("最大：" + strconv.Itoa(max(results)))
    fmt.Println("最小：" + strconv.Itoa(min(results)))
    fmt.Println("平均：" + strconv.Itoa(avg(results)))
}

実行結果

件数：50
最大：573
最小：108
平均：311

「ここはこうした方が良い」など、ありましたらコメントいただければ幸いです。

別の方法も考えてみた

チャネルに結果を溜め込んで、完了後に取り出して集計する、今回のはこれで十分っぽい。

package main

import (
    "math/rand"
    "time"
    "fmt"
    "sync"
    "strconv"
)

func Sleep(i chan int) {
    r := rand.Intn(500) + 100 // 止まるミリ秒数の定義.ランダム数
    time.Sleep(time.Duration(r) * time.Millisecond) // 止まるミリ秒数の定義
    fmt.Printf("I Slept %d millseconds. \n", r)
    i <- r
}

func max(a []int) int {
    max := a[0]
    for _, i := range a {
        if i > max {
            max = i
        }
    }
    return max
}

func min(a []int) int {
    min := a[0]
    for _, i := range a {
        if i < min {
            min = i
        }
    }
    return min
}

func avg(a []int) int {
    l := len(a)
    sum := 0
    for _, i := range a {
        sum += i
    }
    return sum / l
}

func main() {
    rand.Seed(time.Now().UnixNano())
    // Sleep関数を2秒以内に50回実施して、停止した最大、最小、平均ミリ秒数を表示してください

    // チャネルを用意
    ch := make(chan int, 50)

    // Sleep関数を50回、並列処理で実行
    wg := &sync.WaitGroup{}
    for i := 0 ; i < 50 ; i++ {
        wg.Add(1)
        go func() {
            Sleep(ch)
            wg.Done()
        }()
    }

    // 全ての並行処理が完了するのを待つ
    wg.Wait()
    close(ch)

    // 並列で実行した結果を受け取る
    results := []int{}
    for v := range ch {
        results = append(results, v)
    }

    // 結果の集計
    fmt.Println("件数：" + strconv.Itoa(len(results)))
    fmt.Println("最大：" + strconv.Itoa(max(results)))
    fmt.Println("最小：" + strconv.Itoa(min(results)))
    fmt.Println("平均：" + strconv.Itoa(avg(results)))
}