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

Fix test for getWaitRunnable

Browse Source
This commit is contained in:
Emmanuel Bigeon 2016-12-06 12:56:42 -05:00
parent ffa54af3be
commit ff9ace1033
1 changed files with 5 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

15
gclc/src/test/java/fr/bigeon/gclc/manager/ReadingRunnableTest.java
View File

@ -48,6 +48,7 @@ import java.io.InputStream;
import java.io.InputStreamReader; import java.io.InputStreamReader;
import java.io.PipedInputStream; import java.io.PipedInputStream;
import java.io.PipedOutputStream; import java.io.PipedOutputStream;
import java.nio.charset.Charset;
import org.junit.Before; import org.junit.Before;
import org.junit.Test; import org.junit.Test;
@ -110,17 +111,15 @@ public class ReadingRunnableTest {
final ReadingRunnable runnable = new ReadingRunnable(reader); final ReadingRunnable runnable = new ReadingRunnable(reader);
Thread th0 = new Thread(runnable, "read"); Thread th0 = new Thread(runnable, "read");
th0.start(); th0.start();
Thread th = runnable.getWaitForDelivery(""); Thread th = runnable.getWaitForDelivery("msg");
final Object start = new Object(); out.write(Charset.forName("UTF-8")
.encode("msg" + System.lineSeparator()).array());
Thread th2 = new Thread(new Runnable() { Thread th2 = new Thread(new Runnable() {
@Override @Override
public void run() { public void run() {
synchronized (start) {
start.notify();
}
try { try {
runnable.getMessage(); runnable.getMessage();
} catch (IOException e) { } catch (IOException e) {
@ -129,11 +128,7 @@ public class ReadingRunnableTest {
} }
} }
}, "get"); }, "get");
synchronized (start) { th2.start();
th2.start();
start.wait();
}
runnable.interrupt();
try { try {
th.join(); th.join();
} catch (InterruptedException e) { } catch (InterruptedException e) {