首页 > 编程语言 >教你如何判断Java代码中异步操作是否完成

教你如何判断Java代码中异步操作是否完成

时间:2024-02-26 10:34:41浏览次数:32  
标签:异步 Java java 代码 Callable 任务 Future import

本文分享自华为云社区《java代码实现异步返回结果如何判断异步执行完成》,作者: 皮牙子抓饭。

在许多应用程序中,我们经常使用异步操作来提高性能和响应度。在Java中,我们可以使用多线程或者异步任务来执行耗时操作,并且在后台处理过程完成后获取结果。但是,在使用异步操作时,我们通常需要知道异步任务何时完成,以便进行下一步的操作。 本篇文章将介绍几种常见的方法来判断Java代码中异步操作是否完成。

1. 使用Future和Callable

Java中的Future接口定义了一种方式来表示异步操作的未来结果。我们可以使用Callable接口来定义异步任务,它返回一个Future对象,我们可以利用Future对象的方法来检查任务是否完成。 下面是一个例子:

javaCopy code
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class AsyncDemo {
    public static void main(String[] args) throws Exception {
        ExecutorService executorService = Executors.newSingleThreadExecutor();
        // 定义异步任务
        Callable<String> asyncTask = () -> {
            Thread.sleep(2000); // 模拟耗时操作
            return "Async task completed";
        };
        // 提交异步任务
        Future<String> future = executorService.submit(asyncTask);
        // 判断任务是否完成
        while (!future.isDone()) {
            System.out.println("Task not done yet...");
            Thread.sleep(500);
        }
        // 获取结果
        String result = future.get();
        System.out.println(result);
        // 关闭线程池
        executorService.shutdown();
    }
}

在上面的代码中,我们创建了一个单线程的ExecutorService来执行异步任务。我们使用submit方法提交异步任务,并得到一个Future对象。然后,我们可以使用isDone()方法来判断任务是否完成,如果任务没有完成,则等待片刻后再次检查。一旦任务完成,我们可以使用get()方法获取任务的结果。

2. 使用CompletableFuture

自Java 8起,Java提供了CompletableFuture类来更加方便地处理异步操作。CompletableFuture是Future的一个实现,同时也支持对未来结果的处理和组合。 下面是一个例子:

javaCopy code
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.TimeUnit;
public class AsyncDemo {
    public static void main(String[] args) throws Exception {
        // 定义异步任务
        CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
            try {
                TimeUnit.SECONDS.sleep(2); // 模拟耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            return "Async task completed";
        });
        // 判断任务是否完成
        while (!future.isDone()) {
            System.out.println("Task not done yet...");
            TimeUnit.MILLISECONDS.sleep(500);
        }
        // 获取结果
        String result = future.get();
        System.out.println(result);
    }
}

在上述代码中,我们使用supplyAsync方法创建了一个CompletableFuture对象,并定义了异步任务。然后,我们可以使用isDone()方法来判断任务是否完成。通过调用get()方法可以获取最终的结果。

当涉及到实际应用场景时,异步操作的一个常见用例是在Web应用中执行并行的HTTP请求以提高性能。以下是一个示例代码,展示了如何使用异步操作来执行多个HTTP请求,并在所有请求完成后进行处理。

javaCopy code
import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.net.HttpURLConnection;
import java.net.URL;
import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;
public class AsyncHttpExample {
    public static void main(String[] args) throws Exception {
        List<Future<String>> futures = new ArrayList<>();
        
        ExecutorService executor = Executors.newFixedThreadPool(5);
        
        List<String> urls = List.of(
                "https://www.example.com/api1",
                "https://www.example.com/api2",
                "https://www.example.com/api3"
        );
        
        for (String url : urls) {
            Callable<String> task = () -> {
                return performRequest(url);
            };
            
            Future<String> future = executor.submit(task);
            futures.add(future);
        }
        
        executor.shutdown();
        
        for (Future<String> future : futures) {
            try {
                String result = future.get();
                System.out.println("Received response: " + result);
            } catch (InterruptedException | ExecutionException e) {
                e.printStackTrace();
            }
        }
    }
    
