Mirrors/sshj
1
0
Fork 0
mirror of https://github.com/hierynomus/sshj.git synced 2025-12-08 08:10:55 +03:00
Code Issues Actions Packages Projects Releases Wiki Activity

don't do a looped cond.await(timeout, unit) as that handles spurious wakeups, and it'll be buggy if the wakeup is due to a call to clear()

Browse Source
This commit is contained in:
Shikhar Bhushan
2012-10-21 01:21:36 +05:30
parent 2fdafb76fd
commit 4c5da634ad
1 changed files with 6 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
src/main/java/net/schmizz/concurrent/Promise.java
View File

@@ -162,11 +162,14 @@ public class Promise<V, T extends Throwable> {
if (val != null) if (val != null)
return val; return val;
log.debug("Awaiting <<{}>>", name); log.debug("Awaiting <<{}>>", name);
while (val == null && pendingEx == null) if (timeout == 0) {
if (timeout == 0) while (val == null && pendingEx == null) {
cond.await(); cond.await();
else if (!cond.await(timeout, unit)) }
} else {
if (!cond.await(timeout, unit))
return null; return null;
}
if (pendingEx != null) { if (pendingEx != null) {
log.error("<<{}>> woke to: {}", name, pendingEx.toString()); log.error("<<{}>> woke to: {}", name, pendingEx.toString());
throw pendingEx; throw pendingEx;