Finish 9.9.0

Author: JavaSaBr

README.md

@@ -16,11 +16,11 @@ repositories {
 }
 
 dependencies {
-    compile 'com.spaceshift:rlib.common:9.8.0'
-    compile 'com.spaceshift:rlib.fx:9.8.0'
-    compile 'com.spaceshift:rlib.network:9.8.0'
-    compile 'com.spaceshift:rlib.mail:9.8.0'
-    compile 'com.spaceshift:rlib.testcontainers:9.8.0'
+    compile 'com.spaceshift:rlib.common:9.9.0'
+    compile 'com.spaceshift:rlib.fx:9.9.0'
+    compile 'com.spaceshift:rlib.network:9.9.0'
+    compile 'com.spaceshift:rlib.mail:9.9.0'
+    compile 'com.spaceshift:rlib.testcontainers:9.9.0'
 }
 ```
 
@@ -41,27 +41,27 @@ dependencies {
 <dependency>
     <groupId>com.spaceshift</groupId>
     <artifactId>rlib.common</artifactId>
-    <version>9.8.0</version>
+    <version>9.9.0</version>
 </dependency>
 <dependency>
     <groupId>com.spaceshift</groupId>
     <artifactId>rlib.fx</artifactId>
-    <version>9.8.0</version>
+    <version>9.9.0</version>
 </dependency>
 <dependency>
     <groupId>com.spaceshift</groupId>
     <artifactId>rlib.network</artifactId>
-    <version>9.8.0</version>
+    <version>9.9.0</version>
 </dependency>
 <dependency>
     <groupId>com.spaceshift</groupId>
     <artifactId>rlib.mail</artifactId>
-    <version>9.8.0</version>
+    <version>9.9.0</version>
 </dependency>
 <dependency>
     <groupId>com.spaceshift</groupId>
     <artifactId>rlib.testcontainers</artifactId>
-    <version>9.8.0</version>
+    <version>9.9.0</version>
 </dependency>
 
 ```

build.gradle

@@ -8,7 +8,7 @@ buildscript {
     }
 }
 
