원자 카운터는 예를 들어갑니다

원자 카운터는 레이스 조건을 피하기 위해 여러 고루틴에서 값을 안전하게 늘리거나 감소 시키거나 읽는 데 사용됩니다. GO의 Sync/Atomic 패키지는 기본 원자 작업을 제공합니다. Atomic.int64 (Go 1.19) 또는 Atomic.addint64/loadint64와 같은 함수를 사용하는 것이 좋습니다. 1. Atomic.int64를 사용하여 1000의 최종 결과를 달성하기 위해 각각 100 번의 고리 틴과 같은 동시 자동화를 안전하게 달성하십시오. 2. GO의 이전 버전에서는 atomic.addint64 (& counter, 1) 및 atomic.loadInt64 (& coun 원자력을 보장하기 위해 Int64가 Int 대신 사용되도록해야합니다. 3.로드 및 추가는 배경이 정기적으로 방문 횟수를 인쇄하고 기본 스레드가 카운트를 증가시키는 등 모니터링 시나리오에서 카운터를 안전하게 읽고 쓰는 데 사용될 수 있습니다. 일반 int 변수가 동시에 직접 증가하는 경우 레이스 조건이 트리거되어 -GO Run -Race에 의해 감지 된 결과 및 문제가 발생합니다. 원자 카운터를 사용해야하는 시나리오는 다음과 같습니다. 간단한 증가 및 공제 점검 작업 만 수행, 고성능 및 복잡한 공유 상태가 없음; 반대로, 여러 관련 변수를 업데이트해야하거나 복합 로직을 대신 사용해야하는 경우; 요약 : 원자 카운터는 동시에 안전하고 효율적이며 잠금이없고 사용하기 쉬운 도구입니다. 유형이 int64인지 확인하는 한 비 원자 작업을 혼합하지 않고 -Race 플래그를 사용하여 문제를 감지하지 않으면 크로스 구로 카운팅 요구 사항을 올바르게 처리 할 수 있습니다.

원자 카운터는 레이스 조건을 유발하지 않고 여러 고어 라인에서 안전하게 득점, 감소 또는 값을 읽어야 할 때 사용됩니다. GO에서 sync/atomic 패키지는 atomic.Int64 , atomic.LoadInt64 등을 통해 int64 통한 atomic.AddInt64 (GO 1.19 이후 사용 가능) 또는 atomic.Value )를 제공하는 저수준 원자 연산을 제공합니다.

원자 카운터가 어떻게 작동하고 언제 사용 해야하는지 보여주는 몇 가지 실제 사례를 살펴 보겠습니다.

✅ 예제 1 : atomic.Int64 있는 간단한 원자 카운터 .int64

Go 1.19 이후 atomic.Int64 원자 카운터를 관리하는 깨끗하고 유형 안전 방법을 제공합니다.

 패키지 메인

수입 (수입)
    "FMT"
    "동조"
    "동기/원자"
    "시간"
))

func main () {
    var 카운터 atomic.int64
    var wg sync.waitgroup

    // 카운터를 100 회 증가시키는 10 개의 고 루틴을 시작합니다.
    i : = 0; I <10; 나 {
        wg.add (1)
        go func () {
            WG.Done을 연기 ()
            J : = 0; J <100; j {
                counter.add (1)
                Time.sleep (time.microsecond) // 작은 작업을 시뮬레이션하십시오
            }
        } ()
    }

    wg.wait ()
    fmt.println ( "최종 카운터 값 :", counter.load ())
}

산출:

 최종 카운터 값 : 1000

safe 안전하고 레이스가 없습니다. 뮤텍스가 필요하지 않습니다.

✅ 예제 2 : atomic.AddInt64 및 atomic.LoadInt64 사용

이전 GO 버전에 있거나 명시 적 기능을 선호하는 경우 :

 패키지 메인

수입 (수입)
    "FMT"
    "동조"
    "동기/원자"
))

func main () {
    var counter int64 // 원자 연산의 경우 int64 여야
    var wg sync.waitgroup

    i : = 0; I <5; 나 {
        wg.add (1)
        go func () {
            WG.Done을 연기 ()
            J : = 0; J <200; j {
                Atomic.addint64 (& Counter, 1)
            }
        } ()
    }

    wg.wait ()
    fmt.println ( "카운터 :", atomic.loadint64 (& counter)))
}

? 참고 : atomic 패키지는 특정 크기로 작동하고 일부 시스템에서는 32 비트 일 수 있으므로 int64 int int )를 사용해야 합니다 .

✅ 예제 3 : 읽기 (로드) 및 쓰기 (저장)가있는 원자 카운터

원자 적으로 안전하게 읽고 쓸 수도 있습니다.

 패키지 메인

수입 (수입)
    "FMT"
    "동기/원자"
    "시간"
))

func main () {
    var 방문 Atomic.int64

    // 배경 모니터를 시뮬레이션합니다
    go func () {
        을 위한 {
            Time.sleep (500 * time.millisecond)
            fmt.println ( "지금까지 방문 :", vising.load ())
        }
    } ()

    // 들어오는 요청을 시뮬레이션합니다
    i : = 0; I <10; 나 {
        방문 .add (1)
        Time.sleep (100 * time.millisecond)
    }

    Time.sleep (time.second) // 모니터를 몇 번 인쇄하십시오
}

이것은 다른 사람들로부터 글을 쓰는 동안 한 고리 틴에서 카운터를 안전하게 읽을 수있는 방법을 보여줍니다.

❌ 원자없이 어떻게됩니까?

정기적 인 int 사용하고 Goroutines에서 증가하는 경우 :

 var 카운터 int
i : = 0; I <10; 나 {
    go func () {
        J : = 0; J <100; j {
            카운터 //? 원자가 아닙니다! 레이스 조건!
        }
    } ()
}

-race 로 이것을 실행하십시오.

 run -race main.go로 이동하십시오

인종 조건 경고가 표시되며 최종 가치는 예상보다 적을 수 있습니다.

원자 카운터를 사용하는시기

원자력 카운터를 사용하십시오.

• 간단한 작업을 수행하고 있습니다 : 증가, 거부, 추가,로드, 저장.
• 성능 문제 - 원자력은 뮤 테스보다 빠릅니다.
• 복잡한 공유 상태가 필요하지 않습니다 (예 : 여러 필드를 함께 업데이트).

Atomics를 피하십시오.

• 여러 관련 변수를 업데이트하고 있습니다. 대신 sync.Mutex 사용하십시오.
• 값에 대한 복잡한 논리 또는 일관성이 필요합니다.

요약

GO의 원자 카운터는 다음과 같습니다.

• 동시 액세스에 안전합니다
• 효율적 (잠금 없음)
• atomic.Int64 또는 atomic.AddInt64 / LoadInt64 와 함께 사용하기 쉽습니다

그냥 기억하십시오 :

• int64 ( int 아님) 사용
• 원자 및 비 원자 액세스를 혼합하지 마십시오
• -race 플래그를 사용하여 문제를 감지하십시오

기본적으로, 고어 라인의 물건을 세고 있다면 atomic.Int64 에 도달하십시오. 간단하고 빠르며 정확합니다.

위 내용은 원자 카운터는 예를 들어갑니다의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!