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