Aircompressor cannot be used in insecure environments due to sun.misc.Unsafe

[xxDark]

... without copying.

public class AirCompressorVMCrash {

	public static void main(String[] args) {
		var deallocation = new ConcurrentLinkedQueue<Arena>();
		Thread.ofPlatform().daemon().start(() -> {
			do {
				Arena arena;
				if ((arena = deallocation.poll()) != null) arena.close();
			} while (true);
		});
		var compressor = new ZstdJavaCompressor();
		var input = createInput();
		var maxCompressedLength /* not 64-bit? */ = compressor.maxCompressedLength(/* not 64-bit? */ Math.toIntExact(input.byteSize()));
		do {
			var arena = Arena.ofShared();
			var output = arena.allocate(maxCompressedLength);
			deallocation.offer(arena);
			compressor.compress(input, output);
		} while (true);
	}

	private static MemorySegment createInput() {
		var b = new byte[655356];
		new SecureRandom().nextBytes(b);
		return MemorySegment.ofArray(b);
	}
}

[Marcono1234]

Isn't the problem here your sample code though? By calling deallocation.offer(arena) before compress(...) you are creating a race condition where the memory might be deallocated before compression has finished.

Or did you expect that the output MemorySegment throws an exception when Aircompressor uses it after it has been deallocated, similar to how regular MemorySegment usage behaves?
(Which currently does not happen because Aircompressor seems to directly operate on the underyling native address.)