Библиотека Go для собеса | вопросы с собеседований

💬 Что такое атомарная операция и для чего предназначен пакет atomic?



Атомарная операция выполняется за один шаг относительно других потоков или, в контексте Go, других горутин. Это означает, что атомарную операцию нельзя прервать в середине ее работы.



Стандартная библиотека Go содержит пакет atomic, который в некоторых простых случаях может помочь избежать использования мьютекса. С помощью него мы получаем доступ к атомарным счетчикам из нескольких горутин, не имея проблем с синхронизацией и не беспокоясь о race condition.



Как показано в примере ниже, при использовании атомарной переменной во избежание race condition все операции чтения и записи атомарной переменной должны выполняться с помощью функций, предоставляемых пакетом atomic.

package main

import (

    "fmt"

    "sync"

    "sync/atomic"

)



type atomCounter struct {

    val int64 }

Это структура для хранения требуемой атомарной переменной int64.

func (c *atomCounter) Value() int64 {

    return atomic.LoadInt64(&c.val)

}

Это вспомогательная функция, которая возвращает текущее значение атомарной переменной int64, используя atomic.LoadInt64().

func main() {

    X := 100

    Y := 4

    var waitGroup sync.WaitGroup

    counter := atomCounter{}

    for i := 0; i < X; i++ {

Мы создаем множество горутин, которые изменяют общую переменную. Благодаря использованию пакета atomic для работы с общей переменной мы получаем простой способ избежать race condition при изменении ее значения.

        waitGroup.Add(1)

        go func(no int) {

            defer waitGroup.Done()

            for i := 0; i < Y; i++ {

                atomic.AddInt64(&counter.val, 1)

            }

Функция atomic.AddInt64() безопасно изменяет значение поля val структуры counter.

            }(i) 

        }



        waitGroup.Wait()

        fmt.Println(counter.Value())

}