代码拉取完成,页面将自动刷新
package anyArrayV2
import (
"encoding/json"
"fmt"
"math/rand"
"reflect"
"slices"
"sort"
"strings"
"sync"
"time"
"github.com/spf13/cast"
)
type AnyArray[T any] struct {
data []T
mu *sync.RWMutex
}
func New[T any](attrs ...Attributer[T]) AnyArray[T] {
a := AnyArray[T]{data: []T{}, mu: &sync.RWMutex{}}
return a.SetAttrs(attrs...)
}
func NewList[T any](list []T) AnyArray[T] { return New(List(list)) }
func NewItems[T any](items ...T) AnyArray[T] { return New(Items(items...)) }
func (my AnyArray[T]) SetAttrs(attrs ...Attributer[T]) AnyArray[T] {
if len(attrs) > 0 {
for idx := range attrs {
attrs[idx].Register(&my)
}
}
return my
}
func (my AnyArray[T]) Lock() AnyArray[T] {
my.mu.Lock()
return my
}
func (my AnyArray[T]) Unlock() AnyArray[T] {
my.mu.Unlock()
return my
}
func (my AnyArray[T]) RLock() AnyArray[T] {
my.mu.RLock()
return my
}
func (my AnyArray[T]) RUnlock() AnyArray[T] {
my.mu.RUnlock()
return my
}
// Empty 判断是否为空
func (my AnyArray[T]) Empty() bool { return len(my.data) == 0 }
// NotEmpty 判断是否不为空
func (my AnyArray[T]) NotEmpty() bool { return !my.Empty() }
// IfEmpty 判断是否为空:如果为空则执行回调
func (my AnyArray[T]) IfEmpty(fn func()) {
if len(my.data) == 0 {
fn()
}
}
// IfNotEmpty 判断是否不为空:如果不为空则执行回调
func (my AnyArray[T]) IfNotEmpty(fn func()) {
if len(my.data) != 0 {
fn()
}
}
// IfEmptyError 判断是否为空:如果为空则执行回调并返回错误
func (my AnyArray[T]) IfEmptyError(fn func() error) error {
if len(my.data) == 0 {
return fn()
}
return nil
}
// IfNotEmptyError 判断是否不为空:如果不为空则执行回调并返回错误
func (my AnyArray[T]) IfNotEmptyError(fn func() error) error {
if len(my.data) != 0 {
return fn()
}
return nil
}
// Has 检查是否存在
func (my AnyArray[T]) Has(k int) bool { return k >= 0 && k < len(my.data) }
func (my AnyArray[T]) SetValue(k int, v T) AnyArray[T] {
my.data[k] = v
return my
}
// Get 获取值
func (my AnyArray[T]) GetValue(idx int) T { return my.data[idx] }
// GetValuePtr 获取值指针
func (my AnyArray[T]) GetValuePtr(idx int) *T {
if idx < 0 || idx >= len(my.data) {
return nil
}
return &my.data[idx]
}
// GetValueOrDefault 获取值:如果索引不存在则返回默认值
func (my AnyArray[T]) GetValueOrDefault(idx int, defaultValue T) T {
if idx < 0 || idx >= len(my.data) {
return defaultValue
}
return my.data[idx]
}
func (my AnyArray[T]) GetValues(indexes ...int) []T {
res := make([]T, len(indexes))
for k, idx := range indexes {
res[k] = my.data[idx]
}
return res
}
func (my AnyArray[T]) Append(v ...T) AnyArray[T] {
return New(List(append(my.data, v...)))
}
// First 获取第一个值
func (my AnyArray[T]) First() T {
var t T
if len(my.data) > 0 {
return my.data[0]
}
return t
}
// Last 获取最后一个值
func (my AnyArray[T]) Last() T {
var t T
if len(my.data) > 0 {
return my.data[len(my.data)-1]
}
return t
}
// ToSlice 获取全部值:到切片
func (my AnyArray[T]) ToSlice() []T { return my.data }
// GetIndexes 获取所有索引
func (my AnyArray[T]) GetIndexes() []int {
var indexes = make([]int, len(my.data))
for i := range my.data {
indexes[i] = i
}
return indexes
}
// GetIndexByValue 根据值获取索引下标
func (my AnyArray[T]) GetIndexByValue(value T) int {
for idx, val := range my.data {
if reflect.DeepEqual(val, value) {
return idx
}
}
return -1
}
// GetIndexesByValues 通过值获取索引下标
func (my AnyArray[T]) GetIndexesByValues(values ...T) []int {
var indexes []int
for _, value := range values {
for idx, val := range my.data {
if reflect.DeepEqual(val, value) {
indexes = append(indexes, idx)
}
}
}
return indexes
}
// Shuffle 打乱切片中的元素顺序
func (my AnyArray[T]) Shuffle() AnyArray[T] {
randStr := rand.New(rand.NewSource(time.Now().UnixNano()))
newData := my.data
for i := range my.data {
j := randStr.Intn(i + 1) // 生成 [0, i] 范围内的随机数
newData[i], newData[j] = newData[j], newData[i] // 交换元素
}
return New(List(newData))
}
// Length 获取数组长度
func (my AnyArray[T]) Length() int { return len(my.data) }
// LengthNotEmpty 获取非0值长度
func (my *AnyArray[T]) LengthNotEmpty() int { return my.RemoveEmpty().Length() }
// Filter 过滤数组值
func (my AnyArray[T]) Filter(fn func(item T) bool) AnyArray[T] {
j := 0
ret := make([]T, len(my.data))
for i := range my.data {
if fn(my.data[i]) {
ret[j] = my.data[i]
j++
}
}
return New(List(ret[:j]))
}
// RemoveEmpty 清除0值元素
func (my AnyArray[T]) RemoveEmpty() AnyArray[T] {
return my.Filter(func(item T) bool {
ref := reflect.ValueOf(item)
if ref.Kind() == reflect.Ptr {
if ref.IsNil() {
return false
}
if ref.Elem().IsZero() {
return false
}
} else {
if ref.IsZero() {
return false
}
}
return true
})
}
// Join 拼接字符串
func (my AnyArray[T]) Join(sep string) string {
values := make([]string, my.Length())
for idx := range my.data {
values[idx] = cast.ToString(my.data[idx])
}
return strings.Join(values, sep)
}
// JoinNotEmpty 拼接非空元素
func (my AnyArray[T]) JoinNotEmpty(sep string) string { return my.RemoveEmpty().Join(sep) }
func (my AnyArray[T]) in(target T) bool {
for idx := range my.data {
if reflect.DeepEqual(target, my.data[idx]) {
return true
}
}
return false
}
// In 检查值是否存在
func (my AnyArray[T]) In(targets ...T) bool { return slices.ContainsFunc(targets, my.in) }
// NotIn 检查值是否不存在
func (my AnyArray[T]) NotIn(targets ...T) bool { return !slices.ContainsFunc(targets, my.in) }
func (my AnyArray[T]) IfIn(fn func(), targets ...T) {
if my.In(targets...) {
fn()
}
}
func (my AnyArray[T]) IfNotIn(fn func(), targets ...T) {
if my.NotIn(targets...) {
fn()
}
}
func (my AnyArray[T]) IfInError(fn func() error, targets ...T) error {
if my.In(targets...) {
return fn()
}
return nil
}
func (my AnyArray[T]) IfNotInError(fn func() error, targets ...T) error {
if my.NotIn(targets...) {
return fn()
}
return nil
}
// AllEmpty 判断当前数组是否0空
func (my AnyArray[T]) AllEmpty() bool { return my.RemoveEmpty().Length() == 0 }
// AnyEmpty 判断当前数组中是否存在0值
func (my AnyArray[T]) AnyEmpty() bool { return my.RemoveEmpty().Length() != my.Length() }
// Chunk 分块
func (my AnyArray[T]) Chunk(size int) [][]T {
var chunks [][]T
for i := 0; i < len(my.data); i += size {
end := min(i+size, len(my.data))
chunks = append(chunks, my.data[i:end])
}
return chunks
}
// Pluck 获取数组中指定字段的值
func (my AnyArray[T]) Pluck(fn func(item T) any) AnyArray[any] {
var ret = make([]any, 0)
for _, v := range my.data {
ret = append(ret, fn(v))
}
return New(List(ret))
}
// Intersection 取交集
func (my AnyArray[T]) Intersection(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var intersection = make([]T, 0)
for idx := range my.data {
if other.In(my.data[idx]) {
intersection = append(intersection, my.data[idx])
}
}
return New(List(intersection))
}
// IntersectionBySlice 取交集:通过切片
func (my AnyArray[T]) IntersectionBySlice(other ...T) AnyArray[T] {
return my.Intersection(New(List(other)))
}
// Difference 取差集
func (my AnyArray[T]) Difference(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var difference = make([]T, 0)
for _, value := range my.data {
if !other.In(value) {
difference = append(difference, value)
}
}
return New(List(difference))
}
// DifferenceBySlice 取差集:通过切片
func (my AnyArray[T]) DifferenceBySlice(other ...T) AnyArray[T] {
return my.Difference(New(List(other)))
}
// Union 取并集
func (my AnyArray[T]) Union(other AnyArray[T]) AnyArray[T] {
if other.Empty() {
return New[T]()
}
var union = make([]T, 0)
union = append(union, my.data...)
for _, value := range other.data {
if !my.In(value) {
union = append(union, value)
}
}
return New(List(union))
}
// UnionBySlice 取并集:通过切片
func (my AnyArray[T]) UnionBySlice(other []T) AnyArray[T] {
return my.Union(New(List(other)))
}
// Unique 去重
func (my AnyArray[T]) Unique() AnyArray[T] {
seen := make(map[string]struct{}) // 使用空结构体作为值,因为我们只关心键
result := make([]T, 0)
for _, value := range my.data {
key := fmt.Sprintf("%v", value)
if _, exists := seen[key]; !exists {
seen[key] = struct{}{}
result = append(result, value)
}
}
return New(List(result))
}
// RemoveByIndex 根据索引删除元素
func (my AnyArray[T]) RemoveByIndex(index int) AnyArray[T] {
if index < 0 || index >= len(my.data) {
return my
}
return New(List(append(my.data[:index], my.data[index+1:]...)))
}
// RemoveByIndexes 根据索引删除元素
func (my AnyArray[T]) RemoveByIndexes(indexes ...int) AnyArray[T] {
newData := make([]T, 0, len(my.data))
myIndexes := make([]int, 0, len(indexes))
for idx := range indexes {
if indexes[idx] < 0 || indexes[idx] >= len(my.data) {
myIndexes = append(myIndexes, indexes[idx])
}
}
for idx := range my.data {
for idx2 := range myIndexes {
if idx == idx2 {
continue
}
newData = append(newData, my.data[idx])
}
}
return New(List(newData))
}
// RemoveByValue 删除数组中对应的目标
func (my AnyArray[T]) RemoveByValue(target T) AnyArray[T] {
var ret = make([]T, len(my.data))
j := 0
for _, value := range my.data {
if !reflect.DeepEqual(value, target) {
ret[j] = value
j++
}
}
return New(List(ret[:j]))
}
// RemoveByValues 删除数组中对应的多个目标
func (my AnyArray[T]) RemoveByValues(targets ...T) AnyArray[T] {
data := my.data
for idx := range targets {
data = New(List(data)).RemoveByValues(targets[idx]).data
}
return New(List(data))
}
// Every 循环处理每一个
func (my AnyArray[T]) Every(fn func(item T) T) AnyArray[T] {
data := make([]T, len(my.data))
for idx := range my.data {
data[idx] = fn(my.data[idx])
}
return New(List(data))
}
// Each 遍历数组
func (my AnyArray[T]) Each(fn func(idx int, item T)) AnyArray[T] {
for idx := range my.data {
fn(idx, my.data[idx])
}
return my
}
// Sort 排序
func (my AnyArray[T]) Sort(fn func(i, j int) bool) AnyArray[T] {
sort.Slice(my.data, fn)
return my
}
// Clean 清理数据
func (my AnyArray[T]) Clean() AnyArray[T] {
my.data = make([]T, 0)
return my
}
// MarshalJSON 实现接口:json序列化
func (my AnyArray[T]) MarshalJSON() ([]byte, error) { return json.Marshal(&my.data) }
// UnmarshalJSON 实现接口:json反序列化
func (my AnyArray[T]) UnmarshalJSON(data []byte) error { return json.Unmarshal(data, &my.data) }
// ToString 导出string
func (my AnyArray[T]) ToString(formats ...string) string {
var format = "%v"
if len(formats) > 0 {
format = formats[0]
}
return fmt.Sprintf(format, my.data)
}
// Cast 转换值类型
func Cast[SRC, DST any](aa AnyArray[SRC], fn func(value SRC) DST) AnyArray[DST] {
if aa.Length() == 0 {
return New[DST]()
}
data := make([]DST, len(aa.data))
for idx := range aa.data {
data[idx] = fn(aa.data[idx])
}
return New(List(data))
}
// ToAny converts any slice to []any
func ToAny(slice any) []any {
v := reflect.ValueOf(slice)
if v.Kind() != reflect.Slice {
return nil
}
result := make([]any, v.Len())
for i := range v.Len() {
result[i] = v.Index(i).Interface()
}
return result
}
此处可能存在不合适展示的内容,页面不予展示。您可通过相关编辑功能自查并修改。
如您确认内容无涉及 不当用语 / 纯广告导流 / 暴力 / 低俗色情 / 侵权 / 盗版 / 虚假 / 无价值内容或违法国家有关法律法规的内容,可点击提交进行申诉,我们将尽快为您处理。