Guava Future

Posted 2021-12-19 水田如雅

 @Test
    public void test2() throws ExecutionException, InterruptedException 
        ExecutorService executorService = Executors.newFixedThreadPool(2);
        Future<String> f1 = executorService.submit(() -> "r1");
        Future<String> f2 = executorService.submit(() -> "r2");
        while (true) 
            if (f1.isDone() & f2.isDone()) 
                System.out.println(f1.get() + "|" + f2.get());
                break;
            
        
    

    @Test
    public void test3() throws ExecutionException, InterruptedException 
        ListeningExecutorService executorService = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(2));
        ListenableFuture<String> f1 = executorService.submit(() -> "r1");
        Futures.addCallback(f1, new FutureCallback<String>() 
            @Override
            public void onSuccess(@Nullable String result) 
                System.out.println("result:" + result);
            

            @Override
            public void onFailure(Throwable t) 

            
        );
        ListenableFuture<String> f2 = executorService.submit(() -> "r2");
        Futures.addCallback(f2, new FutureCallback<String>() 
            @Override
            public void onSuccess(@Nullable String result) 
                System.out.println("result:" + result);
            

            @Override
            public void onFailure(Throwable t) 

            
        );