- New:
remove(int)
allows atomic removal of multiple elements. - New:
forEach(ElementVisitor)
allows iterating queue items and stopping iteration early. QueueFile
now implements theCloseable
interface.- Fix: Do not erase data before updating the header when calling
clear()
orremove()
.
close()
method onFileObjectQueue
now closes underlyingQueueFile
.- Fix: Properly move and zero out bytes during copy opertaions.
- Fix: Prevent corruption when expanding a perfectly saturated queue.
- New:
QueueFile
instances throw anIOException
on creation if a corrupt header is found.
- New: Zero out old records in
clear()
andremove()
.
- Fix: Ensure -1 is returned when no more bytes are available.
- Fix: Correct read to use position offset in certain cases where it would otherwise use 0.
- Allow a
TaskQueue
'sTaskInjector
to benull
. TaskQueue
listener is now called with a reference to the queue instance rather than its delegate.
Initial release.