Formatted with Google Java Formatter

Author: github-actions

src/main/java/com/examplehub/basics/thread/InterruptedThread.java

@@ -1,4 +1,3 @@
 package com.examplehub.basics.thread;
 
-public class InterruptedThread {
-}
+public class InterruptedThread {}

src/main/java/com/examplehub/basics/thread/VolatileExample.java

@@ -1,4 +1,3 @@
 package com.examplehub.basics.thread;
 
-public class VolatileExample {
-}
+public class VolatileExample {}

src/main/java/com/examplehub/basics/thread/YieldThread.java

@@ -4,7 +4,7 @@ public class YieldThread implements Runnable {
 
  @Override
  public void run() {
-// System.out.println(Thread.currentThread().getName() + " is running");
+ // System.out.println(Thread.currentThread().getName() + " is running");
  Thread.yield();
  System.out.println(Thread.currentThread().getName() + " is stopped");
  }

src/test/java/com/examplehub/basics/thread/InterruptedThreadTest.java

@@ -7,7 +7,7 @@ class InterruptedThreadTest {
  @Test
  @Disabled
  void test() throws InterruptedException {
- //TODO
+ // TODO
  class MyThread extends Thread {
  @Override
  public void run() {
@@ -25,4 +25,4 @@ public void run() {
  thread.join();
  System.out.println(Thread.currentThread().getName() + " stopped");
  }
-}
+}

src/test/java/com/examplehub/basics/thread/JoinThreadTest.java

@@ -1,10 +1,9 @@
 package com.examplehub.basics.thread;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.*;
 
 import java.util.concurrent.atomic.AtomicInteger;
+import org.junit.jupiter.api.Test;
 
 class JoinThreadTest {
  @Test
@@ -22,14 +21,16 @@ void test() throws InterruptedException {
  @Test
  void testJoinWithTime() throws InterruptedException {
  AtomicInteger number = new AtomicInteger();
- Thread thread = new Thread(()->{
- try {
- Thread.sleep(100);
- number.set(1);
- } catch (InterruptedException e) {
- e.printStackTrace();
- }
- });
+ Thread thread =
+ new Thread(
+ () -> {
+ try {
+ Thread.sleep(100);
+ number.set(1);
+ } catch (InterruptedException e) {
+ e.printStackTrace();
+ }
+ });
  thread.start();
  thread.join(50);
  assertEquals(0, number.get());

src/test/java/com/examplehub/basics/thread/SynchronizedThreadTest.java

@@ -1,9 +1,9 @@
 package com.examplehub.basics.thread;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.*;
 
+import org.junit.jupiter.api.Test;
+
 class Counter {
  public static final Object lock = new Object();
  public static int count = 0;
@@ -56,11 +56,13 @@ public void run() {
  void testSynchronizedThis() throws InterruptedException {
  class Counter {
  private int count = 0;
+
  public void dec() {
  synchronized (this) {
  count = count - 1;
  }
  }
+
  public void add() {
  synchronized (this) {
  count = count + 1;
@@ -72,16 +74,20 @@ public int getCount() {
  }
  }
  Counter counter = new Counter();
- var firstThread = new Thread(() -> {
- for (int i = 0; i < 100; i++) {
- counter.add();
- }
- });
- var secondThread = new Thread(() -> {
- for (int i = 0; i < 100; i++) {
- counter.dec();
- }
- });
+ var firstThread =
+ new Thread(
+ () -> {
+ for (int i = 0; i < 100; i++) {
+ counter.add();
+ }
+ });
+ var secondThread =
+ new Thread(
+ () -> {
+ for (int i = 0; i < 100; i++) {
+ counter.dec();
+ }
+ });
  firstThread.start();
  secondThread.start();
  firstThread.join();
@@ -93,28 +99,34 @@ public int getCount() {
  void testSynchronizedFunction() throws InterruptedException {
  class Counter {
  private int count = 0;
+
  public synchronized void dec() {
-  count = count - 1;
+ count = count - 1;
  }
+
  public synchronized void add() {
-  count = count + 1;
+ count = count + 1;
  }
 
  public int getCount() {
  return count;
  }
  }
  Counter counter = new Counter();
- var firstThread = new Thread(() -> {
- for (int i = 0; i < 100; i++) {
- counter.add();
- }
- });
- var secondThread = new Thread(() -> {
- for (int i = 0; i < 100; i++) {
- counter.dec();
- }
- });
+ var firstThread =
+ new Thread(
+ () -> {
+ for (int i = 0; i < 100; i++) {
+ counter.add();
+ }
+ });
+ var secondThread =
+ new Thread(
+ () -> {
+ for (int i = 0; i < 100; i++) {
+ counter.dec();
+ }
+ });
  firstThread.start();
  secondThread.start();
  firstThread.join();

src/test/java/com/examplehub/basics/thread/VolatileExampleTest.java

@@ -1,11 +1,12 @@
 package com.examplehub.basics.thread;
 
-import org.junit.jupiter.api.Test;
-
 import static org.junit.jupiter.api.Assertions.*;
 
+import org.junit.jupiter.api.Test;
+
 class VolatileExampleTest {
  int number = 0;
+
  @Test
  void test() throws InterruptedException {
  class MyThread extends Thread {
@@ -27,4 +28,4 @@ public void run() {
  thirdThread.join();
  assertEquals(30, number);
  }
-}
+}