Code cleanup

pom.xml

@@ -291,7 +291,7 @@
       <dependency>
         <groupId>org.warp</groupId>
         <artifactId>common-utils</artifactId>
-        <version>1.1.5</version>
+        <version>1.1.6</version>
       </dependency>
       <dependency>
         <groupId>io.net5</groupId>

src/main/java/it/cavallium/dbengine/database/LLDictionary.java

@@ -10,12 +10,10 @@ import java.util.List;
 import java.util.Optional;
 import java.util.function.Function;
 import org.jetbrains.annotations.Nullable;
-import org.warp.commonutils.concurrency.atomicity.NotAtomic;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
 
 @SuppressWarnings("unused")
-@NotAtomic
 public interface LLDictionary extends LLKeyValueDatabaseStructure {
 
 	String getColumnName();

src/main/java/it/cavallium/dbengine/database/disk/LLLocalDictionary.java

@@ -57,7 +57,6 @@ import org.rocksdb.Slice;
 import org.rocksdb.Snapshot;
 import org.rocksdb.WriteBatch;
 import org.rocksdb.WriteOptions;
-import org.warp.commonutils.concurrency.atomicity.NotAtomic;
 import org.warp.commonutils.log.Logger;
 import org.warp.commonutils.log.LoggerFactory;
 import reactor.core.publisher.Flux;
@@ -69,7 +68,6 @@ import reactor.util.function.Tuple3;
 import reactor.util.function.Tuple4;
 import reactor.util.function.Tuples;
 
-@NotAtomic
 public class LLLocalDictionary implements LLDictionary {
 
 	protected static final Logger logger = LoggerFactory.getLogger(LLLocalDictionary.class);

src/main/java/it/cavallium/dbengine/database/serialization/CodecsArray.java

@@ -1,8 +1,5 @@
 package it.cavallium.dbengine.database.serialization;
 
-import org.warp.commonutils.concurrency.atomicity.NotAtomic;
-
-@NotAtomic
 public class CodecsArray<A> implements Codecs<A> {
 
 	private final Codec<A>[] codecs;

src/main/java/it/cavallium/dbengine/database/serialization/CodecsStandard.java

@@ -2,9 +2,7 @@ package it.cavallium.dbengine.database.serialization;
 
 import it.unimi.dsi.fastutil.ints.Int2ObjectMap;
 import it.unimi.dsi.fastutil.ints.Int2ObjectOpenHashMap;
-import org.warp.commonutils.concurrency.atomicity.NotAtomic;
 
-@NotAtomic
 public class CodecsStandard<A> implements Codecs<A> {
 
 	private final Int2ObjectMap<Codec<A>> codecs;

src/main/java/org/rocksdb/CappedWriteBatch.java

@@ -12,9 +12,7 @@ import it.cavallium.dbengine.database.disk.RocksDBColumn;
 import java.nio.ByteBuffer;
 import java.util.ArrayList;
 import java.util.List;
-import org.warp.commonutils.concurrency.atomicity.NotAtomic;
 
-@NotAtomic
 public class CappedWriteBatch extends WriteBatch {
 
 	/**