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

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();
    }
}

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);
    }
}

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();
    }
}

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();
    }
}