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

Renaming the Class to Reflect the Article Update

This commit is contained in:
Ali Dehghani 2020-04-14 01:28:10 +04:30
parent a057b3af44
commit 123485714d
4 changed files with 12 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
core-java-modules/core-java-concurrency-basic/src/main/java/com/baeldung/concurrent/threadsafety/application/Application.java
View File

@ -9,7 +9,7 @@ import com.baeldung.concurrent.threadsafety.callables.ReentranReadWriteLockCount
import com.baeldung.concurrent.threadsafety.callables.ReentrantLockCounterCallable; import com.baeldung.concurrent.threadsafety.callables.ReentrantLockCounterCallable;
import com.baeldung.concurrent.threadsafety.services.AtomicCounter; import com.baeldung.concurrent.threadsafety.services.AtomicCounter;
import com.baeldung.concurrent.threadsafety.services.Counter; import com.baeldung.concurrent.threadsafety.services.Counter;
import com.baeldung.concurrent.threadsafety.services.ExtrinsicLockCounter; import com.baeldung.concurrent.threadsafety.services.ObjectLockCounter;
import com.baeldung.concurrent.threadsafety.services.MessageService; import com.baeldung.concurrent.threadsafety.services.MessageService;
import com.baeldung.concurrent.threadsafety.services.ReentrantLockCounter; import com.baeldung.concurrent.threadsafety.services.ReentrantLockCounter;
import com.baeldung.concurrent.threadsafety.services.ReentrantReadWriteLockCounter; import com.baeldung.concurrent.threadsafety.services.ReentrantReadWriteLockCounter;
@ -48,9 +48,9 @@ public class Application {
System.out.println(future3.get()); System.out.println(future3.get());
System.out.println(future4.get()); System.out.println(future4.get());
ExtrinsicLockCounter extrinsicLockCounter = new ExtrinsicLockCounter(); ObjectLockCounter objectLockCounter = new ObjectLockCounter();
Future<Integer> future5 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(extrinsicLockCounter)); Future<Integer> future5 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(objectLockCounter));
Future<Integer> future6 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(extrinsicLockCounter)); Future<Integer> future6 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(objectLockCounter));
System.out.println(future5.get()); System.out.println(future5.get());
System.out.println(future6.get()); System.out.println(future6.get());

6
core-java-modules/core-java-concurrency-basic/src/main/java/com/baeldung/concurrent/threadsafety/callables/ExtrinsicLockCounterCallable.java
View File

@ -1,13 +1,13 @@
package com.baeldung.concurrent.threadsafety.callables; package com.baeldung.concurrent.threadsafety.callables;
import com.baeldung.concurrent.threadsafety.services.ExtrinsicLockCounter; import com.baeldung.concurrent.threadsafety.services.ObjectLockCounter;
import java.util.concurrent.Callable; import java.util.concurrent.Callable;
public class ExtrinsicLockCounterCallable implements Callable<Integer> { public class ExtrinsicLockCounterCallable implements Callable<Integer> {
private final ExtrinsicLockCounter counter; private final ObjectLockCounter counter;
public ExtrinsicLockCounterCallable(ExtrinsicLockCounter counter) { public ExtrinsicLockCounterCallable(ObjectLockCounter counter) {
this.counter = counter; this.counter = counter;
} }

4
core-java-modules/core-java-concurrency-basic/src/main/java/com/baeldung/concurrent/threadsafety/services/ExtrinsicLockCounter.java → core-java-modules/core-java-concurrency-basic/src/main/java/com/baeldung/concurrent/threadsafety/services/ObjectLockCounter.java
View File

@ -1,11 +1,11 @@
package com.baeldung.concurrent.threadsafety.services; package com.baeldung.concurrent.threadsafety.services;
public class ExtrinsicLockCounter { public class ObjectLockCounter {
private int counter; private int counter;
private final Object lock = new Object(); private final Object lock = new Object();
public ExtrinsicLockCounter() { public ObjectLockCounter() {
this.counter = 0; this.counter = 0;
} }

6
core-java-modules/core-java-concurrency-basic/src/test/java/com/baeldung/concurrent/threadsafety/ExtrinsicLockCounterUnitTest.java → core-java-modules/core-java-concurrency-basic/src/test/java/com/baeldung/concurrent/threadsafety/ObjectLockCounterUnitTest.java
View File

@ -1,7 +1,7 @@
package com.baeldung.concurrent.threadsafety; package com.baeldung.concurrent.threadsafety;
import com.baeldung.concurrent.threadsafety.callables.ExtrinsicLockCounterCallable; import com.baeldung.concurrent.threadsafety.callables.ExtrinsicLockCounterCallable;
import com.baeldung.concurrent.threadsafety.services.ExtrinsicLockCounter; import com.baeldung.concurrent.threadsafety.services.ObjectLockCounter;
import org.junit.Test; import org.junit.Test;
import java.util.concurrent.ExecutorService; import java.util.concurrent.ExecutorService;
@ -10,12 +10,12 @@ import java.util.concurrent.Future;
import static org.assertj.core.api.Assertions.assertThat; import static org.assertj.core.api.Assertions.assertThat;
public class ExtrinsicLockCounterUnitTest { public class ObjectLockCounterUnitTest {
@Test @Test
public void whenCalledIncrementCounter_thenCorrect() throws Exception { public void whenCalledIncrementCounter_thenCorrect() throws Exception {
ExecutorService executorService = Executors.newFixedThreadPool(2); ExecutorService executorService = Executors.newFixedThreadPool(2);
ExtrinsicLockCounter counter = new ExtrinsicLockCounter(); ObjectLockCounter counter = new ObjectLockCounter();
Future<Integer> future1 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(counter)); Future<Integer> future1 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(counter));
Future<Integer> future2 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(counter)); Future<Integer> future2 = (Future<Integer>) executorService.submit(new ExtrinsicLockCounterCallable(counter));