Go语言搬砖 collections队列

发表于

「这是我参与11月更文挑战的第19天，活动详情查看：2021最后一次更文挑战」。

简介

collections是无意在github上发现的一款小巧好用的队列包，还是国人写的，不错不错

目前已有的功能包括:

  • 先进先出队列
  • 后进先出队列
  • 优先队列
  • 双端队列
  • 有序Map
  • 计数器
  • 排序

缺点就是已经好几年没更新了，但是了功能还能用😅

官网传送门: github.com/chenjiandon…

安装

先使用go将包下载到本地

1
js复制代码go get github.com/chenjiandongx/collections

在代码编辑器里面引入既可使用

1
js复制代码import "github.com/chenjiandongx/collections"

使用

所以的功能方法都在collections里面，不同功能使用不同方法

image.png

先进先出

先进先出的优点在一些需要按顺序执行的场景，确保流程可以按照预先 设定好的顺序执行，这在做运维自动化时特别有用(一个脚本执行完后再执行另一个脚本)

运行以下代码会 在控制台输出从0到9的数字(从小到大)

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
js复制代码var q  = Q()

func Q() *collections.Queue {
   q := collections.NewQueue()
   return q
}

func main() {
   for i :=0; i < 10;i++{
      q.Put(i)
   }
   for i:=0;i <10 ;i++  {
      if item,ok:=q.Get(); ok{
         fmt.Println(item)
      }
   }
}

后进先出

运行以下代码，会发现 数字是从大到小输出的

1
2
3
4
5
6
7
8
9
10
11
js复制代码func main() {
   q := collections.NewLifoQueue()
   for i := 0; i < 10; i++ {
      q.Put(i)
   }
   for i := 0; i < 10; i++ {
      if item, ok := q.Get(); ok {
         fmt.Println(item)
      }
   }
}

实战demo

上面的小demo运行起来好像也没太大问题，但是如果加上了goroutine,在实际运行中可能达不到想要的效果，所以这里需要结合channe来实现一个，可以不断提交任务，但每次只执行一个任务，且只有这个任务执行完了，再执行下一个任务

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
js复制代码var (
   q = collections.NewQueue()
)

func main() {
   go QueueApi()
   Web()
}

func Web() {
   r := gin.Default()
   r.GET("/api/devops", func(c *gin.Context) {

      args1 := c.Query("args1")
      args2 := c.Query("args2")
      data := map[string]string{
         "parameters1": args1,
         "parameters2": args2,
      }
      q.Put(data)

      c.JSON(http.StatusOK, gin.H{
         "message": "commit success",
         "data":    "ok",
         "code":    200,
      })
   })

   r.Run(":8080")
}

func QueueApi() {
   fmt.Println("开始监听队列....")
   for {
      select {
      case <-time.After(time.Second * 5):
         if item, ok := q.Get(); ok {
            result := item.(map[string]string)
            var wg sync.WaitGroup
            wg.Add(1)
            go func() {
               defer wg.Done()
               //TODO  具体执行的逻辑
               time.Sleep(10 * time.Second)
               fmt.Println(result)
            }()
            wg.Wait()
         }
      }
   }
}

该demo使用提顺序执行队列，GET接口/api/devops接收提交参数，可以不停的提交，但是方法QueueApi每5秒循环查一次，当查询到队列里有数据，就开始执行，每次只执行一个，执行成功后。继续循环以上逻辑

1
2
js复制代码#测试
curl --location --request GET 'localhost:8080?args1=hello&args2=world'

总结

code的力量还是很强大的，虽然这个包并不出名，作者也不是鼎鼎大名大佬，但是写出来的包依然非常棒(实用)

至于该包的其它的功能，有需要的同学可以自行探索哦

本文转载自: 掘金

开发者博客 – 和开发相关的 这里全都有

0%