sync

README

线程安全map

说明

• 使用ConcurrentMap实现，Go1.9版本改用sync/syncmap包实现
• map中key与value使用指针，请实现HashBytes与Equals接口

代码示例

package main

import (
	"fmt"

	"git.oschina.net/cloudzone/smartgo/stgcommon/sync"
)

func main() {
	demoInt()
	demoStruct()
}

func demoInt() {
	m := sync.NewMap()

	previou, err := m.Put(1, 10) //return nil, nil
	fmt.Println("put val:", previou, err)
	previou, err = m.PutIfAbsent(1, 20) //return 10, nil
	fmt.Println("put if absent val:", previou, err)

	val, err := m.Get(1) //return 10, nil
	fmt.Println("get val:", val, err)
	s := m.Size() //return 1
	fmt.Println("map size:", s)

	err = m.PutAll(map[interface{}]interface{}{
		1: 100,
		2: 200,
	})
	fmt.Println("putalll:", err)

	ok, err := m.RemoveEntry(1, 100) //return true, nil
	fmt.Println("removeEntry:", ok, err)

	previou, err = m.Replace(2, 20) //return 200, nil
	fmt.Println("replace:", previou, err)
	ok, err = m.CompareAndReplace(2, 200, 20) //return false, nil
	fmt.Println("CompareAndReplace:", previou, err)

	previou, err = m.Remove(2) //return 20, nil
	fmt.Println("remove:", previou, err)

	m.Clear()
	s = m.Size() //return 0
	fmt.Println("clear map size:", s)
}

type user struct {
	id   string
	Name string
}

func (u *user) HashBytes() []byte {
	return []byte(u.id)
}

func (u *user) Equals(v2 interface{}) (equal bool) {
	u2, ok := v2.(*user)
	return ok && u.id == u2.id
}

type userInfo struct {
	id     string
	Name   string
	Street string
	Age    int
}

func (u *userInfo) HashBytes() []byte {
	return []byte(u.id)
}

func (u *userInfo) Equals(v2 interface{}) (equal bool) {
	u2, ok := v2.(*userInfo)
	return ok && u.id == u2.id
}

func demoStruct() {
	m := sync.NewMap()

	k := &user{id: "0001", Name: "jerrylou"}
	v := &userInfo{id: "0001", Name: "jerrylou", Street: "tianfusanjie", Age: 16}
	previou, err := m.Put(k, v)
	fmt.Println("put val:", previou, err)

	previou, err = m.PutIfAbsent(k, v)
	fmt.Println("put if absent val:", previou, err)

	val, err := m.Get(k)
	fmt.Println("get val:", val, err)
	s := m.Size()
	fmt.Println("map size:", s)

	err = m.PutAll(map[interface{}]interface{}{
		k: v,
		&user{id: "0002", Name: "jack"}: &userInfo{id: "0002", Name: "jack", Street: "tianfusanjie", Age: 26},
	})
	fmt.Println("putalll:", err)

	ok, err := m.RemoveEntry(k, v)
	fmt.Println("removeEntry:", ok, err)

	previou, err = m.Replace(&user{id: "0002", Name: "jack"}, &userInfo{id: "0002", Name: "jack wang", Street: "tianfusanjie", Age: 28})
	fmt.Println("replace:", previou, err)

	previou, err = m.Remove(&user{id: "0002", Name: "jack"})
	fmt.Println("remove:", previou, err)

	m.Clear()
	s = m.Size()
	fmt.Println("clear map size:", s)
}

Documentation

Index

• type Cond
  • func NewCond() *Cond
  • func (c *Cond) Broadcast()
  • func (c *Cond) Close()
  • func (c *Cond) Signal()
  • func (c *Cond) Wait()
  • func (c *Cond) WaitTimeout(timeout time.Duration)
• type Map
  • func NewMap() *Map
  • func NewMapFromOtherMap(m map[interface{}]interface{}) *Map
• type Notify
  • func NewNotify() *Notify
  • func (n *Notify) Close()
  • func (n *Notify) Signal()
  • func (n *Notify) Wait()
  • func (n *Notify) WaitTimeout(timeout time.Duration)

Types

type Cond

type Cond struct {
	// contains filtered or unexported fields
}

Cond 条件变量，同sync.Cond，增加WaitTimeout

func NewCond

func NewCond() *Cond

NewCond returns a new Cond.

func (*Cond) Broadcast

func (c *Cond) Broadcast()

Broadcast wakes all goroutines waiting on c.

func (*Cond) Close

func (c *Cond) Close()

Close close done chan

func (*Cond) Signal

func (c *Cond) Signal()

Signal wakes one goroutine waiting on c, if there is any.

func (*Cond) Wait

func (c *Cond) Wait()

Wait cannot return unless awoken by Broadcast or Signal.

func (*Cond) WaitTimeout

func (c *Cond) WaitTimeout(timeout time.Duration)

WaitTimeout cannot return unless awoken by Broadcast or Signal, timeout.

type Map

type Map struct {
	// 使用ConcurrentMap，Go1.9版本改用sync/syncmap包实现
	*concurrent.ConcurrentMap
}

Map 线程安全的map

func NewMap

func NewMap() *Map

NewMap 返回线程安全map

func NewMapFromOtherMap

func NewMapFromOtherMap(m map[interface{}]interface{}) *Map

NewMapFromOtherMap 返回线程安全map

type Notify

type Notify struct {
	// contains filtered or unexported fields
}

Notify 唤醒Goroutine

func NewNotify

func NewNotify() *Notify

NewNotify create notfiy

func (*Notify) Close

func (n *Notify) Close()

Close close c

func (*Notify) Signal

func (n *Notify) Signal()

Signal wakes one goroutine waiting on c, if there is any.

func (*Notify) Wait

func (n *Notify) Wait()

Wait cannot return unless awoken by Signal.

func (*Notify) WaitTimeout

func (n *Notify) WaitTimeout(timeout time.Duration)

WaitTimeout cannot return unless awoken by Signal or timeout.