iSharkFly-Docs
/
java-tutorials
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #4000 from eugenp/issue-2433 

fix volatile test
This commit is contained in:
Loredana Crusoveanu 2018-04-14 19:04:32 +03:00 committed by GitHub
parent a41399d8a1 a60f86ddee
commit 42360c980d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 17 additions and 33 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
core-java-concurrency/src/test/java/com/baeldung/concurrent/volatilekeyword/SharedObjectManualTest.java
View File

@ -1,55 +1,36 @@
package com.baeldung.concurrent.volatilekeyword; package com.baeldung.concurrent.volatilekeyword;
import org.junit.After;
import org.junit.Before;
import org.junit.Test; import org.junit.Test;
import static junit.framework.Assert.assertEquals; import static org.junit.Assert.*;
public class SharedObjectManualTest { public class SharedObjectManualTest {
private SharedObject sharedObject;
private int valueReadByThread2;
private int valueReadByThread3;
@Before
public void setUp() {
sharedObject = new SharedObject();
}
@Test @Test
public void whenOneThreadWrites_thenVolatileReadsFromMainMemory() throws InterruptedException { public void whenOneThreadWrites_thenVolatileReadsFromMainMemory() throws InterruptedException {
SharedObject sharedObject = new SharedObject();
Thread writer = new Thread(() -> sharedObject.increamentCount()); Thread writer = new Thread(() -> sharedObject.increamentCount());
writer.start(); writer.start();
Thread.sleep(100);
Thread readerOne = new Thread(() -> { Thread readerOne = new Thread(() -> {
try { int valueReadByThread2 = sharedObject.getCount();
Thread.sleep(1000); assertEquals(1, valueReadByThread2);
} catch (InterruptedException e) {
e.printStackTrace();
}
valueReadByThread2 = sharedObject.getCount();
}); });
readerOne.start(); readerOne.start();
Thread readerTwo = new Thread(() -> { Thread readerTwo = new Thread(() -> {
try { int valueReadByThread3 = sharedObject.getCount();
Thread.sleep(1000); assertEquals(1, valueReadByThread3);
} catch (InterruptedException e) {
e.printStackTrace();
}
valueReadByThread3 = sharedObject.getCount();
}); });
readerTwo.start(); readerTwo.start();
assertEquals(1, valueReadByThread2);
assertEquals(1, valueReadByThread3);
} }
@Test @Test
public void whenTwoThreadWrites_thenVolatileReadsFromMainMemory() throws InterruptedException { public void whenTwoThreadWrites_thenVolatileReadsFromMainMemory() throws InterruptedException {
SharedObject sharedObject = new SharedObject();
Thread writerOne = new Thread(() -> sharedObject.increamentCount()); Thread writerOne = new Thread(() -> sharedObject.increamentCount());
writerOne.start(); writerOne.start();
Thread.sleep(100); Thread.sleep(100);
@ -58,14 +39,17 @@ public class SharedObjectManualTest {
writerTwo.start(); writerTwo.start();
Thread.sleep(100); Thread.sleep(100);
Thread readerOne = new Thread(() -> valueReadByThread2 = sharedObject.getCount()); Thread readerOne = new Thread(() -> {
int valueReadByThread2 = sharedObject.getCount();
assertEquals(2, valueReadByThread2);
});
readerOne.start(); readerOne.start();
Thread readerTwo = new Thread(() -> valueReadByThread3 = sharedObject.getCount()); Thread readerTwo = new Thread(() -> {
int valueReadByThread3 = sharedObject.getCount();
assertEquals(2, valueReadByThread3);
});
readerTwo.start(); readerTwo.start();
assertEquals(2, valueReadByThread2);
assertEquals(2, valueReadByThread3);
} }
} }