Golang заканчивает goroutine внутри для цикла с временем ожидания - PullRequest
Новая
       32

Golang заканчивает goroutine внутри для цикла с временем ожидания

0 голосов
/ 24 октября 2019

У меня есть программа, которая должна проходить через вложенный массив. После каждого элемента массива for loop должен подождать время и затем перейти к следующему элементу.

Программа должна немедленно остановиться, если булево значение передается в канал, переданный этой программе с помощью оператора select. ,Немедленно означает остановить цикл for для вложенного массива и остановить время ожидания / длительности для обработки следующего элемента.

На данный момент у меня есть что-то вроде следующего: 

package main

import (
    "fmt"
    "time"
)

type listEntry struct {
    text     string
    duration time.Duration
}

func timeTrack(start time.Time, name string) {
    elapsed := time.Since(start)
    fmt.Printf("%s took %s\n", name, elapsed)
}

func main() {
    defer timeTrack(time.Now(), "move")
    fmt.Println("-- START --")
    var list [2][10]*listEntry

    var sublist [10]*listEntry
    sublist[0] = &listEntry{"0.0.", time.Duration(2 * time.Second)}
    sublist[1] = &listEntry{"0.1.", time.Duration(3 * time.Second)}
    sublist[2] = &listEntry{"0.2.", time.Duration(4 * time.Second)}
    sublist[3] = &listEntry{"0.3.", time.Duration(9 * time.Second)}
    sublist[4] = &listEntry{"0.4.", time.Duration(32 * time.Second)}
    sublist[5] = &listEntry{"0.5.", time.Duration(21 * time.Second)}
    sublist[6] = &listEntry{"0.6.", time.Duration(19 * time.Second)}
    sublist[7] = &listEntry{"0.7.", time.Duration(11 * time.Second)}
    sublist[8] = &listEntry{"0.8.", time.Duration(9 * time.Second)}
    sublist[9] = &listEntry{"0.9.", time.Duration(6 * time.Second)}

    list[0] = sublist

    var sublist2 [10]*listEntry
    sublist2[0] = &listEntry{"1.0.", time.Duration(2 * time.Second)}
    sublist2[1] = &listEntry{"1.1.", time.Duration(20 * time.Second)}
    sublist2[2] = &listEntry{"1.2.", time.Duration(12 * time.Second)}
    sublist2[3] = &listEntry{"1.3.", time.Duration(9 * time.Second)}
    sublist2[4] = &listEntry{"1.4.", time.Duration(32 * time.Second)}
    sublist2[5] = &listEntry{"1.5.", time.Duration(21 * time.Second)}
    sublist2[6] = &listEntry{"1.6.", time.Duration(19 * time.Second)}
    sublist2[7] = &listEntry{"1.7.", time.Duration(11 * time.Second)}
    sublist2[8] = &listEntry{"1.8.", time.Duration(9 * time.Second)}
    sublist2[9] = &listEntry{"1.9.", time.Duration(6 * time.Second)}

    list[1] = sublist2

    finish := make(chan bool)
    go move(list, finish)
    time.Sleep(10 * time.Second)
    fmt.Println("-> FINISH CHAN")
    // finish <- true
    close(finish)
    time.Sleep(1 * time.Second)
    fmt.Println("-- FINISHED --")
}

func move(list [2][10]*listEntry, finish chan bool) {
    for index := 0; index < len(list); index++ {
        fmt.Printf("List: %d\n", index)
        for sublistIndex := 0; sublistIndex < len(list[index]); sublistIndex++ {
            fmt.Printf("Sublist: %d.%d - %v\n", index, sublistIndex, list[index][sublistIndex].duration)
            select {
            case <-finish:
                fmt.Println("move: finish 2")
                return
            case <-time.After(list[index][sublistIndex].duration):
                continue
            }
            // time.Sleep(list[index][sublistIndex].duration)
        }
    }
}

Ссылка на игровую площадку Go: Go Playground Пример кода

Выходное значение выглядит следующим образом: 

-- START --
Go ...
List: 0
Sublist: 0.0 - 2s
Sublist: 0.1 - 3s
Sublist: 0.2 - 4s
Sublist: 0.3 - 9s
-> FINISH CHAN
move: finish 2
-- FINISHED --
move took 11.0005366s

Таким образом, время выполнения в основном соответствует ожидаемому времени. Ждем в основной ветке. Отлично!

Но реализация выглядит не очень красиво. Ребята, у вас есть хорошая идея структурировать код более элегантным способом? Первый for loop и первый оператор выбора вообще необходимы?

...