Rumah >pembangunan bahagian belakang >Golang >Bagaimana untuk menyelesaikan masalah akses cache serentak dalam bahasa Go?
Bagaimana untuk menyelesaikan masalah akses cache serentak dalam bahasa Go?
Dalam pengaturcaraan serentak, caching ialah strategi pengoptimuman yang biasa digunakan. Dengan menyimpan data dalam cache, akses kerap kepada storan asas boleh dikurangkan dan prestasi sistem dipertingkatkan. Walau bagaimanapun, dalam berbilang senario akses serentak, masalah akses cache serentak sering dihadapi, seperti persaingan cache, penembusan cache, dsb. Artikel ini akan memperkenalkan cara menyelesaikan masalah akses cache serentak dalam bahasa Go dan memberikan contoh kod khusus.
package main import ( "fmt" "sync" ) var cache map[string]string var mutex sync.Mutex func main() { cache = make(map[string]string) var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go func(index int) { defer wg.Done() key := fmt.Sprintf("key-%d", index) value, ok := getFromCache(key) if ok { fmt.Printf("Read from cache: %s -> %s ", key, value) } else { value = expensiveCalculation(key) setToCache(key, value) fmt.Printf("Write to cache: %s -> %s ", key, value) } }(i) } wg.Wait() } func getFromCache(key string) (string, bool) { mutex.Lock() defer mutex.Unlock() value, ok := cache[key] return value, ok } func setToCache(key string, value string) { mutex.Lock() defer mutex.Unlock() cache[key] = value } func expensiveCalculation(key string) string { // 模拟耗时操作 return fmt.Sprintf("value-%s", key) }
Dalam kod di atas, kami menambah mutex sebelum dan selepas getFromCache
dan setToCache Operasi kunci pengecualian memastikan bahawa hanya satu utas boleh membaca dan menulis ke cache pada masa yang sama, dengan itu menyelesaikan masalah akses cache serentak. <code>getFromCache
和setToCache
操作前后加上了互斥锁,确保了同一时刻只有一个线程可以对缓存进行读写,从而解决了并发缓存访问问题。
package main import ( "fmt" "sync" ) var cache map[string]string var rwmutex sync.RWMutex func main() { cache = make(map[string]string) var wg sync.WaitGroup for i := 0; i < 10; i++ { wg.Add(1) go func(index int) { defer wg.Done() key := fmt.Sprintf("key-%d", index) value, ok := getFromCache(key) if ok { fmt.Printf("Read from cache: %s -> %s ", key, value) } else { value = expensiveCalculation(key) setToCache(key, value) fmt.Printf("Write to cache: %s -> %s ", key, value) } }(i) } wg.Wait() } func getFromCache(key string) (string, bool) { rwmutex.RLock() defer rwmutex.RUnlock() value, ok := cache[key] return value, ok } func setToCache(key string, value string) { rwmutex.Lock() defer rwmutex.Unlock() cache[key] = value } func expensiveCalculation(key string) string { // 模拟耗时操作 return fmt.Sprintf("value-%s", key) }
在上述代码中,我们使用了读写锁sync.RWMutex
,在读操作前后加上了读锁RLock
,在写操作前后加上了写锁Lock
mutex lock ialah ia menyekat kedua-dua operasi baca dan operasi tulis, mengakibatkan prestasi serentak yang lemah. Menggunakan kunci baca-tulis membolehkan berbilang utas membaca cache pada masa yang sama, tetapi hanya satu utas boleh melakukan operasi tulis, meningkatkan prestasi serentak. Berikut ialah contoh kod yang menggunakan kunci baca-tulis untuk menyelesaikan masalah akses cache serentak:
rrreee
Dalam kod di atas, kami menggunakan kunci baca-tulisRLLock
, menambah kunci tulis Lock
sebelum dan selepas operasi tulis, supaya kami boleh membenarkan berbilang urutan membaca cache pada masa yang sama, tetapi hanya satu utas boleh melakukan operasi tulis, sekali gus meningkatkan prestasi konkurensi. 🎜🎜Dengan menggunakan kunci mutex atau kunci baca-tulis, kami boleh menyelesaikan masalah akses cache serentak dalam bahasa Go dengan berkesan. Dalam aplikasi sebenar, mekanisme kunci yang sesuai boleh dipilih mengikut keperluan khusus untuk memastikan keselamatan dan prestasi akses serentak. 🎜🎜(bilangan perkataan: 658)🎜Atas ialah kandungan terperinci Bagaimana untuk menyelesaikan masalah akses cache serentak dalam bahasa Go?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!