package main

import (
	"fmt"
	"github.com/gogf/gf/container/gqueue"
	"sync"
)

func main() {
	// 创建一个普通队列
	queue := gqueue.New()

	// 创建一个安全队列
	safeQueue := gqueue.NewSafe()

	// 使用 WaitGroup 同步并发操作
	var wg sync.WaitGroup
	wg.Add(2)

	// 并发向普通队列中添加元素
	go func() {
		defer wg.Done()
		queue.Push(1)
		queue.Push(2)
	}()

	// 并发向安全队列中添加元素
	go func() {
		defer wg.Done()
		safeQueue.Push(3)
		safeQueue.Push(4)
	}()

	// 等待两个 goroutine 完成
	wg.Wait()

	// 从普通队列中获取元素
	fmt.Println("Queue Pop:")
	for {
		value := queue.Pop()
		if value == nil {
			break
		}
		fmt.Println(value)
	}

	// 从安全队列中获取元素
	fmt.Println("\nSafe Queue Pop:")
	for {
		value := safeQueue.Pop()
		if value == nil {
			break
		}
		fmt.Println(value)
	}
}