登录
首页 >  Golang >  Go问答

更新全局范围变量值

来源:stackoverflow

时间:2024-04-16 14:27:35 312浏览 收藏

对于一个Golang开发者来说,牢固扎实的基础是十分重要的,golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《更新全局范围变量值》,主要介绍了,希望对大家的知识积累有所帮助,快点收藏起来吧,否则需要时就找不到了!

问题内容

我有一个 json 文件,其中有数千条记录作为键值对,我通过将其解组为接口来读取这些记录。

var devices map[string]interface{} //globalscope in app
jsonfast:= jsoniter.configfastest
_, b, _, _ := runtime.caller(0)
dir := filepath.dir(b)

jsonfile, _ := ioutil.readfile(dir + "/devices.json")
_ = jsonfast.unmarshal(jsonfile, &devices)

在高负载下的应用程序过程中,多个 goroutine 会访问它。

现在,由于此文件每 5 分钟更新一次,因此在不重新启动应用程序的情况下,我想使此地图接口 devices 无效,以便从文件加载新数据。

在node.js中,我曾经使用delete require.cache[require.resolve("filename")],但不确定如何在go中完成此操作。

我尝试在 setinterval func(节点版本的端口)中使用互斥锁,我从这里使用它每 5 分钟后读取一次文件,但我收到此错误:

goroutine 871895 [io wait]: 这似乎意味着 goroutine 正在等待解锁以从全局变量中读取。

代码:

var m sync.Mutex
    //this function execute every 5 minute to read file and reassign to map interface.
    _ = setInterval(func() {

        jsonFile, _ := ioutil.ReadFile(dir + "/devices.json")
        m.Lock() // used this mutex as the step may cause race condition.
        _ = jsonFast.Unmarshal(jsonFile, &devices)
        m.Unlock()

    }, 5* 60 * 1000, false)

    //this initializes at the start after which the set interval execute every 5 minute to get updated data.
    jsonFile, _ := ioutil.ReadFile(dir + "/devices.json")
    _ = jsonFast.Unmarshal(jsonFile, &devices)

我应该采取什么方法来实现这一目标?或者有什么方法可以从文件中读取/更新而不是使用映射接口以避免竞争条件和 io 锁定?


解决方案


我认为这个问题与以下事实有关:当您尝试用新数据覆盖地图时,您仍然有 goroutine 从地图中读取数据。我建议您使用 sync.rwmutex 来保护它,并这样做:

type GlobalState struct {
    data map[string]interface{}
    sync.RWMutex
}

func (gs *GlobalState) Get(key string) interface{} {
    gs.RLock()
    defer gs.RUnlock()
    return gs.data[key]
}

func (gs *GlobalState) Refresh() {
    jsonFile, _ := ioutil.ReadFile(dir + "/devices.json")
    gs.Lock()
    defer gs.Unlock()
    _ = jsonFast.Unmarshal(jsonFile, &gs.data)
}

var devices GlobalState

func main() {
    t := time.NewTicker(5 * 60 * time.Second)
    for ; true; <-t.C {
         devices.Refresh()
    }
}

然后您就可以安全读取(但需要执行 devices.get(key) 而不是 devices[key])、安全写入。另外,最后它被清理了一点,因此您不必重复代码即可使计时器立即运行。

本篇关于《更新全局范围变量值》的介绍就到此结束啦,但是学无止境,想要了解学习更多关于Golang的相关知识,请关注golang学习网公众号!

声明:本文转载于:stackoverflow 如有侵犯,请联系study_golang@163.com删除
相关阅读
更多>
最新阅读
更多>
课程推荐
更多>