Go에서 여러 고루틴의 값을 안전하게 읽는 방법은 무엇입니까?

여러 스레드에서 안전하게 값 읽기

Go에서 여러 스레드가 동시에 작동하는 시나리오에서는 안전한 데이터 액세스를 보장하는 것이 중요합니다. 이 문서에서는 메인 스레드가 스레드 안전성을 손상시키지 않고 작업자 스레드에서 데이터를 수집해야 하는 시나리오를 살펴봅니다.

시나리오

메인 스레드는 각각 다음에서 실행되는 여러 작업자 스레드를 생성합니다. 자체적인 고루틴을 생성하고 정기적으로 반복 횟수를 증가시킵니다. 10초마다 메인 스레드는 작업자로부터 반복 횟수를 수집하고 통합 통계를 표시하는 것을 목표로 합니다.

질문

메인 스레드는 개별 스레드가 쓰는 동안에만 읽는다는 점을 고려하면, 값에 직접 액세스하는 것이 안전합니까? 어떻게 효과적으로 구현할 수 있나요?

답변

동기화 없이 다른 스레드에서 값을 직접 읽는 것은 Go에서 정의되지 않은 동작을 나타낼 수 있으므로 본질적으로 안전하지 않습니다. 데이터 무결성을 보장하려면 어떤 형태의 동기화가 필요합니다.

구현 고려 사항

제안 솔루션은 sync.RWMutex를 활용하여 공유 데이터를 보호합니다. 작업자가 반복 횟수만큼 쓸 때 쓰기 잠금을 획득하고, 메인 스레드가 읽을 때 읽기 잠금을 획득합니다.

sync.RWMutex를 사용한 예제 코드

type Worker struct {
    iterMu sync.RWMutex
    iter   int
}

func (w *Worker) Iter() int {
    w.iterMu.RLock()
    defer w.iterMu.RUnlock()
    return w.iter
}

func (w *Worker) incIter() {
    w.iterMu.Lock()
    w.iter++
    w.iterMu.Unlock()
}

또는 다음과 같이 sync/atomic 패키지를 사용하여 스레드로부터 안전한 데이터 수정을 관리할 수 있습니다. 코드:

sync/atomic을 사용한 예제 코드

type Worker struct {
    iter int64
}

func (w *Worker) Iter() int64 {
    return atomic.LoadInt64(&w.iter)
}

func (w *Worker) incIter() {
    atomic.AddInt64(&w.iter, 1)
}

위 내용은 Go에서 여러 고루틴의 값을 안전하게 읽는 방법은 무엇입니까?의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!