前言
今天在搞一个需求,从三方获得有信息变更的商品,更新自己的数据库,再推送给下游进行商品更新。
期间有更新商品数量不确定,为了保证程序稳定性,每组向下游推送20个商品id。
查了garray的文档,发现支持Chunk()方法,灰常好用。
func commonSendMessage(goodsIds *garray.IntArray, messageType int) { goodsIdsChunk := goodsIds.Chunk(20) for _, chunkedGoodsIds := range goodsIdsChunk { //给下游推送消息 message.SendMessage(chunkedGoodsIds, messageType, 0) //商品变动appid为0 } }
于是,决定今天分享 GoFrame garray的开箱体验
普通数组
package main import ( "fmt" "github.com/gogf/gf/v2/container/garray" ) func main() { // 创建并发安全的int类型数组 a := garray.NewIntArray(true) // 添加数据项 for i := 0; i < 10; i++ { a.Append(i) } // 获取当前数组长度 fmt.Println(a.Len()) // 获取当前数据项列表 fmt.Println(a.Slice()) // 获取指定索引项 fmt.Println(a.Get(6)) // 在指定索引后插入数据项 a.InsertAfter(9, 11) // 在指定索引前插入数据项 a.InsertBefore(10, 10) fmt.Println(a.Slice()) // 修改指定索引的数据项 a.Set(0, 100) fmt.Println(a.Slice()) // 搜索数据项,返回搜索到的索引位置 fmt.Println(a.Search(5)) // 删除指定索引的数据项 a.Remove(0) fmt.Println(a.Slice()) // 并发安全,写锁操作 a.LockFunc(func(array []int) { // 将末尾项改为100 array[len(array)-1] = 100 }) // 并发安全,读锁操作 a.RLockFunc(func(array []int) { fmt.Println(array[len(array)-1]) }) // 清空数组 fmt.Println(a.Slice()) a.Clear() fmt.Println(a.Slice()) }
输出结果如下:
下面介绍常用的方法 🔽
Append
说明:向数组的尾部追加数据,可以添加任意数量字符串。Append
的方法是PushRight
的别名
格式:
Append(value ...string) *StrArray
示例:建立一个空数组,设置完数据后,并在数组尾部添加新的数据。
package main import ( "fmt" "github.com/gogf/gf/v2/container/garray" "github.com/gogf/gf/v2/frame/g" ) func main() { s := garray.NewStrArray() s.SetArray(g.SliceStr{"We", "are", "GF", "fans"}) s.Append("王", "中", "阳") fmt.Println(s) }
输出结果:
At
说明:返回数组指定索引的数据
格式:
At(index int) (value string)
示例:建立一个数组,找到index
为2的数据。
func ExampleStrArray_At() { s := garray.NewStrArrayFrom(g.SliceStr{"We", "are", "GF", "fans", "!"}) sAt := s.At(2) fmt.Println(sAt) }
输出结果:GF
Chunk
说明:把指定数组按指定的大小Size
,分割成多个数组,返回值为[][]string
。最后一个数组包含数据的数量可能小于Size
格式:
Chunk(size int) [][]string
示例:建立一个数组,并将该数组分割成3个数组
func ExampleStrArray_Chunk() { s := garray.NewStrArrayFrom(g.SliceStr{"a", "b", "c", "d", "e", "f", "g", "h"}) r := s.Chunk(3) fmt.Println(r) }
输出结果:[[a b c] [d e f] [g h]]
Clear
说明:删除当前数组中所有的数据
格式:
Clear() *StrArray
示例:建立一个空数组,赋值后,并删除该数组的数据。
func ExampleStrArray_Clear() { s := garray.NewStrArray() s.SetArray(g.SliceStr{"a", "b", "c", "d", "e", "f", "g", "h"}) fmt.Println(s) fmt.Println(s.Clear()) fmt.Println(s) }
输出结果:
Clone
说明:克隆当前的数组。返回一个与当前数组相同的数组拷贝
格式:
Clone() (newArray *StrArray)
示例:建立一个空数组,赋值后,克隆出一个新数组。
func ExampleStrArray_Clone() { s := garray.NewStrArray() s.SetArray(g.SliceStr{"a", "b", "c", "d", "e", "f", "g", "h"}) r := s.Clone() fmt.Println(r) fmt.Println(s) }
输出结果:
PopLefts
说明:从数组的左侧将多个字符串数据出栈,返回值为出栈的字符串数据,出栈数据的个数为size
。如果size
比数组的size
大,那么方法将返回数组中所有的数据。如果size<=0或者为空
,那么将返回nil
格式:
PopLefts(size int) []string
示例:建立1个新数组,将最左边的2个数据做出栈操作,并打印出出栈的数据和原数组的剩余数据
func ExampleStrArray_PopLefts() { s := garray.NewStrArray() s.SetArray(g.SliceStr{"a", "b", "c", "d", "e", "f", "g", "h"}) r := s.PopLefts(2) fmt.Println(r) fmt.Println(s) }
输出结果: