concurrent test

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

+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+/**
+ * Created on 2019/8/8.
+ *
+ * @author shenhongxi
+ */
+public class CallableTest {
+
+    public static void main(String[] args) throws Exception {
+        ExecutorService executorService = Executors.newSingleThreadExecutor();
+        Future<String> future = executorService.submit(() -> {
+           Thread.sleep(2000);
+           return "hello";
+        });
+        long begin = System.currentTimeMillis();
+        System.out.println(future.get());
+        System.out.println(System.currentTimeMillis() - begin);
+    }
+}

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

+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.FutureTask;
+
+/**
+ * Created on 2019/8/8.
+ *
+ * @author shenhongxi
+ */
+public class FutureTaskTest {
+
+    public static void main(String[] args) throws Exception {
+        ExecutorService executorService = Executors.newCachedThreadPool();
+        FutureTask<String> task = new FutureTask<>(() -> "hello");
+        executorService.submit(task);
+        FutureTask<String> task2 = new FutureTask<>(() ->
+                System.out.println("..."), "world");
+        executorService.submit(task2);
+        System.out.println(task.get());
+        System.out.println(task2.get());
+
+    }
+}

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

+package org.hongxi.java.util.concurrent;
+
+import java.util.concurrent.ExecutorService;
+import java.util.concurrent.Executors;
+import java.util.concurrent.Future;
+
+/**
+ * Created on 2019/8/8.
+ *
+ * @author shenhongxi
+ */
+public class RunnableTest {
+
+    public static void main(String[] args) throws Exception {
+        ExecutorService executorService = Executors.newSingleThreadExecutor();
+        executorService.submit(() -> System.out.println("hello"));
+
+        Future<String> future = executorService.submit(() ->
+                System.out.println("..."), "world");
+        System.out.println(future.get());
+    }
+}