如何在Golang中实现并发安全的队列-Golang-PHP中文网

如何在Golang中实现并发安全的队列

P粉602998670

发布： 2025-10-26 15:04:01

原创

893人浏览过

使用互斥锁或channel可实现Golang并发安全队列：通过sync.Mutex保护切片操作，确保Push、Pop等操作原子性；或利用channel天然并发安全特性构建队列，其中带缓冲channel适合固定规模生产者-消费者场景，且操作无需额外加锁。

如何在golang中实现并发安全的队列

在Golang中实现并发安全的队列，关键在于保护共享数据不被多个goroutine同时访问导致竞争。可以通过结合使用channel或sync.Mutex与切片来构建线程安全的队列结构。下面介绍两种常见且有效的实现方式。

使用互斥锁（Mutex）保护切片队列

利用sync.Mutex可以轻松地将基于切片的队列变为并发安全。这种方式灵活，适合需要自定义操作的场景。

基本思路是：用一个结构体封装切片和互斥锁，在入队（Push）和出队（Pop）操作时加锁，确保同一时间只有一个goroutine能修改队列。

示例代码：

package main
<p>import (
"sync"
)</p><p>type Queue struct {
items []interface{}
mu    sync.Mutex
}</p><p>func (q *Queue) Push(item interface{}) {
q.mu.Lock()
defer q.mu.Unlock()
q.items = append(q.items, item)
}</p><p>func (q *Queue) Pop() (interface{}, bool) {
q.mu.Lock()
defer q.mu.Unlock()
if len(q.items) == 0 {
return nil, false
}
item := q.items[0]
q.items = q.items[1:]
return item, true
}</p><p>func (q *Queue) Len() int {
q.mu.Lock()
defer q.mu.Unlock()
return len(q.items)
}

登录后复制

这个实现中，每次操作都通过Lock/Unlock保护，避免了数据竞争。虽然append和切片操作本身不是原子的，但加锁后整个操作过程是安全的。

立即学习“go语言免费学习笔记（深入）”；

使用Channel实现天然并发安全的队列

Go的channel本身就是并发安全的，可用于直接构建队列。这是更“Go风格”的做法，尤其适合生产者-消费者模型。

如果队列大小可预估，使用带缓冲的channel；若不确定，可用无缓冲channel配合select控制流程。

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

简单示例：

package main
<p>type SafeQueue chan interface{}</p><p>func NewSafeQueue(size int) SafeQueue {
return make(SafeQueue, size)
}</p><p>func (q SafeQueue) Push(item interface{}) {
q <- item
}</p><p>func (q SafeQueue) Pop() (interface{}, bool) {
select {
case item := <-q:
return item, true
default:
return nil, false
}
}

登录后复制

注意：上面的Pop是非阻塞的。如需阻塞读取，可直接写成 item := 。使用channel的好处是无需手动加锁，语言层面已保证安全。