Устранение DATA RACE для разных типов данных

@asdfg15432 · Регистрация: 07.04.2015

Студворк — интернет-сервис помощи студентам

Здравствуйте. Есть рабочий код, при помощи которого можно создать string slice, защищенный от DATA RACE:

Go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
type SliceOfString struct {
    mx sync.Mutex
    pairs []string
}
 
func (c *SliceOfString) GetPairs() []string {
    defer c.mx.Unlock()
    c.mx.Lock()
    return c.pairs
}
 
func (c *SliceOfString) Store(value string) {
    isExist := false
 
    c.mx.Lock()
    for _, v := range c.pairs {
        if value == v {
            isExist = true
                        break
        }
    }
 
    if !isExist {
        c.pairs = append(c.pairs, value)
    }
    c.mx.Unlock()
}
 
func (c *SliceOfString) DeleteEntry(value string) {
    c.mx.Lock()
    for k, v := range c.pairs {
        if value == v {
            ret := make([]string, 0)
            ret = append(ret, c.pairs[:k]...)
            c.pairs = append(ret, c.pairs[k + 1:]...)
            break
        }
    }
    c.mx.Unlock()
}
 
func NewProtectedStringSlice() *SliceOfString {
    return &SliceOfString{
        pairs: []string{},
    }
}

Как можно сделать этот код более универсальным, чтоб можно было защитить от состояния гонки не только slice of string, но и типы []int, и []struct?

@moskitos80 · 01.01.2023, 23:36

Ну как вариант через дженерики:

Go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
type SliceOfString[T comparable] struct {
    mx    sync.Mutex
    pairs []T
}
 
func (c *SliceOfString[T]) GetPairs() []T {
    defer c.mx.Unlock()
    c.mx.Lock()
    return c.pairs
}
 
func (c *SliceOfString[T]) Store(value T) {
    isExist := false
 
    c.mx.Lock()
    for _, v := range c.pairs {
        if value == v {
            isExist = true
            break
        }
    }
 
    if !isExist {
        c.pairs = append(c.pairs, value)
    }
    c.mx.Unlock()
}
 
func (c *SliceOfString[T]) DeleteEntry(value T) {
    c.mx.Lock()
    for k, v := range c.pairs {
        if value == v {
            ret := make([]T, 0)
            ret = append(ret, c.pairs[:k]...)
            c.pairs = append(ret, c.pairs[k+1:]...)
            break
        }
    }
    c.mx.Unlock()
}
 
func NewProtectedStringSlice[T comparable]() *SliceOfString[T] {
    return &SliceOfString[T]{
        pairs: []T{},
    }
}

Но вообще на сколько я понял это не Go Way )) ну, т.е. так на Go не пишут.
Если верить этому чуваку: dotGo 2016 - Dave Cheney - Do not fear first class functions , то вот более правильная реализация:

Go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
package main
 
import (
    "fmt"
    "math/rand"
    "sync"
    "time"
)
 
//////////////////////////////////////////////////////////////////////
 
// По сути обертка над фоновым процессом 
type Storage[T comparable] struct {
    // канал для передачи команды (это будет ф-ция замыкание)
    option chan func(itemList map[T]struct{})
}
 
func (b *Storage[T]) Store(item T) {
    b.option <- func(itemList map[T]struct{}) {
        itemList[item] = struct{}{}
    }
}
 
func (b *Storage[T]) DeleteEntry(item T) {
    b.option <- func(itemList map[T]struct{}) {
        delete(itemList, item)
    }
}
 
func (b *Storage[T]) GetPairs() []T {
    reply := make(chan []T)
    b.option <- func(itemList map[T]struct{}) {
        r := make([]T, 0)
        for k := range itemList {
            r = append(r, k)
        }
        reply <- r
    }
    return <-reply
}
 
// фоновый процесс обращение к которому только через канал
func (b *Storage[T]) loop() {
    itemList := make(map[T]struct{})
    for optFn := range b.option {
        optFn(itemList)
    }
}
 
