fixup

lytics · Dec 21, 2023 · 94b5ecf · 94b5ecf
1 parent f8fbefb
commit 94b5ecf
Showing 1 changed file with 2 additions and 3 deletions.
diff --git a/opwindow.go b/opwindow.go
@@ -50,10 +50,9 @@ func NewOpWindow(depth, width int, windowedBy time.Duration) *OpWindow {
 
 // Close provides graceful shutdown: no new ops will be enqueued.
 func (q *OpWindow) Close() {
-	q.mu.Lock()
-	defer q.mu.Unlock()
-
 	q.once.Do(func() {
+		q.mu.Lock()
+		defer q.mu.Unlock()
 		close(q.done)
 		// HACK (2023-12) (mh): Set depth to zero so new entries are rejected.
 		q.depth = 0