commons_go/util
3
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

ing

Browse Source
This commit is contained in:
crusader 2017-11-27 18:57:43 +09:00
parent 2122e939e8
commit f3b7cb5bdf
1 changed files with 38 additions and 29 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

67
context/attributes.go
View File

@ -2,66 +2,75 @@ package context
import "sync" import "sync"
type AttributeManager interface { type Attributes interface {
Init() initialize()
SetAttribute(key string, value interface{}) Set(key string, value interface{})
GetAttribute(key string) (value interface{}) Get(key string) (value interface{})
RemoveAttribute(key string) Remove(key string)
Contains(key string) (exist bool) Contains(key string) (exist bool)
Destroy() Destroy()
} }
type AttributeManagers struct { func NewAttributes(parent Attributes) Attributes {
Parent AttributeManager am := &attributes{
attributes map[string]interface{} Parent: parent,
}
am.initialize()
return am
}
type attributes struct {
Parent Attributes
values map[string]interface{}
mtx sync.RWMutex mtx sync.RWMutex
} }
func (am *AttributeManagers) Init() { func (am *attributes) initialize() {
if nil != am.Parent { if nil != am.Parent {
am.Parent.Init() am.Parent.initialize()
} }
if nil == am.attributes { if nil == am.values {
am.Destroy() am.Destroy()
} }
am.attributes = make(map[string]interface{}) am.values = make(map[string]interface{})
} }
func (am *AttributeManagers) SetAttribute(key string, value interface{}) { func (am *attributes) Set(key string, value interface{}) {
am.checkInitialized() am.checkInitialized()
am.mtx.Lock() am.mtx.Lock()
defer am.mtx.Unlock() defer am.mtx.Unlock()
am.attributes[key] = value am.values[key] = value
} }
func (am *AttributeManagers) GetAttribute(key string) (value interface{}) { func (am *attributes) Get(key string) (value interface{}) {
am.checkInitialized() am.checkInitialized()
am.mtx.RLock() am.mtx.RLock()
defer am.mtx.RUnlock() defer am.mtx.RUnlock()
if _, ok := am.attributes[key]; ok { if _, ok := am.values[key]; ok {
return am.attributes[key] return am.values[key]
} }
if nil == am.Parent { if nil == am.Parent {
return nil return nil
} }
return am.Parent.GetAttribute(key) return am.Parent.Get(key)
} }
func (am *AttributeManagers) RemoveAttribute(key string) { func (am *attributes) Remove(key string) {
am.checkInitialized() am.checkInitialized()
am.mtx.Lock() am.mtx.Lock()
defer am.mtx.Unlock() defer am.mtx.Unlock()
if _, ok := am.attributes[key]; ok { if _, ok := am.values[key]; ok {
delete(am.attributes, key) delete(am.values, key)
return return
} }
@ -69,16 +78,16 @@ func (am *AttributeManagers) RemoveAttribute(key string) {
return return
} }
am.Parent.RemoveAttribute(key) am.Parent.Remove(key)
} }
func (am *AttributeManagers) Contains(key string) (exist bool) { func (am *attributes) Contains(key string) (exist bool) {
am.checkInitialized() am.checkInitialized()
am.mtx.RLock() am.mtx.RLock()
defer am.mtx.RUnlock() defer am.mtx.RUnlock()
if _, ok := am.attributes[key]; ok { if _, ok := am.values[key]; ok {
return true return true
} }
@ -88,9 +97,9 @@ func (am *AttributeManagers) Contains(key string) (exist bool) {
return am.Parent.Contains(key) return am.Parent.Contains(key)
} }
func (am *AttributeManagers) Destroy() { func (am *attributes) Destroy() {
if nil != am.attributes { if nil != am.values {
am.attributes = nil am.values = nil
} }
if nil != am.Parent { if nil != am.Parent {
@ -98,8 +107,8 @@ func (am *AttributeManagers) Destroy() {
} }
} }
func (am *AttributeManagers) checkInitialized() { func (am *attributes) checkInitialized() {
if nil == am.attributes { if nil == am.values {
panic("Attribute Manager: must be initialized") panic("Attribute Manager: must be initialized")
} }
} }