Upgrade levelqueue to v0.4.0 (#16560) (#16561)

Fix #16546

vendor/gitea.com/lunny/levelqueue/queue.go

@@ -295,6 +295,11 @@ func (queue *Queue) LHandle(h func([]byte) error) error {
 
 // Close closes the queue (and the underlying db is set to closeUnderlyingDB)
 func (queue *Queue) Close() error {
+	queue.highLock.Lock()
+	queue.lowLock.Lock()
+	defer queue.highLock.Unlock()
+	defer queue.lowLock.Unlock()
+
 	if !queue.closeUnderlyingDB {
 		queue.db = nil
 		return nil

vendor/gitea.com/lunny/levelqueue/set.go

@@ -107,6 +107,8 @@ func (set *Set) Remove(value []byte) (bool, error) {
 
 // Close closes the set (and the underlying db if set to closeUnderlyingDB)
 func (set *Set) Close() error {
+	set.lock.Lock()
+	defer set.lock.Unlock()
 	if !set.closeUnderlyingDB {
 		set.db = nil
 		return nil

vendor/gitea.com/lunny/levelqueue/uniquequeue.go

@@ -181,6 +181,8 @@ func (queue *UniqueQueue) Len() int64 {
 func (queue *UniqueQueue) Close() error {
 	_ = queue.q.Close()
 	_ = queue.set.Close()
+	queue.set.lock.Lock()
+	defer queue.set.lock.Unlock()
 	if !queue.closeUnderlyingDB {
 		queue.db = nil
 		return nil