gqueue

使用场景：

该队列是并发安全的，常用于多goroutine数据通信且支持动态队列大小的场景。

使用方式：

https://godoc.org/github.com/gogf/gf/container/gqueue

package main
import (
    "fmt"
    "time"
    "github.com/gogf/gf/os/gtimer"
    "github.com/gogf/gf/container/gqueue"
)
func main() {
    q := gqueue.New()
    // 数据生产者，每隔1秒往队列写数据
    gtimer.SetInterval(time.Second, func() {
        v := gtime.Now().String()
        q.Push(v)
        fmt.Println("Push:", v)
    })
    // 3秒后关闭队列
        q.Close()
    })
    // 消费者，不停读取队列数据并输出到终端
    for {
        if v := q.Pop(); v != nil {
        } else {
            break
        }
    }
}

在该示例中，第3秒时关闭队列，这时程序立即退出，因此结果中只会打印2秒的数据。执行后，输出结果为：

使用队列对象公开的Queue.C属性，结合selectIO复用语法实现对队列的读取。

package main
import (
    "fmt"
    "github.com/gogf/gf/container/gqueue"
    "github.com/gogf/gf/os/gtime"
    "github.com/gogf/gf/os/gtimer"
    "time"
)
func main() {
    // 数据生产者，每隔1秒往队列写数据
    gtimer.SetInterval(time.Second, func() {
        queue.Push(gtime.Now().String())
    })
    // 消费者，不停读取队列数据并输出到终端
    for {
        select {
            case v := <-queue.C:
                    fmt.Println(v)
                } else {
                    return
                }
        }
    }
}

gqueue的底层基于list链表实现动态大小特性，但是gqueue的使用场景都是多goroutine下的并发安全通信场景。在队列满时存储(限制队列大小时)，或者在队列空时读取数据会产生类似channel那样的阻塞效果。

glist是一个并发安全的链表，并可以允许在关闭并发安全特性的时和一个普通的list链表无异，在存储和读取数据时不会发生阻塞。

gqueue与标准库channel的性能测试，其中每一次基准测试的b.N值均为20000000，以保证动态队列存取一致防止deadlock:

goos: darwin
goarch: amd64
pkg: github.com/gogf/gf/container/gqueue
Benchmark_Gqueue_StaticPushAndPop-4       20000000            84.2 ns/op
Benchmark_Gqueue_DynamicPush-4            20000000             164 ns/op
Benchmark_Gqueue_DynamicPop-4             20000000             121 ns/op
PASS

使用起来比channel更加灵活，不仅创建效率高（动态分配内存），不受队列大小限制(也可限定大小)。

gqueue (并发安全队列)

gqueue