refactor(demo-thread): rename demo classes for consistency and clarity

Author: helltractor

demo-thread/src/main/java/com/helltractor/demo/WaitAndNotifyDemo.java

@@ -26,7 +26,7 @@ public static void main(String[] args) throws InterruptedException {
 
         Thread add = new Thread(() -> {
             for (int i = 0; i < 10; i++) {
-                String s = "t-" + Math.random();
+                String s = "Worker-" + i;
                 System.out.println("add task: " + s);
                 q.addTask(s);
                 try {
@@ -39,12 +39,13 @@ public static void main(String[] args) throws InterruptedException {
         add.start();
         add.join();
         Thread.sleep(100);
+        
         for (var t : ts) {
             t.interrupt();
         }
     }
 
-    private static class TaskQueue {
+    static class TaskQueue {
 
         private Queue<String> queue = new LinkedList<>();
 
@@ -54,6 +55,7 @@ public synchronized void addTask(String s) {
         }
 
         public synchronized String getTask() throws InterruptedException {
+            // avoid spurious wakeup
             while (queue.isEmpty()) {
                 this.wait();
             }

…emo/reentrantlock/ReentrantLockDemo.java …o/reentrantlock/ReentrantLockSample.javademo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantLockDemo.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantLockSample.java demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantLockDemo.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantLockSample.java

@@ -3,7 +3,7 @@
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.locks.ReentrantLock;
 
-public class ReentrantLockDemo {
+public class ReentrantLockSample {
 
     private static void getReentrantLockContext(ReentrantLock lock) {
         try {

…rantlock/ReentrantReadWriteLockDemo.java …ntlock/ReentrantReadWriteLockSample.javademo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantReadWriteLockDemo.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantReadWriteLockSample.java demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantReadWriteLockDemo.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/ReentrantReadWriteLockSample.java

@@ -2,11 +2,11 @@
 
 import java.util.Random;
 
-public class ReentrantReadWriteLockDemo {
+public class ReentrantReadWriteLockSample {
 
     public static UnboundedCache<Integer, Integer> cache = new UnboundedCache<>();
 
-    public class MyThread implements Runnable {
+    public static class ReentrantReadWriteLockThread implements Runnable {
 
         @Override
         public void run() {

demo-thread/src/main/java/com/helltractor/demo/reentrantlock/Task.java

@@ -2,6 +2,7 @@
 
 @FunctionalInterface
 public interface Task {
-
+    
     void execute();
+    
 }

…tractor/demo/reentrantlock/MyThread.java …actor/demo/reentrantlock/TaskThread.javademo-thread/src/main/java/com/helltractor/demo/reentrantlock/MyThread.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/TaskThread.java demo-thread/src/main/java/com/helltractor/demo/reentrantlock/MyThread.java renamed to demo-thread/src/main/java/com/helltractor/demo/reentrantlock/TaskThread.java

@@ -1,10 +1,10 @@
 package com.helltractor.demo.reentrantlock;
 
-class MyThread extends Thread {
+class TaskThread extends Thread {
 
     private final Task task;
-
-    public MyThread(String name, Task task) {
+    
+    public TaskThread(String name, Task task) {
         super(name);
         this.task = task;
     }

…or/demo/threadlocal/ThreadLocalTask.java …tractor/demo/threadlocal/TaskThread.javademo-thread/src/main/java/com/helltractor/demo/threadlocal/ThreadLocalTask.java renamed to demo-thread/src/main/java/com/helltractor/demo/threadlocal/TaskThread.java demo-thread/src/main/java/com/helltractor/demo/threadlocal/ThreadLocalTask.java renamed to demo-thread/src/main/java/com/helltractor/demo/threadlocal/TaskThread.java

@@ -1,10 +1,10 @@
 package com.helltractor.demo.threadlocal;
 
-class ThreadLocalTask implements Runnable {
+class TaskThread implements Runnable {
 
-    final String username;
+    private final String username;
 
-    public ThreadLocalTask(String username) {
+    public TaskThread(String username) {
         this.username = username;
     }
 

demo-thread/src/main/java/com/helltractor/demo/threadlocal/ThreadLocalDemo.java

@@ -5,16 +5,30 @@
 import java.util.concurrent.TimeUnit;
 
 public class ThreadLocalDemo {
-
+    
     public static void main(String[] args) throws Exception {
         ExecutorService es = Executors.newFixedThreadPool(3);
         String[] users = new String[]{"Bob", "Alice", "Tim", "Mike", "Lily", "Jack", "Bush"};
         for (String user : users) {
-            es.submit(new ThreadLocalTask(user));
+            es.submit(new TaskThread(user));
         }
         es.awaitTermination(3, TimeUnit.SECONDS);
         es.shutdown();
+        
         InheritableThreadLocal<String> inheritableThreadLocal = new InheritableThreadLocal<>();
+        inheritableThreadLocal.set("Hello from parent thread!");
+        
+        Thread childThread = new Thread(() -> {
+            System.out.println("Child thread: " + inheritableThreadLocal.get());
+            inheritableThreadLocal.set("Hello from child thread!");
+            System.out.println("Child thread after set: " + inheritableThreadLocal.get());
+        });
+        
+        childThread.start();
+        childThread.join();
+        
+        System.out.println("Parent thread after child thread: " + inheritableThreadLocal.get());
+        inheritableThreadLocal.remove();
     }
-
+    
 }

demo-thread/src/test/java/com/helltractor/demo/reentrantlock/ReentrantLockTest.java

@@ -1,19 +1,19 @@
 package com.helltractor.demo.reentrantlock;
 
-import com.helltractor.demo.reentrantlock.ReentrantLockDemo.LockInterruptiblyTask;
-import com.helltractor.demo.reentrantlock.ReentrantLockDemo.LockTask;
-import com.helltractor.demo.reentrantlock.ReentrantLockDemo.TryLockTask;
-import com.helltractor.demo.reentrantlock.ReentrantLockDemo.TryLockTaskTwo;
+import com.helltractor.demo.reentrantlock.ReentrantLockSample.LockInterruptiblyTask;
+import com.helltractor.demo.reentrantlock.ReentrantLockSample.LockTask;
+import com.helltractor.demo.reentrantlock.ReentrantLockSample.TryLockTask;
+import com.helltractor.demo.reentrantlock.ReentrantLockSample.TryLockTaskTwo;
 import org.junit.jupiter.api.Test;
 
 public class ReentrantLockTest {
 
     @Test
     public void testReentrantLock() {
         LockTask lockTask = new LockTask();
-        MyThread thread1 = new MyThread("Thread 1", lockTask);
-        MyThread thread2 = new MyThread("Thread 2", lockTask);
-        MyThread thread3 = new MyThread("Thread 3", lockTask);
+        TaskThread thread1 = new TaskThread("Thread 1", lockTask);
+        TaskThread thread2 = new TaskThread("Thread 2", lockTask);
+        TaskThread thread3 = new TaskThread("Thread 3", lockTask);
 
         thread1.start();
         thread2.start();
@@ -23,9 +23,9 @@ public void testReentrantLock() {
     @Test
     public void testTryLock() {
         TryLockTask tryLockTask = new TryLockTask();
-        MyThread thread1 = new MyThread("Thread 1", tryLockTask);
-        MyThread thread2 = new MyThread("Thread 2", tryLockTask);
-        MyThread thread3 = new MyThread("Thread 3", tryLockTask);
+        TaskThread thread1 = new TaskThread("Thread 1", tryLockTask);
+        TaskThread thread2 = new TaskThread("Thread 2", tryLockTask);
+        TaskThread thread3 = new TaskThread("Thread 3", tryLockTask);
 
         thread1.start();
         thread2.start();
@@ -35,9 +35,9 @@ public void testTryLock() {
     @Test
     public void testTryLockWithTimeout() {
         TryLockTaskTwo tryLockTask = new TryLockTaskTwo();
-        MyThread thread1 = new MyThread("Thread 1", tryLockTask);
-        MyThread thread2 = new MyThread("Thread 2", tryLockTask);
-        MyThread thread3 = new MyThread("Thread 3", tryLockTask);
+        TaskThread thread1 = new TaskThread("Thread 1", tryLockTask);
+        TaskThread thread2 = new TaskThread("Thread 2", tryLockTask);
+        TaskThread thread3 = new TaskThread("Thread 3", tryLockTask);
 
         thread1.start();
         thread2.start();
@@ -47,9 +47,9 @@ public void testTryLockWithTimeout() {
     @Test
     public void testTryLockWithTimeoutAndNanos() {
         LockInterruptiblyTask lockInterruptiblyTask = new LockInterruptiblyTask();
-        MyThread thread1 = new MyThread("Thread 1", lockInterruptiblyTask);
-        MyThread thread2 = new MyThread("Thread 2", lockInterruptiblyTask);
-        MyThread thread3 = new MyThread("Thread 3", lockInterruptiblyTask);
+        TaskThread thread1 = new TaskThread("Thread 1", lockInterruptiblyTask);
+        TaskThread thread2 = new TaskThread("Thread 2", lockInterruptiblyTask);
+        TaskThread thread3 = new TaskThread("Thread 3", lockInterruptiblyTask);
 
         thread1.start();
         thread2.start();

demo-thread/src/test/java/com/helltractor/demo/reentrantlock/ReentrantReadWriteLockTest.java

@@ -12,10 +12,10 @@ public class ReentrantReadWriteLockTest {
     public void testReentrantReadWriteLock() {
 
         ExecutorService executorService = Executors.newCachedThreadPool();
-        ReentrantReadWriteLockDemo demo = new ReentrantReadWriteLockDemo();
+        ReentrantReadWriteLockSample sample = new ReentrantReadWriteLockSample();
         for (int i = 0; i < 20; i++) {
-            executorService.execute(demo.new MyThread());
-            demo.cache.get(0);
+            executorService.execute(new ReentrantReadWriteLockSample.ReentrantReadWriteLockThread());
+            sample.cache.get(0);
         }
         executorService.shutdown();
     }