⚰️ 🍻 💩

Author: shuxuecode

toolTest/common/src/test/java/tool/guava/ListeningExecutorServiceTest.java

@@ -1,15 +1,17 @@
 package tool.guava;
 
+import com.google.common.base.Function;
 import com.google.common.util.concurrent.*;
+import org.checkerframework.checker.nullness.qual.Nullable;
 import org.junit.jupiter.api.Test;
 
 import java.util.concurrent.ExecutorService;
 import java.util.concurrent.Executors;
 import java.util.concurrent.TimeUnit;
+import java.util.stream.IntStream;
 
 
 /**
- *
  * ListeningExecutorService 是Guava对Java标准库ExecutorService的扩展，
  * 1、支持回调机制：不再需要手动get()等待结果，任务完成后自动触发回调
  * 2、返回ListenableFuture：支持链式操作
@@ -21,13 +23,13 @@
 public class ListeningExecutorServiceTest {
 
 
+    ExecutorService executorService = Executors.newFixedThreadPool(8);
 
+    ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(executorService);
 
-    @Test void t1(){
-
-        ExecutorService executorService = Executors.newFixedThreadPool(8);
 
-        ListeningExecutorService listeningExecutorService = MoreExecutors.listeningDecorator(executorService);
+    @Test
+    void t1() {
 
 
         ListenableFuture<?> future = listeningExecutorService.submit(() -> {
@@ -44,6 +46,7 @@ public class ListeningExecutorServiceTest {
             public void onSuccess(Object result) {
                 System.out.println("Task success");
             }
+
             @Override
             public void onFailure(Throwable t) {
                 System.out.println("Task fail");
@@ -59,7 +62,31 @@ public void onFailure(Throwable t) {
     }
 
 
+    @Test
+    void v2() {
+        ListenableFuture<String> str = listeningExecutorService.submit(() -> {
+            System.out.println("123");
+            return "123";
+        });
+        ListenableFuture<Integer> transform = Futures.transform(str, new Function<String, Integer>() {
+            @Override
+            public Integer apply(String input) {
+                return Integer.valueOf(input);
+            }
+        }, MoreExecutors.directExecutor());
+
+        Futures.addCallback(transform, new FutureCallback<Integer>() {
+            @Override
+            public void onSuccess(@Nullable Integer result) {
+                System.out.println("Task success " + result);
+            }
+            @Override
+            public void onFailure(Throwable t) {
+                System.out.println("Task fail");
+            }
+        }, MoreExecutors.directExecutor());
 
+    }
 
 
 }