Ясен обнови решението на 16.11.2014 19:18 (преди над 3 години)
+//Written by Yasen Visulchev for FMI/GOLANG
+/*
+{
+ "FacultyNumber": 81236
+ "FirstName": "Yasen"
+ "LastName": "Visulchev"
+ "AcademicYear": 2
+ "Master": false
+}
+*/
+//16/11/2014
+//how to channel
+package main
+
+import (
+ "errors"
+ "reflect"
+ "strconv"
+ "strings"
+ "sync"
+ "time"
+)
+
+//ExpireMap implements a map with expiring keys.
+type ExpireMap struct {
+ dict map[string]interface{}
+ expireDict map[string]time.Time
+ rwm sync.RWMutex
+ echan chan string
+ trulyDead bool
+}
+
+//Returns a brand new ExpireMap, not truly dead!
+func NewExpireMap() *ExpireMap {
+ var em ExpireMap
+ em.dict = make(map[string]interface{})
+ em.expireDict = make(map[string]time.Time)
+ em.echan = make(chan string, 1)
+ em.trulyDead = false
+ return &em
+}
+
+//Adds a new key to the ExpireMap, with an expiration duration.
+func (em *ExpireMap) Set(key string, value interface{}, expire time.Duration) {
+ em.rwm.Lock()
+ defer em.rwm.Unlock()
+ em.dict[key] = value
+ em.expireDict[key] = time.Now().Add(expire)
+ go func(em *ExpireMap, key string) {
+ time.Sleep(expire)
+ if _, ok := em.Get(key); ok && !em.trulyDead {
+ em.echan <- key
+ em.Delete(key)
+ }
+ }(em, key)
+}
+
+//Fetches value from the ExpireMap.
+func (em *ExpireMap) Get(key string) (interface{}, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ i, ok := em.dict[key]
+ return i, ok
+}
+
+//Fetches integer value from the ExpireMap.
+func (em *ExpireMap) GetInt(key string) (int, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ if i, ok := em.dict[key]; ok && (reflect.TypeOf(i) == reflect.TypeOf(1)) {
+ return i.(int), ok
+ }
+ return 0, false
+}
+
+//Fetches float64 value from the ExpireMap.
+func (em *ExpireMap) GetFloat64(key string) (float64, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ var check float64
+ if i, ok := em.dict[key]; ok && (reflect.TypeOf(i) == reflect.TypeOf(check)) {
+ return i.(float64), ok
+ }
+ return 0, false
+}
+
+//Fetches string value from the ExpireMap.
+func (em *ExpireMap) GetString(key string) (string, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ if i, ok := em.dict[key]; ok && (reflect.TypeOf(i) == reflect.TypeOf("")) {
+ return i.(string), ok
+ }
+ return "", false
+}
+
+//Fetches boolean value from the ExpireMap.
+func (em *ExpireMap) GetBool(key string) (bool, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ if i, ok := em.dict[key]; ok && (reflect.TypeOf(i) == reflect.TypeOf(false)) {
+ return i.(bool), ok
+ }
+ return false, false
+}
+
+//Returns the expiration time of the key.
+func (em *ExpireMap) Expires(key string) (time.Time, bool) {
+ em.rwm.RLock()
+ defer em.rwm.RUnlock()
+ if i, ok := em.expireDict[key]; ok {
+ return i, ok
+ }
+ var a time.Time
+ return a, false
+}
+
+//Deletes key and values from all structures of ExpireMap.
+func (em *ExpireMap) Delete(key string) {
+ em.rwm.Lock()
+ defer em.rwm.Unlock()
+ delete(em.dict, key)
+ delete(em.expireDict, key)
+}
+
+//States whether ExpireMap contains specified key.
+func (em *ExpireMap) Contains(key string) bool {
+ _, ok := em.dict[key]
+ return ok
+}
+
+//Returns the size of the ExpireMap.
+func (em *ExpireMap) Size() int {
+ em.rwm.Lock()
+ defer em.rwm.Unlock()
+ return len(em.dict)
+}
+
+//Increments integer values and string-integer values of the ExpireMap.
+func (em *ExpireMap) Increment(key string) error {
+ if _, ok := em.dict[key]; !ok {
+ return errors.New("No such key in ExpireMap")
+ }
+ if reflect.TypeOf(em.dict[key]) == reflect.TypeOf(0) {
+ em.dict[key] = em.dict[key].(int) + 1
+ return nil
+ } else if reflect.TypeOf(em.dict[key]) == reflect.TypeOf("") {
+ temp, err := strconv.Atoi(em.dict[key].(string))
+ em.dict[key] = strconv.Itoa(temp + 1)
+ return err
+ }
+ return errors.New("Value not an int or string.")
+}
+
+//Decrements similarly to Increment.
+func (em *ExpireMap) Decrement(key string) error {
+ if _, ok := em.dict[key]; !ok {
+ return errors.New("No such key in ExpireMap")
+ }
+ if reflect.TypeOf(em.dict[key]) == reflect.TypeOf(0) {
+ em.dict[key] = em.dict[key].(int) - 1
+ return nil
+ } else if reflect.TypeOf(em.dict[key]) == reflect.TypeOf("") {
+ temp, err := strconv.Atoi(em.dict[key].(string))
+ em.dict[key] = strconv.Itoa(temp - 1)
+ return err
+ }
+ return errors.New("Value not an int or string.")
+}
+
+//Capitalizes letters of string values.
+func (em *ExpireMap) ToUpper(key string) error {
+ if _, ok := em.dict[key]; !ok {
+ return errors.New("No such key in ExpireMap")
+ }
+ if reflect.TypeOf(em.dict[key]) == reflect.TypeOf("") {
+ em.dict[key] = strings.ToUpper(em.dict[key].(string))
+ return nil
+ }
+ return errors.New("Value not a string.")
+}
+
+//Un-capitalizes letters of string values.
+func (em *ExpireMap) ToLower(key string) error {
+ if _, ok := em.dict[key]; !ok {
+ return errors.New("No such key in ExpireMap")
+ }
+ if reflect.TypeOf(em.dict[key]) == reflect.TypeOf("") {
+ em.dict[key] = strings.ToLower(em.dict[key].(string))
+ return nil
+ }
+ return errors.New("Value not a string.")
+}
+
+//Returns a channel where expiring keys are reporter.
+//(Only expiring keys - not ones being deleted.)
+func (em *ExpireMap) ExpiredChan() <-chan string {
+ return em.echan
+}
+
+//Clears all internal storage of the ExpireMap.
+func (em *ExpireMap) Cleanup() {
+ for key, _ := range em.dict {
+ em.Delete(key)
+ }
+}
+
+//Clears all internal storage of the ExpireMap and closes down all assets.
+func (em *ExpireMap) Destroy() {
+ em.trulyDead = true
+ em.Cleanup()
+ close(em.echan)
+}
Грешка в Set-a, разменям 53-54 ред.