import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AdvancedConcurrency {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// Run a task asynchronously and process the result
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Data from Remote API";
});
// Chain another task to the result
future.thenAccept(result -> System.out.println("Processing: " + result))
.get(); // Blocks until complete (for demo purposes)
}
}
import java.util.concurrent.CompletableFuture;
import java.util.concurrent.ExecutionException;
public class AdvancedConcurrency {
public static void main(String[] args) throws ExecutionException, InterruptedException {
// Run a task asynchronously and process the result
CompletableFuture future = CompletableFuture.supplyAsync(() -> {
try { Thread.sleep(1000); } catch (InterruptedException e) {}
return "Data from Remote API";
});
}