init

Author: 王涛

README.md

@@ -0,0 +1,36 @@
+## 说明
+fixedlist 提供定长列表，初始化时定义好长度，add()负责向尾部添加数据,当数据达到指定长度时，fixedlist会自动删除头部数据。
+
+该场景常用于统计最近X时间的数据，比如最近60秒内每秒的请求量，只需把每秒的统计数据顺序add即可。
+## 安装
+```
+go get github.com/go-basic/fixedlist
+```
+## 使用
+```
+package main
+
+import (
+	"fmt"
+	"github.com/go-basic/fixedlist"
+)
+
+func main() {
+	f := fixedlist.NewFixedList(2)
+	f.Add("a")
+	f.Add("b")
+	fmt.Println(f.Data())
+	f.Add("c")
+	fmt.Println(f.Data())
+	f.Add("d")
+	fmt.Println(f.Data())
+	f.Add("e")
+	fmt.Println(f.Data())
+}
+/**
+[a b]
+[b c]
+[c d]
+[d e]
+ */
+```

example/main.go

@@ -0,0 +1,26 @@
+package main
+
+import (
+	"fmt"
+	"github.com/go-basic/fixedlist"
+)
+
+func main() {
+	f := fixedlist.NewFixedList(2)
+	f.Add("a")
+	f.Add("b")
+	fmt.Println(f.Data())
+	f.Add("c")
+	fmt.Println(f.Data())
+	f.Add("d")
+	fmt.Println(f.Data())
+	f.Add("e")
+	fmt.Println(f.Data())
+}
+
+/**
+[a b]
+[b c]
+[c d]
+[d e]
+ */

fixedlist.go

@@ -0,0 +1,54 @@
+package fixedlist
+
+import (
+	"container/list"
+	"sync"
+)
+
+type FixedList interface {
+	Add(interface{})
+	Len() int
+	Data() []interface{}
+}
+
+type fixedList struct {
+	sync.RWMutex
+	length int
+	data   *list.List
+}
+
+//创建定长列表
+func NewFixedList(len int) FixedList {
+	f := &fixedList{}
+	f.length = len
+	f.data = list.New()
+	return f
+}
+
+//添加一条记录
+func (f *fixedList) Add(val interface{}) {
+	f.Lock()
+	defer f.Unlock()
+	f.data.PushBack(val)
+	if f.data.Len() > f.length {
+		for i := 0; i <= f.data.Len()-f.length; i++ {
+			f.data.Remove(f.data.Front())
+		}
+	}
+}
+
+//获取数据长度
+func (f *fixedList) Len() int {
+	return f.data.Len()
+}
+
+//获取数据
+func (f *fixedList) Data() []interface{} {
+	f.RLock()
+	defer f.RUnlock()
+	var data []interface{}
+	for i := f.data.Front(); i != nil; i = i.Next() {
+		data = append(data, i.Value)
+	}
+	return data
+}

fixedlist_test.go

@@ -0,0 +1,33 @@
+package fixedlist
+
+import "testing"
+
+func TestFixedList_Add(t *testing.T) {
+	f := NewFixedList(2)
+	f.Add("a")
+	if f.Data()[0] != "a" {
+		t.Error("add err")
+	}
+}
+
+func TestFixedList_Len(t *testing.T) {
+	var length int
+	f := NewFixedList(length)
+	f.Add("a")
+	f.Add("b")
+	f.Add("c")
+	if f.Len() != length {
+		t.Error("len err")
+	}
+}
+
+func TestFixedList_Data(t *testing.T) {
+	var length int
+	f := NewFixedList(length)
+	f.Add("a")
+	f.Add("b")
+	f.Add("c")
+	if len(f.Data()) != length {
+		t.Error("data err")
+	}
+}

go.mod

@@ -0,0 +1,3 @@
+module github.com/go-basic/fixedlist
+
+go 1.14