How to Implement a Thread-Safe Global Counter in a Highly Concurrent Go System?

Global Counter in a Highly Concurrent System

Question: How can I create a shared global counter that can be accessed by multiple goroutines without duplication in a highly concurrent system?

You mentioned referring to a previous question and trying to use a channel counter, which is generally not recommended for a shared counter. While it may work in some scenarios, it becomes problematic in high-concurrency situations.

Answer:

1. Atomic Package:

The most effective approach to implement a shared counter is through the atomic package provided by Go. Atomic operations ensure that changes to shared data are executed as a single indivisible action, effectively preventing race conditions.

Example:

<code class="go">import "sync/atomic"

var globalCounter int32 = 0 // Atomically updated counter

func IncrementCounter() {
    atomic.AddInt32(&globalCounter, 1) // Atomically increments the counter
}

func ReadCounter() int32 {
    return atomic.LoadInt32(&globalCounter) // Atomically reads the counter's value
}</code>

2. Synchronized Channel:

Another option is to use a synchronized channel to share the counter value. However, this approach is less efficient and introduces additional complexity.

Example:

<code class="go">var counter chan int = make(chan int, 1)

func IncrementCounter() {
    counter <- 1
}

func ReadCounter() int {
    return <-counter
}</code>

In the provided code snippet, you have implemented a thread-safe counter by utilizing a channel for value exchange. However, you should also consider thread-safe operations for resetting the value. A proper implementation would look like:

<code class="go">var addCounterChan chan int = make(chan int, 100)
var readCounterChan chan int = make(chan int, 100)

func AddCounter() {
    addCounterChan <- 1
}

func GetCount() int {
    return <-readCounterChan
}</code>

The above is the detailed content of How to Implement a Thread-Safe Global Counter in a Highly Concurrent Go System?. For more information, please follow other related articles on the PHP Chinese website!