From 3b7bd3999a5d7fa3a4240f43432bba2c8e06e19e Mon Sep 17 00:00:00 2001 From: javahongxi Date: Sun, 11 Aug 2019 19:23:04 +0800 Subject: [PATCH] concurrent test --- .../hongxi/java/util/concurrent/CompletionServiceTest.java | 6 +++--- .../java/org/hongxi/java/util/concurrent/InterruptTest.java | 2 +- .../{InterruptTest2.java => InterruptedTest.java} | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) rename whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/{InterruptTest2.java => InterruptedTest.java} (93%) diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CompletionServiceTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CompletionServiceTest.java index 4753aec6..028f4863 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CompletionServiceTest.java +++ b/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 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; }); } diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest.java index eb5a85f6..62e9f695 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest.java +++ b/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 { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest2.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java similarity index 93% rename from whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest2.java rename to whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java index 06a92097..3d560f17 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptTest2.java +++ b/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(() -> { -- GitLab