func (b *Storage[T]) Close() {
    close(b.option)
}
 
func NewBuf[T comparable]() *Storage[T] {
    b := &Storage[T]{
        option: make(chan func(itemList map[T]struct{})),
    }
    go b.loop()
    return b
}
 
//////////////////////////////////////////////////////////////////////
 
func main() {
    sl := NewBuf[int]()
    defer sl.Close() // теперь его необходимо закрывать!
 
    // сие для пущего рандома
    rand.Seed(time.Now().UnixNano())
    var wg sync.WaitGroup
 
    // Рандомно пишем
    wg.Add(10)
    for i := 0; i < 10; i++ {
        go func() {
            i := rand.Intn(5)
            sl.Store(i)
            fmt.Print(" +", i)
            wg.Done()
        }()
    }
 
    // Рандомно удаляем
    wg.Add(5)
    for i := 0; i < 5; i++ {
        go func() {
            i := rand.Intn(5)
            sl.DeleteEntry(i)
            fmt.Print(" -", i)
            wg.Done()
        }()
    }
 
    wg.Wait()
    // смотрим что осталось
    fmt.Printf("\n%v\n", sl.GetPairs())
}

Новые блоги и статьи Все статьи Все блоги /
Модульный подход на примере F# DevAlt 06.03.2026 В блоге дяди Боба наткнулся на такое определение: В этой книге («Подход, основанный на вариантах использования») Ивар утверждает, что архитектура программного обеспечения — это структуры,. . .	Управление камерой с помощью скрипта OrbitControls.js на Three.js: Вращение, зум и панорамирование 8Observer8 05.03.2026 Содержание блога Финальная демка в браузере работает на Desktop и мобильных браузерах. Итоговый код: orbit-controls-threejs-js. zip. Сканируйте QR-код на мобильном. Вращайте камеру одним пальцем,. . .	SDL3 для Web (WebAssembly): Синхронизация спрайтов SDL3 и тел Box2D 8Observer8 04.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-sync-physics-sprites-sdl3-c. zip На первой гифке отладочные линии отключены, а на второй включены:. . .	SDL3 для Web (WebAssembly): Идентификация объектов на Box2D v3 - использование userData и событий коллизий 8Observer8 02.03.2026 Содержание блога Финальная демка в браузере. Итоговый код: finish-collision-events-sdl3-c. zip Сканируйте QR-код на мобильном и вы увидите, что появится джойстик для управления главным героем. . . .
Реалии Hrethgir 01.03.2026 Нет, я не закончил до сих пор симулятор. Эта задача сложнее. Не получилось уйти в плавсостав, но оно и к лучшему, возможно. Точнее получалось - но сварщиком в палубную команду, а это значит, в моём. . .	Ритм жизни kumehtar 27.02.2026 Иногда приходится жить в ритме, где дел становится всё больше, а вовлечения в происходящее — всё меньше. Плотный график не даёт вниманию закрепиться ни на одном событии. Утро начинается с быстрых,. . .	SDL3 для Web (WebAssembly): Сборка библиотек: SDL3, Box2D, FreeType, SDL3_ttf, SDL3_mixer и SDL3_image из исходников с помощью CMake и Emscripten 8Observer8 27.02.2026 Недавно вышла версия 3. 4. 2 библиотеки SDL3. На странице официальной релиза доступны исходники, готовые DLL (для x86, x64, arm64), а также библиотеки для разработки под Android, MinGW и Visual Studio. . . .	SDL3 для Web (WebAssembly): Реализация движения на Box2D v3 - трение и коллизии с повёрнутыми стенами 8Observer8 20.02.2026 Содержание блога Box2D позволяет легко создать главного героя, который не проходит сквозь стены и перемещается с заданным трением о препятствия, которые можно располагать под углом, как верхнее. . .

Устранение DATA RACE для разных типов данных

Решение