update thread (#150)

realDuYuanChao · github-actions · web-flow · commit 636a350755b0 · 2021-08-09T11:02:44.000+08:00
* update thread

* Formatted with Google Java Formatter

Co-authored-by: github-actions &lt;${GITHUB_ACTOR}@users.noreply.github.com&gt;
diff --git a/src/main/java/com/examplehub/basics/lambda/SumWithLambda.java b/src/main/java/com/examplehub/basics/lambda/SumWithLambda.java
@@ -0,0 +1,5 @@
+package com.examplehub.basics.lambda;
+
+public interface SumWithLambda {
+  public int sum(int n);
+}
diff --git a/src/main/java/com/examplehub/basics/thread/CallableExample.java b/src/main/java/com/examplehub/basics/thread/CallableExample.java
@@ -0,0 +1,15 @@
+package com.examplehub.basics.thread;
+
+import java.util.concurrent.Callable;
+
+public class CallableExample implements Callable<Integer> {
+
+  @Override
+  public Integer call() throws Exception {
+    int sum = 0;
+    for (int i = 1; i <= 100; ++i) {
+      sum += i;
+    }
+    return sum;
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/DaemonThread.java b/src/main/java/com/examplehub/basics/thread/DaemonThread.java
@@ -0,0 +1,11 @@
+package com.examplehub.basics.thread;
+
+public class DaemonThread implements Runnable {
+
+  @Override
+  public void run() {
+    while (Thread.currentThread().getState() != Thread.State.TERMINATED) {
+      System.out.println("daemon thread is terminated");
+    }
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/JoinThread.java b/src/main/java/com/examplehub/basics/thread/JoinThread.java
@@ -0,0 +1,10 @@
+package com.examplehub.basics.thread;
+
+public class JoinThread implements Runnable {
+  @Override
+  public void run() {
+    for (int i = 0; i < 10; i++) {
+      System.out.println(Thread.currentThread().getName() + i);
+    }
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/PriorityOfThread.java b/src/main/java/com/examplehub/basics/thread/PriorityOfThread.java
@@ -0,0 +1,9 @@
+package com.examplehub.basics.thread;
+
+public class PriorityOfThread implements Runnable {
+  @Override
+  public void run() {
+    System.out.println(
+        Thread.currentThread().getName() + "-> priority = " + Thread.currentThread().getPriority());
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/StateOfThread.java b/src/main/java/com/examplehub/basics/thread/StateOfThread.java
@@ -0,0 +1,15 @@
+package com.examplehub.basics.thread;
+
+public class StateOfThread implements Runnable {
+
+  @Override
+  public void run() {
+    for (int i = 0; i < 5; i++) {
+      try {
+        Thread.sleep(1000);
+      } catch (InterruptedException e) {
+        e.printStackTrace();
+      }
+    }
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/StopThread.java b/src/main/java/com/examplehub/basics/thread/StopThread.java
@@ -0,0 +1,25 @@
+package com.examplehub.basics.thread;
+
+public class StopThread implements Runnable {
+
+  private boolean flag = true;
+
+  @Override
+  public synchronized void run() {
+    while (true) {
+      for (int i = 1; ; ++i) {
+        System.out.println(i);
+        try {
+          Thread.sleep(500);
+        } catch (InterruptedException e) {
+          e.printStackTrace();
+        }
+      }
+    }
+  }
+
+  public void stop() {
+    flag = false;
+    System.out.println("sub thread stopped");
+  }
+}
diff --git a/src/main/java/com/examplehub/basics/thread/YieldThread.java b/src/main/java/com/examplehub/basics/thread/YieldThread.java
@@ -0,0 +1,11 @@
+package com.examplehub.basics.thread;
+
+public class YieldThread implements Runnable {
+
+  @Override
+  public void run() {
+    System.out.println(Thread.currentThread().getName() + " is running");
+    Thread.yield();
+    System.out.println(Thread.currentThread().getName() + " is stopped");
+  }
+}
diff --git a/src/main/java/com/examplehub/leetcode/easy/ThirdMaximumNumber.java b/src/main/java/com/examplehub/leetcode/easy/ThirdMaximumNumber.java
@@ -0,0 +1,20 @@
+package com.examplehub.leetcode.easy;
+
+import java.util.Arrays;
+import java.util.HashSet;
+
+/** https://leetcode.com/problems/third-maximum-number/ */
+public class ThirdMaximumNumber {
+  public static int solution1(int... nums) {
+    HashSet<Integer> set = new HashSet<>();
+    for (int num : nums) {
+      set.add(num);
+    }
+    int i = 0;
+    for (int num : set) {
+      nums[i++] = num;
+    }
+    Arrays.sort(nums, 0, i);
+    return i < 3 ? nums[i - 1] : nums[i - 3];
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/lambda/SumWithLambdaTest.java b/src/test/java/com/examplehub/basics/lambda/SumWithLambdaTest.java
@@ -0,0 +1,20 @@
+package com.examplehub.basics.lambda;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+class SumWithLambdaTest {
+  @Test
+  void testLambda() {
+    SumWithLambda sumWithLambda =
+        n -> {
+          int total = 0;
+          for (int i = 1; i <= n; ++i) {
+            total = total + i;
+          }
+          return total;
+        };
+    assertEquals(5050, sumWithLambda.sum(100));
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/CallableExampleTest.java b/src/test/java/com/examplehub/basics/thread/CallableExampleTest.java
@@ -0,0 +1,19 @@
+package com.examplehub.basics.thread;
+
+import java.util.concurrent.ExecutionException;
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+import org.junit.jupiter.api.*;
+import org.junit.jupiter.api.Test;
+
+class CallableExampleTest {
+  @Test
+  void test() throws ExecutionException, InterruptedException {
+    ExecutorService executorService = Executors.newFixedThreadPool(1);
+    Future<Integer> result = executorService.submit(new CallableExample());
+    int callableSum = result.get();
+    Assertions.assertEquals(5050, callableSum);
+    executorService.shutdown();
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/DaemonThreadTest.java b/src/test/java/com/examplehub/basics/thread/DaemonThreadTest.java
@@ -0,0 +1,15 @@
+package com.examplehub.basics.thread;
+
+import org.junit.jupiter.api.Test;
+
+class DaemonThreadTest {
+  @Test
+  void test() {
+    Thread thread = new Thread(new DaemonThread());
+    thread.setDaemon(true);
+    thread.start();
+    for (int i = 0; i < 10; i++) {
+      System.out.println("main thread");
+    }
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/JoinThreadTest.java b/src/test/java/com/examplehub/basics/thread/JoinThreadTest.java
@@ -0,0 +1,17 @@
+package com.examplehub.basics.thread;
+
+import org.junit.jupiter.api.Test;
+
+class JoinThreadTest {
+  @Test
+  void test() throws InterruptedException {
+    Thread thread = new Thread(new JoinThread());
+    thread.start();
+    for (int i = 0; i < 10; i++) {
+      if (i == 1) {
+        thread.join();
+      }
+      System.out.println(Thread.currentThread().getName() + i);
+    }
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/PriorityOfThreadTest.java b/src/test/java/com/examplehub/basics/thread/PriorityOfThreadTest.java
@@ -0,0 +1,23 @@
+package com.examplehub.basics.thread;
+
+import org.junit.jupiter.api.Test;
+
+class PriorityOfThreadTest {
+  @Test
+  void test() {
+    Thread first = new Thread(new PriorityOfThread());
+    first.setPriority(3);
+
+    Thread second = new Thread(new PriorityOfThread());
+    second.setPriority(5);
+
+    Thread third = new Thread(new PriorityOfThread());
+    second.setPriority(Thread.MAX_PRIORITY);
+
+    first.start();
+    second.start();
+    third.start();
+    System.out.println(
+        Thread.currentThread().getName() + "-> priority = " + Thread.currentThread().getPriority());
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/StateOfThreadTest.java b/src/test/java/com/examplehub/basics/thread/StateOfThreadTest.java
@@ -0,0 +1,21 @@
+package com.examplehub.basics.thread;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+class StateOfThreadTest {
+  @Test
+  void test() {
+    Thread thread = new Thread(new StateOfThread());
+    assertEquals(Thread.State.NEW, thread.getState());
+
+    thread.start();
+    assertEquals(Thread.State.RUNNABLE, thread.getState());
+
+    while (thread.getState() != Thread.State.TERMINATED) {
+      System.out.println(thread.getState());
+    }
+    System.out.println(thread.getState());
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/StopThreadTest.java b/src/test/java/com/examplehub/basics/thread/StopThreadTest.java
@@ -0,0 +1,18 @@
+package com.examplehub.basics.thread;
+
+import org.junit.jupiter.api.Test;
+
+class StopThreadTest {
+  @Test
+  void test() {
+    StopThread stopThread = new StopThread();
+    new Thread(stopThread).start();
+    try {
+      Thread.sleep(5000);
+    } catch (InterruptedException e) {
+      e.printStackTrace();
+    }
+    stopThread.stop();
+    System.out.println("main thread stopped");
+  }
+}
diff --git a/src/test/java/com/examplehub/basics/thread/YieldThreadTest.java b/src/test/java/com/examplehub/basics/thread/YieldThreadTest.java
@@ -0,0 +1,14 @@
+package com.examplehub.basics.thread;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+class YieldThreadTest {
+  @Test
+  void test() {
+    YieldThread yieldThread = new YieldThread();
+    new Thread(yieldThread).start();
+    new Thread(yieldThread).start();
+  }
+}
diff --git a/src/test/java/com/examplehub/leetcode/easy/ThirdMaximumNumberTest.java b/src/test/java/com/examplehub/leetcode/easy/ThirdMaximumNumberTest.java
@@ -0,0 +1,14 @@
+package com.examplehub.leetcode.easy;
+
+import static org.junit.jupiter.api.Assertions.*;
+
+import org.junit.jupiter.api.Test;
+
+class ThirdMaximumNumberTest {
+  @Test
+  void testSolution1() {
+    assertEquals(1, ThirdMaximumNumber.solution1(3, 2, 1));
+    assertEquals(2, ThirdMaximumNumber.solution1(1, 2));
+    assertEquals(1, ThirdMaximumNumber.solution1(2, 2, 3, 1));
+  }
+}
