concurrent test

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CompletionServiceTest.java

@@ -11,10 +11,10 @@ public class CompletionServiceTest {
     public static void main(String[] args) {
         ExecutorService executor = Executors.newFixedThreadPool(10);
         CompletionService<Integer> completionService = new ExecutorCompletionService<>(executor);
-        for (int i = 1; i <= 10; i++) {
-            final int seq = i;
+        for (int i = 0; i < 10; i++) {
+            final int seq = i + 1;
             completionService.submit(() -> {
-                Thread.sleep(new Random().nextInt(5000));
+                Thread.sleep(new Random().nextInt(3000));
                 return seq;
             });
         }

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest.java

@@ -5,7 +5,7 @@ package org.hongxi.java.util.concurrent;
  *
  * @author shenhongxi
  *
- * @see InterruptTest2
+ * @see InterruptedTest
  */
 public class InterruptTest {
 

whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest2.java → whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java

@@ -5,7 +5,7 @@ package org.hongxi.java.util.concurrent;
  *
  * @author shenhongxi
  */
-public class InterruptTest2 {
+public class InterruptedTest {
 
     public static void main(String[] args) {
         Thread t = new Thread(() -> {