本篇文章给大家分享的是有关golang value并发安全的另一种玩法是怎样的,小编觉得挺实用的,因此分享给大家学习,希望大家阅读完这篇文章后可以有所收获,话不多说,跟着小编一起来看看吧。

创新互联公司主营昌江网站建设的网络公司,主营网站建设方案,成都app开发,昌江h5小程序开发搭建,昌江网站营销推广欢迎昌江等地区企业咨询
golang value并发安全的另一种玩法,就是使用atomic.Value,看一段代码。
package main
import (
"sync"
"sync/atomic"
"time"
)
func main() {
var m atomic.Value
type Map map[string]string
m.Store(make(Map))
var mu sync.Mutex
read := func(key string) (val string) {
m1 := m.Load().(Map)
return m1[key]
}
insert := func(key, val string) {
mu.Lock()
defer mu.Unlock()
m1 := m.Load().(Map)
m2 := make(Map)
for k, v := range m1 {
m2[k] = v
}
m2[key] = val
m.Store(m2)
}
go func() {
for {
insert("k", "v")
time.Sleep(100 * time.Millisecond)
}
}()
go func() {
for {
read("k")
}
}()
time.Sleep(10 * time.Second)
}相对于读写锁,少了一些锁的争抢,不过相对的,带来了一些,内存上的开销,适用于读多写少并且变量占用内存不是特别大的情况,如果用内存存储大量数据,这个并不适合,技术上主要是常见的写时复制(copy-on-write)。
另外这个还比较适合程序配置的存储,贴一段官方的栗子
var config Value // holds current server configuration
// Create initial config value and store into config.
config.Store(loadConfig())
go func() {
// Reload config every 10 seconds
// and update config value with the new version.
for {
time.Sleep(10 * time.Second)
config.Store(loadConfig())
}
}()
// Create worker goroutines that handle incoming requests
// using the latest config value.
for i := 0; i < 10; i++ {
go func() {
for r := range requests() {
c := config.Load()
// Handle request r using config c.
_, _ = r, c
}
}()
}恩,挺好玩的。
以上就是golang value并发安全的另一种玩法是怎样的,小编相信有部分知识点可能是我们日常工作会见到或用到的。希望你能通过这篇文章学到更多知识。更多详情敬请关注创新互联行业资讯频道。