golang线程安全的map实现

网上找的协程安全的map都是用互斥锁或者读写锁实现的，这里用单个协程来实现下，即所有的增删查改操作都集成到一个goroutine中，这样肯定不会出现多线程并发访问的问题。

基本思路是后台启动一个长期运行的goroutine，阻塞的接受自己channel中的请求req，req分为不同的请求，比如读key，写key等，然后在这个goroutine中进行各种操作。

例： Get方法向readSig（channel）中发送一条请求。请求是readReq的指针，当run方法接收到信号时，读取底层map，将值写入readReq的value中（value是个channel），Get方法阻塞的接收value，接收到就返回value。

ps：花了两个多小时写完，只是简单的做了测试，没有深入测试，另外性能也没有测过，以后有空会深入测试一下正确性以及相比加锁的写法其性能如何。

package util
 
type smap struct {
 m      map[interface{}]interface{}
 readSig   chan *readReq
 writeSig   chan *writeReq
 lenSig    chan *lenReq
 terminateSig chan bool
 delSig    chan *delReq
 scanSig   chan *scanReq
}
 
type readReq struct {
 key  interface{}
 value interface{}
 ok  chan bool
}
 
type writeReq struct {
 key  interface{}
 value interface{}
 ok  chan bool
}
 
type lenReq struct {
 len chan int
}
 
type delReq struct {
 key interface{}
 ok chan bool
}
 
type scanReq struct {
 do     func(interface{}, interface{})
 doWithBreak func(interface{}, interface{}) bool
 brea    int
 done    chan bool
}
// NewSmap returns an instance of the pointer of safemap
func NewSmap() *smap {
 var mp smap
 mp.m = make(map[interface{}]interface{})
 mp.readSig = make(chan *readReq)
 mp.writeSig = make(chan *writeReq)
 mp.lenSig = make(chan *lenReq)
 mp.delSig = make(chan *delReq)
 mp.scanSig = make(chan *scanReq)
 go mp.run()
 return &mp
}
 
//background function to operate map in one goroutine
//this can ensure that the map is Concurrent security.
func (s *smap) run() {
 for {
 select {
 case read :=  

github地址：https://github.com/hackssssss/safemap

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


      
查看更多关于golang线程安全的map实现的详细内容...
        

          
声明：本文来自网络，不代表【好得很程序员自学网】立场，转载请注明出处：http://www.haodehen.cn/did19039