reentrant lock

src/main/java/org/cactoos/scalar/Synced.java

@@ -24,6 +24,7 @@
 package org.cactoos.scalar;
 
 import org.cactoos.Scalar;
+import java.util.concurrent.locks.ReentrantLock;
 
 /**
  * Scalar that is thread-safe.
@@ -50,37 +51,32 @@
 public final class Synced<T> implements Scalar<T> {
 
     /**
-     * The scalar to cache.
-     */
-    private final Scalar<? extends T> origin;
-
-    /**
-     * Sync lock.
+     * The lock.
      */
-    private final Object mutex;
+    private final ReentrantLock lock;
 
     /**
-     * Ctor.
-     * @param src The Scalar to cache
+     * The scalar to cache.
      */
-    public Synced(final Scalar<? extends T> src) {
-        this(src, src);
-    }
+    private final Scalar<? extends T> origin;
 
     /**
      * Ctor.
+     *
      * @param scalar The Scalar to cache
-     * @param lock Sync lock
      */
-    public Synced(final Scalar<? extends T> scalar, final Object lock) {
+    public Synced(final Scalar<? extends T> scalar) {
         this.origin = scalar;
-        this.mutex = lock;
+        this.lock = new ReentrantLock();
     }
 
     @Override
     public T value() throws Exception {
-        synchronized (this.mutex) {
+        this.lock.lock();
+        try {
             return this.origin.value();
+        } finally {
+            this.lock.unlock();
         }
     }
 }

src/main/java/org/cactoos/text/Synced.java

@@ -33,20 +33,12 @@
  * @since 0.18
  */
 public final class Synced extends TextEnvelope {
-    /**
-     * Ctor.
-     * @param text The text
-     */
-    public Synced(final Text text) {
-        this(text, text);
-    }
 
     /**
      * Ctor.
      * @param text The text
-     * @param lck The lock
      */
-    public Synced(final Text text, final Object lck) {
-        super(new TextOf(new org.cactoos.scalar.Synced<>(text::asString, lck)));
+    public Synced(final Text text) {
+        super(new TextOf(new org.cactoos.scalar.Synced<>(text::asString)));
     }
 }