Merge branch '__rultor'

objectionary · Apr 27, 2024 · 0c3f311 · 0c3f311
2 parents 58135f6 + c0a5dca
commit 0c3f311
Show file tree

Hide file tree

Showing 3 changed files with 27 additions and 3 deletions.
diff --git a/eo-maven-plugin/src/main/java/org/eolang/maven/hash/ChRemote.java b/eo-maven-plugin/src/main/java/org/eolang/maven/hash/ChRemote.java
@@ -25,7 +25,6 @@
 
 import com.jcabi.log.Logger;
 import org.cactoos.Text;
-import org.cactoos.text.Sticky;
 
 /**
  * Hash of tag from objectionary.
@@ -37,7 +36,7 @@ public final class ChRemote implements CommitHash {
     /**
      * Cached text of hashes.
      */
-    private static final Text CACHE = new Sticky(new CommitHashesText());
+    private static final Text CACHE = new CommitHashesText();
 
     /**
      * Tag.

diff --git a/eo-maven-plugin/src/main/java/org/eolang/maven/hash/CommitHash.java b/eo-maven-plugin/src/main/java/org/eolang/maven/hash/CommitHash.java
@@ -23,12 +23,15 @@
  */
 package org.eolang.maven.hash;
 
+import org.cactoos.Scalar;
+
 /**
  * Hash of tag.
  *
  * @since 0.28.11
  */
-public interface CommitHash {
+@FunctionalInterface
+public interface CommitHash extends Scalar<String> {
 
     /**
      * SHA Hash.

diff --git a/eo-maven-plugin/src/test/java/org/eolang/maven/hash/ChRemoteTest.java b/eo-maven-plugin/src/test/java/org/eolang/maven/hash/ChRemoteTest.java
@@ -25,6 +25,10 @@
 package org.eolang.maven.hash;
 
 import com.yegor256.WeAreOnline;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+import java.util.stream.StreamSupport;
+import org.cactoos.experimental.Threads;
 import org.eolang.maven.BinarizeParseTest;
 import org.hamcrest.MatcherAssert;
 import org.hamcrest.Matchers;
@@ -67,4 +71,22 @@ void throwsCommitHashException() {
             BinarizeParseTest.TO_ADD_MESSAGE
         );
     }
+
+    @Test
+    void isThreadSafe() {
+        final int threads = 200;
+        final String sample = new ChRemote("0.23.19").value();
+        MatcherAssert.assertThat(
+            "You can use this class concurrently",
+            StreamSupport.stream(
+                new Threads<>(
+                    threads,
+                    Stream.generate(
+                        () -> new ChRemote("0.23.19")
+                    ).limit(threads).collect(Collectors.toList())
+                ).spliterator(), false
+            ).filter(str -> !sample.equals(str)).collect(Collectors.toList()),
+            Matchers.empty()
+        );
+    }
 }