Golang实现对map的并发读写的方法示例

 更新时间:2019-04-17 22:00:46   作者:佚名   我要评论(0)

在Golang多协程的情况下使用全局map时,如果不做线程同步,会出现panic的情况。


为了解决这个问题,通常有两种方式:

第一种是最常见的使用互斥锁或者读

在Golang多协程的情况下使用全局map时,如果不做线程同步,会出现panic的情况。

为了解决这个问题,通常有两种方式:

  • 第一种是最常见的使用互斥锁或者读写锁的方法;
  • 第二种是比较符合Golang特色的方法,启动单个协程对map进行读写,当其他协程需要读写map时,通过channel向这个协程发送信号即可。

写了一个模拟程序对map中的一项进行读或者写,后台一直运行的协程阻塞的接受读写信号,并对map进行操作,但是读操作的时候没想好怎么返回这个值。

后来想到用传引用的方式,定义结构体,第一个参数是读写的标志,第二个参数是读成功或者写成功后的值的channel,定义的channel中传结构体指针。

ps:以后验证一下效率。简单封装了一下:https://www.jb51.net/article/157620.htm

package main

import (
 "fmt"
 "strconv"
 "time"
)

type value struct {
 id int
 op int
 ret chan int
}
var dic map[int]int
var ch chan *value

func readAndWrite2Map() {
 for {
 select{
 case flag := <- ch:

  if flag.op > 0 {
  log.Printf("id: %v, op: %v, ret: %v", flag.id, flag.op, flag.op)
  dic[1] = flag.op
  flag.ret <- dic[1]
  } else if flag.op == 0 {
  log.Printf("id: %v, op: %v, ret: %v", flag.id, flag.op, dic[1])
  flag.ret <- dic[1]
  } else {
  return
  }
 }
 }
}


func out(flag, i, val int) {
 if flag == 0 {
 fmt.Println(strconv.Itoa(i) + "th goroutine read the value is ", val)
 } else {
 fmt.Println(strconv.Itoa(i)+"th goroutine write to the map ", val)
 }
}

func main() {
 dic = make(map[int]int)
 ch = make(chan *value)
 dic[1] = -1
 go readAndWrite2Map()
 for i := 0; i <= 5; i++ {
 if (i % 2) == 0 {
  go func(i int) {
   var tmp value
   for {
   tmp.op = 0
   ch <- &tmp
   out(0, i, <-tmp.ret)
   time.Sleep(time.Millisecond)
   }
  }(i)

 } else {
  go func(i int) {
   var tmp value
   for {
   tmp.op = i
   ch <- &tmp
   out(1, i, <-tmp.ret)
   time.Sleep(time.Millisecond)

   }
  }(i)
 }
 }
 time.Sleep(time.Second * 60)
}

以上就是本文的全部内容,希望对大家的学习有所帮助,也希望大家多多支持脚本之家。

您可能感兴趣的文章:

  • golang中sync.Map并发创建、读取问题实战记录

相关文章

  • Golang实现对map的并发读写的方法示例

    Golang实现对map的并发读写的方法示例

    在Golang多协程的情况下使用全局map时,如果不做线程同步,会出现panic的情况。 为了解决这个问题,通常有两种方式: 第一种是最常见的使用互斥锁或者读
    2019-04-17
  • Linux crontab定时执行Shell脚本需要执行特定的命令时解决思路

    Linux crontab定时执行Shell脚本需要执行特定的命令时解决思路

    由于一些不可抗拒的原因,项目部署后需要定时检测项目是否正常运行,否则将执行重启命令。 在具体实施过程中发现,定时器执行无误,但是重启命令无法正常启动
    2019-04-17
  • linux中shell的变量的数值计算

    linux中shell的变量的数值计算

    1、expr命令 a=123 expr $a + 10 ##加法 expr $a - 10 ##减法 expr $a \* 10 ##乘法 exp
    2019-04-17
  • ruby中并发并行与全局锁详解

    ruby中并发并行与全局锁详解

    前言 本文主要给大家介绍了关于ruby并发并行和全局锁的相关内容,分享出来供大家参考学习,下面话不多说了,来一起看看详细的介绍吧。 并发和并行 在开发时
    2019-04-17
  • Redis集群搭建全记录

    Redis集群搭建全记录

    Redis集群是一个提供在多个Redis节点间共享数据的程序集。   Redis集群中不支持处理多个keys的命令。   Redis集群通过分区来提供一定程度的可用性。在某个
    2019-04-17
  • 在EditPlus中配置Perl开发编译环境

    在EditPlus中配置Perl开发编译环境

    偶尔写写Perl脚本,用Eclipse打开太慢,NotePad吧,色彩又太单调了,NotePad++无疑是不一个不错的选择,但当要输入中文注释时,经常卡壳非常不爽,最后还是选
    2019-04-17
  • python ---lambda匿名函数介绍

    python ---lambda匿名函数介绍

    lambda特性:“一个语法,三个特性,四个用法” 一个语法 在Python中,lambda的语法是唯一的。其形式如下: lambda argument_list: expression 其中,lambda
    2019-04-17
  • 在JSP中使用formatNumber控制要显示的小数位数方法

    在JSP中使用formatNumber控制要显示的小数位数方法

    先引入标签库 <%@ taglib uri="http://java.sun.com/jsp/jstl/fmt" prefix="fmt" %> 比如保留小数点后两位小数: <fmt:formatNumber value="${xxx}" typ
    2019-04-17
  • jsp实现局部刷新页面、异步加载页面的方法

    jsp实现局部刷新页面、异步加载页面的方法

    局部刷新页面、异步加载页面方案: 1.在jsp页面需要刷新的地方增加一个控件 <div id=courseList></div> 2.新建一个jsp页面:aaa.jsp(用来放置需要刷新的内
    2019-04-17
  • 使用正则表达式去除所有html标签只保留文字

    使用正则表达式去除所有html标签只保留文字

    后台将富文本编辑器中的内容返回到前端时如果带上了标签,这时就可以利用这种方法只保留文字。 标签的格式有以下几种 1.<div class="test"></div> 2.<img />
    2019-04-17

最新评论