-rootProject.version = '9.8.0'
+rootProject.version = '9.9.0'
 group = 'com.spaceshift'
 
 allprojects {

rlib-common/src/main/java/com/ss/rlib/common/function/NotNullSafeTriFunction.java

@@ -0,0 +1,10 @@
+package com.ss.rlib.common.function;
+
+import org.jetbrains.annotations.NotNull;
+
+@FunctionalInterface
+public interface NotNullSafeTriFunction<F, S, T, R> extends SafeTriFunction<F, S, T, R> {
+
+    @Override
+    @NotNull R apply(@NotNull F first, @NotNull S second, @NotNull T third) throws Exception;
+}

rlib-common/src/main/java/com/ss/rlib/common/function/NullableSupplier.java

@@ -0,0 +1,12 @@
+package com.ss.rlib.common.function;
+
+import org.jetbrains.annotations.Nullable;
+
+import java.util.function.Supplier;
+
+@FunctionalInterface
+public interface NullableSupplier<T> extends Supplier<T> {
+
+    @Override
+    @Nullable T get();
+}

rlib-common/src/main/java/com/ss/rlib/common/function/SafeTriFunction.java

@@ -0,0 +1,9 @@
+package com.ss.rlib.common.function;
+
+import org.jetbrains.annotations.Nullable;
+
+@FunctionalInterface
+public interface SafeTriFunction<F, S, T, R> {
+
+    @Nullable R apply(@Nullable F first, @Nullable S second, @Nullable T third) throws Exception;
+}

rlib-common/src/main/java/com/ss/rlib/common/util/ReflectionUtils.java

@@ -1,7 +1,7 @@
 package com.ss.rlib.common.util;
 
+import static com.ss.rlib.common.util.ArrayUtils.contains;
 import com.ss.rlib.common.util.array.Array;
-import com.ss.rlib.common.util.array.ArrayFactory;
 import org.jetbrains.annotations.NotNull;
 import org.jetbrains.annotations.Nullable;
 
@@ -20,41 +20,53 @@ public final class ReflectionUtils {
      * Get all fields of the class.
      *
      * @param container  the field container.
-     * @param cs         the class.
-     * @param last       the last class.
-     * @param declared   the flag of getting private fields.
+     * @param startClass the class.
+     * @param lastClass  the last class.
+     * @param declared   the flag to get private fields as well.
      * @param exceptions exception fields.
      */
     public static void addAllFields(
-            @NotNull Array<Field> container,
-            @NotNull Class<?> cs,
-            @NotNull Class<?> last,
-            boolean declared,
-            @Nullable String... exceptions
+        @NotNull Array<Field> container,
+        @NotNull Class<?> startClass,
+        @NotNull Class<?> lastClass,
+        boolean declared,
+        @NotNull String... exceptions
     ) {
 
-        Class<?> next = cs;
+        var next = startClass;
 
-        while (next != null && next != last) {
+        while (next != null && next != lastClass) {
 
-            Field[] fields = declared ? next.getDeclaredFields() : next.getFields();
+            var fields = declared ? next.getDeclaredFields() : next.getFields();
 
             next = next.getSuperclass();
 
             if (fields.length < 1) {
                 continue;
             }
 
-            if (exceptions == null || exceptions.length < 1) {
+            if (exceptions.length < 1) {
                 container.addAll(fields);
             } else {
-                ArrayUtils.forEach(fields, toCheck ->
-                        !ArrayUtils.contains(exceptions, toCheck.getName()),
-                        container::add);
+                ArrayUtils.forEach(fields, toCheck -> !contains(exceptions, toCheck.getName()), container::add);
             }
         }
     }
 
+    /**
+     * Get all fields of a class.
+     *
+     * @param cs         the class.
+     * @param exceptions exception fields.
+     * @return the all declared fields.
+     * @since 9.9.0
+     */
+    public static @NotNull Array<Field> getAllDeclaredFields(@NotNull Class<?> cs, @NotNull String... exceptions) {
+        var container = Array.ofType(Field.class);
+        addAllFields(container, cs, Object.class, true, exceptions);
+        return container;
+    }
+
     /**
      * Get all fields of the class.
      *
@@ -65,12 +77,12 @@ public static void addAllFields(
      * @return the all fields
      */
     public static @NotNull Array<Field> getAllFields(
-            @NotNull Class<?> cs,
-            @NotNull Class<?> last,
-            boolean declared,
-            @Nullable String... exceptions
+        @NotNull Class<?> cs,
+        @NotNull Class<?> last,
+        boolean declared,
+        @NotNull String... exceptions
     ) {
-        Array<Field> container = ArrayFactory.newArray(Field.class);
+        var container = Array.ofType(Field.class);
         addAllFields(container, cs, last, declared, exceptions);
         return container;
     }

rlib-common/src/main/java/com/ss/rlib/common/util/Utils.java

@@ -264,6 +264,34 @@ public static <F, S> void unchecked(
         }
     }
 
+    /**
+     * Execute the function with auto-converting a checked exception to an unchecked.
+     *
+     * @param first    the first argument.
+     * @param second   the second argument.
+     * @param function the function.
+     * @param <F>      the first's type.
+     * @param <S>      the second's type.
+     * @param <T>      the third's type.
+     * @param <R>      the result's type.
+     * @return the result.
+     * @since 9.9.0
+     */
+    public static <F, S, T, R> @NotNull R uncheckedGet(
+        @NotNull F first,
+        @NotNull S second,
+        @NotNull T third,
+        @NotNull NotNullSafeTriFunction<F, S, T, R> function
+    ) {
+        try {
+            return function.apply(first, second, third);
+        } catch (IOException e) {
+            throw new UncheckedIOException(e);
+        } catch (Exception e) {
+            throw new RuntimeException(e);
+        }
+    }
+
     /**
      * Try to execute a function with some result.
      *

rlib-common/src/main/java/com/ss/rlib/common/util/array/ConcurrentArray.java

@@ -353,6 +353,31 @@ default void writeUnlock(long stamp) {
         }
     }
 
+    /**
+     * Execute a function to get some result under {@link #readLock()} block.
+     *
+     * @param first    the first argument for the function.
+     * @param second   the second argument for the function.
+     * @param function the function.
+     * @param <A>      the first argument's type.
+     * @param <T>      the second argument's type.
+     * @param <R>      the result's type.
+     * @return the result from the function.
+     * @since 9.9.0
+     */
+    default <A, T, R> @Nullable R getInReadLock(
+        @NotNull A first,
+        @NotNull T second,
+        @NotNull NotNullNullableTripleFunction<ConcurrentArray<E>, A, T, R> function
+    ) {
+        var stamp = readLock();
+        try {
+            return function.apply(this, first, second);
+        } finally {
+            readUnlock(stamp);
+        }
+    }
+
     /**
      * Execute a function to get some result under {@link #writeLock()} block.
      *
@@ -391,6 +416,31 @@ default void writeUnlock(long stamp) {
         }
     }
 
+    /**
+     * Execute a function to get some result under {@link #writeLock()} block.
+     *
+     * @param first    the first argument for the function.
+     * @param second   the second argument for the function.
+     * @param function the function.
+     * @param <A>      the first argument's type.
+     * @param <T>      the second argument's type.
+     * @param <R>      the result's type.
+     * @return the result from the function.
+     * @since 9.9.0
+     */
+    default <A, T, R> @Nullable R getInWriteLock(
+        @NotNull A first,
+        @NotNull T second,
+        @NotNull NotNullNullableTripleFunction<ConcurrentArray<E>, A, T, R> function
+    ) {
+        var stamp = writeLock();
+        try {
+            return function.apply(this, first, second);
+        } finally {
+            writeUnlock(stamp);
+        }
+    }
+
     /**
      * Execute a function under {@link #readLock()} block.
      *
@@ -433,6 +483,33 @@ default void writeUnlock(long stamp) {
         return this;
     }
 
+    /**
+     * Execute a function under {@link #readLock()} block.
+     *
+     * @param <A>      the first argument's type.
+     * @param <T>      the second argument's type.
+     * @param first    the first argument.
+     * @param second   the second argument.
+     * @param function the function.
+     * @return this array.
+     * @since 9.9.0
+     */
+    default <A, T> @NotNull ConcurrentArray<E> runInReadLock(
+        @NotNull A first,
+        @NotNull T second,
+        @NotNull NotNullTripleConsumer<ConcurrentArray<E>, A, T> function
+    ) {
+
+        var stamp = readLock();
+        try {
+            function.accept(this, first, second);
+        } finally {
+            readUnlock(stamp);
+        }
+
+        return this;
+    }
+
     /**
      * Execute a function under {@link #writeLock()} block.
      *
@@ -474,6 +551,31 @@ default void writeUnlock(long stamp) {
         return this;
     }
 
+    /**
+     * Execute a function under {@link #writeLock()} block.
+     *
+     * @param first    the first argument for the function.
+     * @param second   the second argument for the function.
+     * @param function the function.
+     * @param <A>      the first argument's type.
+     * @param <T>      the second argument's type.
+     * @return this array.
+     * @since 9.9.0
+     */
+    default <A, T> @NotNull ConcurrentArray<E> runInWriteLock(
+        @NotNull A first,
+        @NotNull T second,
+        @NotNull NotNullTripleConsumer<ConcurrentArray<E>, A, T> function
+    ) {
+        var stamp = writeLock();
+        try {
+            function.accept(this, first, second);
+        } finally {
+            writeUnlock(stamp);
+        }
+        return this;
+    }
+
     /**
      * Search an element using the condition under {@link #readLock()} block.
      *