andreacavalli/filequeue
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Code cleanup

Browse Source
This commit is contained in:
Andrea Cavalli 2023-10-20 12:54:50 +02:00
parent c91507381c
commit a359656ca9
1 changed files with 2 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/main/java/it/cavallium/filequeue/QueueToConsumer.java
View File

@ -100,10 +100,8 @@ class QueueToConsumer<T> implements IQueueToConsumer<T> {
}
}
preAddQueued.updateAndGet(n -> n > 0 ? n - 1 : 0);
} else {
if (park) {
LockSupport.parkNanos(HALF_SECOND_NS);
}
} else if (park) {
LockSupport.parkNanos(HALF_SECOND_NS);
}
}
}