emmanuel/gclc-core
emmanuel/gclc-core
1
0
Fork 0
Code Issues 2 Pull Requests Projects 1 Releases Wiki Activity

Fix available message test

Browse Source 
Signed-off-by: Emmanuel Bigeon <emmanuel@bigeon.fr>
This commit is contained in:
Emmanuel Bigeon 2018-10-27 14:02:31 -04:00
parent 171f79518d
commit 0ab39b24f6
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
gclc/src/main/java/net/bigeon/gclc/utils/ReadingRunnable.java
View File

@ -177,7 +177,7 @@ public final class ReadingRunnable implements Runnable {
} }
} }
public void waitForDelivery(String message) throws InterruptedException { public void waitForDelivery(final String message) throws InterruptedException {
Object mLock; Object mLock;
synchronized (messageBlockerLock) { synchronized (messageBlockerLock) {
if (!messageBlocker.containsKey(message)) { if (!messageBlocker.containsKey(message)) {
@ -196,10 +196,11 @@ public final class ReadingRunnable implements Runnable {
* @throws IOException if the pipe is closed */ * @throws IOException if the pipe is closed */
public boolean hasMessage() throws IOException { public boolean hasMessage() throws IOException {
synchronized (lock) { synchronized (lock) {
if (!running) { final boolean empty = messages.isEmpty();
if (!running && empty) {
throw new IOException(CLOSED_PIPE); throw new IOException(CLOSED_PIPE);
} }
return !messages.isEmpty(); return !empty;
} }
} }