Go语言自定义线程安全的队列结构
package main
import (
"fmt"
"sync"
"time"
)
type Queue struct { // 队列
queue []interface{}
cond *sync.Cond
}
func GetDefaultQueue() *Queue { //获取默认队列
q := Queue{
queue: []interface{}{},
cond: sync.NewCond(&sync.Mutex{}),
}
return &q
}
func (q *Queue) Enqueue(item interface{}) { // 存值
q.cond.L.Lock()
defer q.cond.L.Unlock()
q.queue = append(q.queue, item)
q.cond.Broadcast()
}
func (q *Queue) Dequeue() interface{} { // 取值
q.cond.L.Lock()
defer q.cond.L.Unlock()
if len(q.queue) == 0 {
q.cond.Wait()
}
result := q.queue[0]
q.queue = q.queue[1:]
return result
}
func main() {
q := GetDefaultQueue()
go func() {
for {
q.Enqueue("a")
fmt.Println("存值：a")
time.Sleep(time.Second * 2)
}
}()
for {
result := q.Dequeue()
fmt.Println("取值：", result)
time.Sleep(time.Second)
}
}