lhotari commented on code in PR #787:
URL: https://github.com/apache/ratis/pull/787#discussion_r1026081437
##########
ratis-common/src/main/java/org/apache/ratis/util/AwaitForSignal.java:
##########
@@ -17,54 +17,54 @@
*/
package org.apache.ratis.util;
-import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.ExecutionException;
import java.util.concurrent.TimeUnit;
-import java.util.concurrent.TimeoutException;
-import java.util.concurrent.atomic.AtomicReference;
+import java.util.concurrent.locks.Condition;
+import java.util.concurrent.locks.Lock;
+import java.util.concurrent.locks.ReentrantLock;
/**
* This class is a partial implementation of {@link
java.util.concurrent.locks.Condition}.
* Only some of the await and signal methods are implemented.
- *
+ * <p>
* This class is threadsafe.
*/
public class AwaitForSignal {
private final String name;
-
- private final AtomicReference<CompletableFuture<Void>> future = new
AtomicReference<>(new CompletableFuture<>());
+ private final Lock lock = new ReentrantLock();
+ private final Condition condition = lock.newCondition();
public AwaitForSignal(Object name) {
this.name = name + "-" + JavaUtils.getClassSimpleName(getClass());
}
/** The same as {@link java.util.concurrent.locks.Condition#await()} */
public void await() throws InterruptedException {
+ lock.lock();
try {
- future.get().get();
- } catch (ExecutionException e) {
- throw new IllegalStateException(e);
+ condition.await();
+ } finally {
+ lock.unlock();
}
}
/** The same as {@link java.util.concurrent.locks.Condition#await(long,
TimeUnit)} */
public boolean await(long time, TimeUnit unit) throws InterruptedException {
- if (time <= 0) {
- return false;
- }
Review Comment:
Is it necessary to keep this logic?
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
