queue.go

package queue

import"sync"

typeQueuestruct {
queue []interface{}
lenint
lock*sync.Mutex
}

funcNew() *Queue {
q:=&Queue{}
q.queue=make([]interface{}, 0)
q.len=0
q.lock=new(sync.Mutex)
returnq
}

func (q*Queue) Len() int {
returnq.len
}

func (q*Queue) isEmpty() bool {
q.lock.Lock()
deferq.lock.Unlock()
returnq.len==0
}

func (q*Queue) Shift() (elinterface{}) {
el, q.queue=q.queue[0], q.queue[1:]
q.len--
return
}

func (q*Queue) Push(elinterface{}) {
q.queue=append(q.queue, el)
q.len++
return
}

func (q*Queue) Peek() (elinterface{}) {
q.lock.Lock()
deferq.lock.Unlock()
returnq.queue[0]
}