From 858d1f86a68e9483c0983836bd157a2a2e364ed7 Mon Sep 17 00:00:00 2001
From: Andrea Cavalli <andrea@cavallium.it>
Date: Thu, 10 Nov 2022 00:40:48 +0100
Subject: [PATCH] Fix synchronization

---
 src/main/java/it/cavallium/filequeue/QueueToConsumer.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
index 6c93ecd..828e1d5 100644
--- a/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
+++ b/src/main/java/it/cavallium/filequeue/QueueToConsumer.java
@@ -37,10 +37,10 @@ class QueueToConsumer<T> implements IQueueToConsumer<T> {
 			boolean crashed = true;
 			try {
 				if (consumer.tryConsume(value)) {
-					crashed = false;
 					shouldAdd = false;
 					preAddQueued.decrementAndGet();
 				}
+				crashed = false;
 			} finally {
 				if (crashed) {
 					shouldAdd = false;