在 Go 中使用互斥锁

我想了解互斥体是如何工作的。据我目前的理解，它是为了进行原子操作并同步对某些数据的访问。

我在这里构建了一个队列数据结构的示例：https://github.com/arnauddri/algorithms/blob/master/data-structs%2Fqueue%2Fqueue.go https://github.com/arnauddri/algorithms/blob/master/data-structures%2Fqueue%2Fqueue.go

这是一些代码：

package queue

import "sync"

type Queue struct {
    queue []interface{}
    len   int
    lock  *sync.Mutex
}

func New() *Queue {
    queue := &Queue{}
    queue.queue = make([]interface{}, 0)
    queue.len = 0

    return queue
}

func (q *Queue) Push(el interface{}) {
    q.lock.Lock()
    defer q.lock.Unlock()

    q.queue = append(q.queue, el)
    q.len++
}

但是，当我尝试创建队列并向其推送项目时，出现运行时错误：

q := New()
q.Push(1)

panic: runtime error: invalid memory address or nil pointer dereference [recovered]
panic: runtime error: invalid memory address or nil pointer dereference

我真的不明白这里发生了什么。

我应该如何使用互斥锁？

非常感谢

您收到该错误是因为您没有分配任何互斥体，您只有一个指向互斥体的指针。 互斥体通常在结构内部声明，而不使用指针。请参阅下面的工作示例：

http://play.golang.org/p/8LF3yVOkSW http://play.golang.org/p/8LF3yVOkSW

import "sync"

type Queue struct {
    len int

    lock  sync.Mutex // add it before the fields that are being protected by the mutex
    queue []interface{}
}

func New() *Queue {
    queue := &Queue{}
    queue.queue = make([]interface{}, 0)
    queue.len = 0

    return queue
}

func (q *Queue) Push(el interface{}) {
    q.lock.Lock()
    defer q.lock.Unlock()

    q.queue = append(q.queue, el)
    q.len++
}

func main() {
    q := New()
    q.Push(1)
}