    private static String performRequest(String url) throws IOException {
        HttpURLConnection connection = null;
        BufferedReader reader = null;
        StringBuilder response = new StringBuilder();
        
        try {
            URL requestUrl = new URL(url);
            connection = (HttpURLConnection) requestUrl.openConnection();
            connection.setRequestMethod("GET");
            
            reader = new BufferedReader(new InputStreamReader(connection.getInputStream()));
            String line;
            
            while ((line = reader.readLine()) != null) {
                response.append(line);
            }
        } finally {
            if (connection != null) {
                connection.disconnect();
            }
            
            if (reader != null) {
                reader.close();
            }
        }
        
        return response.toString();
    }
}

在这个示例中,我们创建了一个固定大小的线程池,并为每个URL创建了一个异步任务。每个任务在自己的线程中执行HTTP请求,并返回响应结果。我们使用Future来跟踪每个任务的执行状态和结果。一旦所有任务都被提交,我们调用shutdown()方法关闭线程池,然后通过迭代每个Future对象,使用get()方法获取任务的结果。最后,我们可以根据需要对结果进行进一步处理,这里只是简单地打印出每个请求的响应。

java.util.concurrent.Callable 是 Java 并发编程中的一个接口,它表示一个可调用的任务,可以在计算中返回一个值。与 Runnable 接口不同,Callable 接口的 call() 方法可以返回一个结果,并且可以在执行过程中抛出受检异常。 Callable 接口定义了以下方法:

  • V call() throws Exception:执行任务并返回结果。可以抛出受检异常。
  • boolean equals(Object obj):比较该 Callable 与指定对象是否相等。
  • default <U> Callable<U> compose(Function<? super V, ? extends U> var1):将该 Callable 的结果应用于给定函数,并返回 Callable。
  • default <V2> Callable<V2> andThen(Function<? super V, ? extends V2> var1):将给定函数应用于该 Callable 的结果,并返回新的 Callable。
  • default Predicate<V> isEqual(Object var1):返回谓词,用于判断对象是否与这个 Callable 的结果相等。
  • default Supplier<V> toSupplier():返回将该 Callable 的结果作为值的供应商。 在实际应用中,Callable 接口常常与 ExecutorService 结合使用,通过将 Callable 对象提交给线程池来执行。线程池会返回一个 Future 对象,用于跟踪任务的执行状态和获取结果。 以下是一个示例代码,展示了如何使用 Callable 接口:
javaCopy code
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableExample {
    public static void main(String[] args) throws Exception {
        Callable<Integer> task = () -> {
            int sum = 0;
            for (int i = 1; i <= 100; i++) {
                sum += i;
            }
            return sum;
        };
        
        ExecutorService executor = Executors.newSingleThreadExecutor();
        Future<Integer> future = executor.submit(task);
        
        // 可以在此处执行其他任务
        
        Integer result = future.get(); // 获取任务的结果,会阻塞直到任务完成
        System.out.println("Sum: " + result);
        
        executor.shutdown();
    }
}

在上述示例中,我们创建了一个实现了 Callable 接口的任务,并将其提交给一个单线程的线程池来执行。我们通过 Future 对象来获取 Callable 任务的执行结果,其中 get() 方法会阻塞当前线程,直到任务完成并返回结果。

总结

通过使用Future和CompletableFuture,我们可以方便地判断Java代码中异步操作的执行是否完成。这样,我们就可以在异步操作完成后获取结果,并且继续进行后续的操作。这种方式提高了代码的响应性和性能,使我们能够更好地处理并发和异步任务。

 

点击关注,第一时间了解华为云新鲜技术~

 

标签:异步,Java,java,代码,Callable,任务,Future,import
From: https://www.cnblogs.com/huaweiyun/p/18033769

