From 683f28270c87a0c85fb5cbf06fb3257b0f3b68bb Mon Sep 17 00:00:00 2001 From: javahongxi Date: Sun, 11 Aug 2019 19:44:25 +0800 Subject: [PATCH] java --- .../hongxi/whatsmars/common/Constants.java | 4 +--- .../java/org/hongxi/java/net/TCPClient.java | 3 +++ .../java/org/hongxi/java/net/TCPServer.java | 3 +++ .../java/org/hongxi/java/net/UDPClient.java | 3 +++ .../java/org/hongxi/java/net/UDPServer.java | 3 +++ .../org/hongxi/java/nio/MappedFileTest.java | 3 +++ .../org/hongxi/java/nio/MultiPortEcho.java | 3 +++ .../java/org/hongxi/java/util/Java8Test.java | 3 +++ .../java/util/concurrent/CallableTest.java | 5 ++-- .../concurrent/CompletionServiceTest.java | 4 ++++ .../util/concurrent/CountDownLatchTest.java | 4 +--- .../util/concurrent/CyclicBarrierTest.java | 24 +++++++++++-------- .../java/util/concurrent/ExchangerTest.java | 3 +++ .../java/util/concurrent/FutureTaskTest.java | 5 ++-- .../java/util/concurrent/InterruptTest.java | 4 +--- .../java/util/concurrent/InterruptedTest.java | 9 ++++--- .../java/util/concurrent/InvokeAllTest.java | 4 +--- .../util/concurrent/ReentrantLockTest.java | 3 +++ .../java/util/concurrent/RunnableTest.java | 4 +--- .../java/util/concurrent/ScheduleTest.java | 4 +--- 20 files changed, 59 insertions(+), 39 deletions(-) diff --git a/whatsmars-common/src/main/java/org/hongxi/whatsmars/common/Constants.java b/whatsmars-common/src/main/java/org/hongxi/whatsmars/common/Constants.java index cf1ed89a..c0e69406 100644 --- a/whatsmars-common/src/main/java/org/hongxi/whatsmars/common/Constants.java +++ b/whatsmars-common/src/main/java/org/hongxi/whatsmars/common/Constants.java @@ -3,9 +3,7 @@ package org.hongxi.whatsmars.common; import java.util.regex.Pattern; /** - * Created on 2019/8/5. - * - * @author shenhongxi + * @author shenhongxi 2019/8/5 */ public class Constants { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/net/TCPClient.java b/whatsmars-common/src/test/java/org/hongxi/java/net/TCPClient.java index 8e2f4a4c..62896b96 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/net/TCPClient.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/net/TCPClient.java @@ -5,6 +5,9 @@ import java.io.IOException; import java.net.Socket; import java.net.UnknownHostException; +/** + * Created by javahongxi on 2018/1/2. + */ public class TCPClient { public static void main(String[] args) { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/net/TCPServer.java b/whatsmars-common/src/test/java/org/hongxi/java/net/TCPServer.java index 5807c055..91ace2d5 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/net/TCPServer.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/net/TCPServer.java @@ -6,6 +6,9 @@ import java.net.BindException; import java.net.ServerSocket; import java.net.Socket; +/** + * Created by javahongxi on 2018/1/2. + */ public class TCPServer { boolean started; ServerSocket ss; diff --git a/whatsmars-common/src/test/java/org/hongxi/java/net/UDPClient.java b/whatsmars-common/src/test/java/org/hongxi/java/net/UDPClient.java index a5e4d1a3..be278255 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/net/UDPClient.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/net/UDPClient.java @@ -7,6 +7,9 @@ import java.net.DatagramPacket; import java.net.DatagramSocket; import java.net.InetSocketAddress; +/** + * Created by javahongxi on 2018/1/2. + */ public class UDPClient { public static void main(String[] args) { try { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/net/UDPServer.java b/whatsmars-common/src/test/java/org/hongxi/java/net/UDPServer.java index 97a25f6b..a9436afd 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/net/UDPServer.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/net/UDPServer.java @@ -6,6 +6,9 @@ import java.io.IOException; import java.net.DatagramPacket; import java.net.DatagramSocket; +/** + * Created by javahongxi on 2018/1/2. + */ public class UDPServer { public static void main(String[] args) { try { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/nio/MappedFileTest.java b/whatsmars-common/src/test/java/org/hongxi/java/nio/MappedFileTest.java index 5fade4f1..d46d41d6 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/nio/MappedFileTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/nio/MappedFileTest.java @@ -4,6 +4,9 @@ import java.io.RandomAccessFile; import java.nio.MappedByteBuffer; import java.nio.channels.FileChannel; +/** + * Created by javahongxi on 2018/1/2. + */ public class MappedFileTest { static private final int start = 0; static private final int size = 1024; diff --git a/whatsmars-common/src/test/java/org/hongxi/java/nio/MultiPortEcho.java b/whatsmars-common/src/test/java/org/hongxi/java/nio/MultiPortEcho.java index 5a9b203b..a7ab139b 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/nio/MultiPortEcho.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/nio/MultiPortEcho.java @@ -11,6 +11,9 @@ import java.nio.channels.SocketChannel; import java.util.Iterator; import java.util.Set; +/** + * Created by javahongxi on 2018/1/2. + */ public class MultiPortEcho { private int ports[]; private ByteBuffer echoBuffer = ByteBuffer.allocate(1024); diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/Java8Test.java b/whatsmars-common/src/test/java/org/hongxi/java/util/Java8Test.java index f63c82fa..a5c36b1c 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/Java8Test.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/Java8Test.java @@ -9,6 +9,9 @@ import java.nio.charset.StandardCharsets; import java.time.*; import java.util.Base64; +/** + * Created by javahongxi on 2018/1/2. + */ public class Java8Test { @Test diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CallableTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CallableTest.java index c62cb504..29a0fce1 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CallableTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CallableTest.java @@ -5,14 +5,13 @@ import java.util.concurrent.Executors; import java.util.concurrent.Future; /** - * Created on 2019/8/8. - * - * @author shenhongxi + * @author shenhongxi 2019/8/8 */ public class CallableTest { public static void main(String[] args) throws Exception { ExecutorService executorService = Executors.newSingleThreadExecutor(); + // submit(Callable) Future future = executorService.submit(() -> { Thread.sleep(2000); return "hello"; 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 028f4863..cc586986 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,6 +11,8 @@ public class CompletionServiceTest { public static void main(String[] args) { ExecutorService executor = Executors.newFixedThreadPool(10); CompletionService completionService = new ExecutorCompletionService<>(executor); + + // produce for (int i = 0; i < 10; i++) { final int seq = i + 1; completionService.submit(() -> { @@ -18,6 +20,8 @@ public class CompletionServiceTest { return seq; }); } + + // consume for (int i = 0; i < 10; i++) { try { System.out.println(completionService.take().get()); diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CountDownLatchTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CountDownLatchTest.java index 60dc99e2..3e5c6095 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CountDownLatchTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CountDownLatchTest.java @@ -3,9 +3,7 @@ package org.hongxi.java.util.concurrent; import java.util.concurrent.CountDownLatch; /** - * Created on 2019/8/11. - * - * @author shenhongxi + * @author shenhongxi 2019/8/11 * * @see JoinTest * @see InvokeAllTest diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CyclicBarrierTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CyclicBarrierTest.java index 32c1d6cb..6b350402 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CyclicBarrierTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/CyclicBarrierTest.java @@ -4,11 +4,14 @@ import java.util.concurrent.CyclicBarrier; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +/** + * @author shenhongxi 2019/8/11 + */ public class CyclicBarrierTest { public static void main(String[] args) { ExecutorService executorService = Executors.newCachedThreadPool(); - final CyclicBarrier cb = new CyclicBarrier(3); + final CyclicBarrier barrier = new CyclicBarrier(3); for (int i = 0; i < 3; i++) { executorService.execute(() -> { try { @@ -16,30 +19,31 @@ public class CyclicBarrierTest { System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点1，当前已有" - + (cb.getNumberWaiting() + 1) + + (barrier.getNumberWaiting() + 1) + "个已经到达，" - + (cb.getNumberWaiting() == 2 ? "都到齐了，继续走啊" + + (barrier.getNumberWaiting() == 2 ? "都到齐了，继续走啊" : "正在等候")); - cb.await(); + barrier.await(); Thread.sleep((long) (Math.random() * 10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点2，当前已有" - + (cb.getNumberWaiting() + 1) + + (barrier.getNumberWaiting() + 1) + "个已经到达，" - + (cb.getNumberWaiting() == 2 ? "都到齐了，继续走啊" + + (barrier.getNumberWaiting() == 2 ? "都到齐了，继续走啊" : "正在等候")); - cb.await(); + barrier.await(); + Thread.sleep((long) (Math.random() * 10000)); System.out.println("线程" + Thread.currentThread().getName() + "即将到达集合地点3，当前已有" - + (cb.getNumberWaiting() + 1) + + (barrier.getNumberWaiting() + 1) + "个已经到达，" - + (cb.getNumberWaiting() == 2 ? "都到齐了，继续走啊" + + (barrier.getNumberWaiting() == 2 ? "都到齐了，继续走啊" : "正在等候")); - cb.await(); + barrier.await(); } catch (Exception e) { e.printStackTrace(); } diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ExchangerTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ExchangerTest.java index b449a610..778d318d 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ExchangerTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ExchangerTest.java @@ -4,6 +4,9 @@ import java.util.concurrent.Exchanger; import java.util.concurrent.ExecutorService; import java.util.concurrent.Executors; +/** + * @author shenhongxi 2019/8/11 + */ public class ExchangerTest { public static void main(String[] args) { ExecutorService executorService = Executors.newCachedThreadPool(); diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/FutureTaskTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/FutureTaskTest.java index 46b23144..ccf4864a 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/FutureTaskTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/FutureTaskTest.java @@ -5,15 +5,14 @@ import java.util.concurrent.Executors; import java.util.concurrent.FutureTask; /** - * Created on 2019/8/8. - * - * @author shenhongxi + * @author shenhongxi 2019/8/8 */ public class FutureTaskTest { public static void main(String[] args) throws Exception { ExecutorService executorService = Executors.newCachedThreadPool(); FutureTask task = new FutureTask<>(() -> "hello"); + // submit(Runnable) executorService.submit(task); FutureTask task2 = new FutureTask<>(() -> System.out.println("..."), "world"); 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 62e9f695..8fb25715 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 @@ -1,9 +1,7 @@ package org.hongxi.java.util.concurrent; /** - * Created on 2019/8/10. - * - * @author shenhongxi + * @author shenhongxi 2019/8/10 * * @see InterruptedTest */ diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java index 3d560f17..6ed37364 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InterruptedTest.java @@ -1,16 +1,15 @@ package org.hongxi.java.util.concurrent; /** - * Created on 2019/8/10. - * - * @author shenhongxi + * @author shenhongxi 2019/8/10 */ public class InterruptedTest { public static void main(String[] args) { Thread t = new Thread(() -> { - System.out.println(Thread.interrupted()); // currentThread().isInterrupted(true); - System.out.println(Thread.interrupted()); + // currentThread().isInterrupted(true); + System.out.println(Thread.interrupted()); // true + System.out.println(Thread.interrupted()); // false }); t.start(); t.interrupt(); // Just to set the interrupt flag diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InvokeAllTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InvokeAllTest.java index 38c1e647..ad7f01ae 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InvokeAllTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/InvokeAllTest.java @@ -6,9 +6,7 @@ import java.util.List; import java.util.concurrent.*; /** - * Created on 2019/8/11. - * - * @author shenhongxi + * @author shenhongxi 2019/8/11 */ public class InvokeAllTest { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ReentrantLockTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ReentrantLockTest.java index a95e1028..609d9e89 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ReentrantLockTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ReentrantLockTest.java @@ -4,6 +4,9 @@ import java.util.concurrent.locks.Condition; import java.util.concurrent.locks.Lock; import java.util.concurrent.locks.ReentrantLock; +/** + * @author shenhongxi 2019/8/11 + */ public class ReentrantLockTest { public static void main(String[] args) { diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/RunnableTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/RunnableTest.java index c2e2e9be..0f242afe 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/RunnableTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/RunnableTest.java @@ -6,9 +6,7 @@ import java.util.concurrent.Future; import java.util.stream.IntStream; /** - * Created on 2019/8/8. - * - * @author shenhongxi + * @author shenhongxi 2019/8/8 * * @see CallableTest * @see FutureTaskTest diff --git a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ScheduleTest.java b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ScheduleTest.java index 357cbc10..ccc8d673 100644 --- a/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ScheduleTest.java +++ b/whatsmars-common/src/test/java/org/hongxi/java/util/concurrent/ScheduleTest.java @@ -7,9 +7,7 @@ import java.util.concurrent.ScheduledFuture; import java.util.concurrent.TimeUnit; /** - * Created on 2019/8/10. - * - * @author shenhongxi + * @author shenhongxi 2019/8/10 */ public class ScheduleTest { -- GitLab