新增garray并发安全数组包,开发中

This commit is contained in:
John
2018-04-15 22:37:39 +08:00
parent 5494a4d710
commit edebdac257
4 changed files with 159 additions and 9 deletions

View File

@ -0,0 +1,8 @@
// Copyright 2018 gf Author(https://gitee.com/johng/gf). All Rights Reserved.
//
// This Source Code Form is subject to the terms of the MIT License.
// If a copy of the MIT was not distributed with this file,
// You can obtain one at https://gitee.com/johng/gf.
// 并发安全的数组.
package garray

View File

@ -0,0 +1,78 @@
// Copyright 2018 gf Author(https://gitee.com/johng/gf). All Rights Reserved.
//
// This Source Code Form is subject to the terms of the MIT License.
// If a copy of the MIT was not distributed with this file,
// You can obtain one at https://gitee.com/johng/gf.
package garray
import "sync"
type IntArray struct {
mu sync.RWMutex // 互斥锁
array []int // 底层数组
}
func NewIntArray(size int, cap ... int) *IntArray {
a := &IntArray{}
if len(cap) > 0 {
a.array = make([]int, size, cap[0])
} else {
a.array = make([]int, size)
}
return a
}
// 获取指定索引的数据项, 调用方注意判断数组边界
func (a *IntArray) Get(index int) int {
a.mu.RLock()
value := a.array[index]
a.mu.RUnlock()
return value
}
// 设置指定索引的数据项, 调用方注意判断数组边界
func (a *IntArray) Set(index int, value int) {
a.mu.Lock()
a.array[index] = value
a.mu.Unlock()
}
// 在当前索引位置前插入一个数据项, 调用方注意判断数组边界
func (a *IntArray) Insert(index int, value int) {
a.mu.Lock()
rear := append([]int{}, a.array[index : ]...)
a.array = append(a.array[0 : index], value)
a.array = append(a.array, rear...)
a.mu.Unlock()
}
// 删除指定索引的数据项, 调用方注意判断数组边界
func (a *IntArray) Remove(index int) {
a.mu.Lock()
a.array = append(a.array[ : index], a.array[index + 1 : ]...)
a.mu.RUnlock()
}
// 追加数据项
func (a *IntArray) Append(value int) {
a.mu.Lock()
a.array = append(a.array, value)
a.mu.Unlock()
}
// 数组长度
func (a *IntArray) Len() int {
a.mu.RLock()
length := len(a.array)
a.mu.RUnlock()
return length
}
// 返回原始数据数组
func (a *IntArray) Slice() []int {
a.mu.RLock()
array := a.array
a.mu.RUnlock()
return array
}

View File

@ -0,0 +1,65 @@
// Copyright 2018 gf Author(https://gitee.com/johng/gf). All Rights Reserved.
//
// This Source Code Form is subject to the terms of the MIT License.
// If a copy of the MIT was not distributed with this file,
// You can obtain one at https://gitee.com/johng/gf.
package garray
//import "sync"
//
//type IntArray struct {
// mu sync.RWMutex // 互斥锁
// array []int // 底层数组
// lessThanFunc func(v1, v2 int) bool // 比较函数如何判断v1比v2小
//}
//
//func NewIntArray(size int, cap ... int) *IntArray {
// a := &IntArray{}
// if len(cap) > 0 {
// a.array = make([]int, size, cap[0])
// } else {
// a.array = make([]int, size)
// }
// a.lessThanFunc = func(v1, v2 int) bool {
// return v1 < v2
// }
// return a
//}
//
//// 获取指定索引的数据项, 调用方注意判断数组边界
//func (a *IntArray) Get(index int) int {
// a.mu.RLock()
// value := a.array[index]
// a.mu.RUnlock()
// return value
//}
//
//// 设置指定索引的数据项, 调用方注意判断数组边界
//func (a *IntArray) Set(index int, value int) {
// a.mu.Lock()
// a.array[index] = value
// a.mu.Unlock()
//}
//
//// 删除指定索引的数据项, 调用方注意判断数组边界
//func (a *IntArray) Remove(index int) {
// a.mu.Lock()
// a.array = append(a.array[ : index], a.array[index + 1 : ]...)
// a.mu.RUnlock()
//}
//
//// 追加数据项
//func (a *IntArray) Append(value int) {
// a.mu.Lock()
// a.array = append(a.array, value)
// a.mu.Unlock()
//}
//
//// 数组长度
//func (a *IntArray) Len() int {
// a.mu.RLock()
// length := len(a.array)
// a.mu.RUnlock()
// return length
//}

View File

@ -1,18 +1,17 @@
package main
import (
"gitee.com/johng/gf/g/container/gmap"
"fmt"
"strings"
"gitee.com/johng/gf/g/container/garray"
)
func main() {
m := gmap.NewIntBoolMap()
m.Set(1, true)
fmt.Println(m.Keys())
m.LockFunc(func(m map[int]bool) {
m[2] = false
})
fmt.Println(m.Keys())
a := garray.NewIntArray(0)
a.Append(1)
a.Append(2)
a.Append(3)
fmt.Println(a.Slice())
a.Insert(0, 0)
fmt.Println(a.Slice())
}