相关文章

  • 代码随想录 day61 每日温度 下一个更大元素 I
    每日温度单调栈的作用就是记录之前的元素好与当前元素比较从栈顶到栈底单调增找第一个第一个大元素单调减找第一个小元素栈内存的是数组下标而不是数组元素因为存元素还要会数组找元素是谁存下标可以直接用栈元素作为索引找数组元素下一个更大元素I跟每日温度......
  • JavaFlink系列之一:Maven程序搭建及Java入门案例多种写法
    JavaFlink系列之一:Maven程序搭建及Java入门案例多种写法 一、Flink项目依赖配置<?xmlversion="1.0"encoding="UTF-8"?><projectxmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xmlns="http://maven.apache.org/POM/4.0.0"......
  • 【译】代码更快、更好,借助 GitHub Copilot 的新功能:斜杠命令和上下文变量
    你是否曾经希望有一个人工智能助手可以帮助你更快更好地编写代码?那就是VisualStudioCopilotChat为您提供的:一个人工智能驱动的结对程序员,可以回答您的问题,建议代码片段,解释代码逻辑,并与您讨论您的项目。您可以使用Copilot更快更好地编写代码,因为它可以帮助您避免错误并......
  • java实现scp功能实现目录下所有文件拷贝至指定服务器
    1、添加pom依赖<dependency><groupId>com.jcraft</groupId><artifactId>jsch</artifactId><version>0.1.55</version></dependency>2、示例代码publicstaticvoidmain(String[]args)throwsIOException{try{......
  • Java中的数组-暂未完结
    数组的定义数组是相同类型数据的有序集合数组描述的是相同类型的若干个数据,按照一定的先后次序排列组合而成。◆其中,每一个数据称作一个数组元素,每个数组元素可以通过一个下标来访问它们。数组声明创建◆首先必须声明数组变量,才能在程序中使用数组。下面是声明数组变量的......
  • 类变量和类方法、代码块、单例设计模式、final关键字、抽象类、接口、内部类
    类变量和类方法类变量-提出问题说:有一群小孩在玩堆雪人,不时有新的小孩加入,请问如何知道现在共有多少人在玩?,编写程序解决。传统的方法来解决思路在main方法中定义一个变量count当一个小孩加入游戏后count++,最后个count就记录有多少小孩玩游戏小孩是一个类,有名字属......
  • Java HashMap merge() 方法
    在3020.子集中元素的最大数量【力扣周赛382】用哈希表统计元素个数使用点击查看代码classSolution{publicintmaximumLength(int[]nums){Map<Long,Integer>cnt=newHashMap<>();for(intx:nums){cnt.merge((long)x,1,In......
  • c#判断代码是否执行超时的几种方式
    c#判断代码是否执行超时的几种方式第一种,使用委托:第二种,使用Task:第三种,使用Timer:第四种,使用Thread:转载:https://blog.csdn.net/Learn_change_myself/article/details/105199967?utm_medium=distribute.pc_relevant_download.none-task-blog-baidujs-2.nonecase&depth_1-......
  • java中的基础方法使用
    何谓方法?◆System.out.printIn(),那么它是什么呢?◆Java方法是语句的集合,它们在一起执行一个功能。◆方法是解决一类问题的步骤的有序组合◆方法包含于类或对象中◆方法在程序中被创建,在其他地方被引用设计方法的原则:方法的本意是功能块,就是实现某个功能的语句块的集合。我......
  • 个人在学习过程中对多线程和异步的理解
    私人对于异步与多线程的理解前言​ 异步与多线程都是并发问题的一种解决方式,但是异步是程序员层面,线程是操作系统层面的。​ 其次,异步与线程解决并发问题的实现方式和目的是不同的。下面举一个不太贴切的例子。如果把线程当作一条单行道,那么多线程就是通过扩展多条道路从而实现......