Получить блокировку, синхронизированную по времени блокировки - PullRequest
Новая
       51

Получить блокировку, синхронизированную по времени блокировки

0 голосов
/ 12 декабря 2018

У меня есть программа с goroutine, которую мы будем называть mainRoutine, которая блокирует ресурс, с другой стороны, другие goroutines из fired, которые мы будем называть goroutine-0 goroutine-1 goroutine-2 .... эту процедуру пытаются получитьблокировка, после остановки mainRoutine мне нужна моя другая goroutine для получения блокировки синхронизированным способом, я имею в виду, что я хочу goroutine-0 затем goroutine-1 ... То, что я сделал для решения этой проблемы, этоотрезок времени. Время, которое заполняется значением time.Now (), в которое была запущена программа, и использовала sync.Cond.Вот пример кода, чтобы проиллюстрировать: 

package main

import (
    "fmt"
    "sync"
    "time"
)

func condition(myTime time.Time, timeSlice []time.Time) bool {
    for _, v := range timeSlice {
        if myTime.After(v) {
            return false
        }
    }
    return true
}

func removeFromSlice(myTime time.Time, timeSlice []time.Time) {
    var place int
    for i, v := range timeSlice {
        if myTime.Equal(v) {
            place = i
            break
        }
    }

    timeSlice = append(timeSlice[:place], timeSlice[place+1:]...)
}

func main() {
    var m sync.Mutex
    c := sync.NewCond(&m)

    c.L.Lock()
    fmt.Println("Locker locked")
    go func() {
        time.Sleep(time.Second * 1)

        c.L.Unlock()
        fmt.Println("Locker unlocked")
    }()

    var wg sync.WaitGroup
    var timeSlice []time.Time
    wg.Add(100)

    for i := 0; i < 100; i++ {
        now := time.Now()
        timeSlice = append(timeSlice, now)
        time.Sleep(time.Nanosecond * 1) // ensure there's at leat 1 nanosec of diff between 2 time.Now
        go func(i int, myTime time.Time) {
            fmt.Printf("Before %d %d\n", i, myTime.Unix())
            c.L.Lock()
            for !condition(myTime, timeSlice) {
                c.Wait()
            }
            c.L.Unlock()
            removeFromSlice(myTime, timeSlice)
            c.Broadcast()
            wg.Done()
            fmt.Printf("After done %d\n", i)
        }(i, now)
    }
    wg.Wait()

    fmt.Println("Hello, playground")
}

Я не думаю, что это правильный способ делать такие вещи, которые кажутся действительно глупыми, есть ли лучший способ?

- РЕДАКТИРОВАТЬ- После ответа @Vorsprung я думаю, что лучший подход в моем случае - создать фрагмент func, который всегда вызывает 1-й элемент фрагмента 

package main

import (
    "fmt"
    "sync"
)

func makeFunc(id int) func() {
    return func() {
        fmt.Printf("called %d\n", id)
    }
}

func main() {
    var wg sync.WaitGroup
    var funcSlice []func()
    var m sync.Mutex

    for i := 0; i < 5; i++ {
        funcSlice = append(funcSlice, makeFunc(i))
        wg.Add(1)
        go func() {
            defer wg.Done()
            m.Lock()
            defer m.Unlock()
            funcSlice[0]()
            funcSlice = funcSlice[1:]
        }()
    }
    wg.Wait()
    fmt.Println("finished")
}

1 Ответ

0 голосов
/ 12 декабря 2018

Дайте goroutines внутренний идентификатор, а затем заставьте их вызывать друг друга по порядку.Пример того, как это может работать ниже 

package main

import (
    "fmt"
    "sync"
)

func main() {
    var wg sync.WaitGroup
    var c [5]chan int
    for i := range c {
        c[i] = make(chan int)
        wg.Add(1)
        go func(id int) {
            defer wg.Done()
            f := <-c[id]
            fmt.Println("called from ", f, ".  My id ", id)
            if id < 4 {
                fmt.Println(id+1, " next")
                c[id+1] <- id
            }
            fmt.Println("ending ", id)
        }(i)
    }
    c[0] <- 99

    wg.Wait()
    fmt.Println("bye")
}

https://play.golang.org/p/psF8ISodJU_3

...