如何使用 Java Executors 和 CompletableFuture 非阻塞地执行任务？

使用 Java 执行器执行非阻塞任务

在处理多个任务队列时，避免可能消耗过多资源的阻塞操作至关重要堆栈空间。本文探讨了如何利用 Java 的 java.util.concurrent 包在不阻塞的情况下将任务提交给执行器，并利用任务完成通知的回调。

回调方法

定义接受任务所需结果或完成状态的回调接口。实现一个接受任务和回调的包装类。当任务完成时，包装器调用回调。

CompletableFuture 和异步执行

Java 8 引入了 CompletableFuture，它提供了更复杂的机制来组合异步和条件管道。创建一个在线程池中执行任务的 CompletableFuture。然后，将一个侦听器附加到将在任务完成时调用的 future。

示例

以下代码片段演示了如何使用 CompletableFuture 进行非阻塞任务执行:

import java.util.concurrent.CompletableFuture;

// Service class to perform the task
class ExampleService {
    public String work() {
        // Simulated work
        char[] str = new char[5];
        ThreadLocalRandom current = ThreadLocalRandom.current();
        for (int idx = 0; idx < str.length; ++idx)
            str[idx] = (char) ('A' + current.nextInt(26));
        String msg = new String(str);
        System.out.println("Generated message: " + msg);
        return msg;
    }
}

// Main class
public class Main {
    public static void main(String[] args) {
        ExampleService svc = new ExampleService();
        CompletableFuture<String> f = CompletableFuture.supplyAsync(svc::work);
        
        // Attach a listener to the future
        f.thenAccept(result -> System.out.println("Result: " + result));
        
        // Main method can continue execution without blocking
        System.out.println("Main method exiting");
    }
}

此代码创建一个异步执行 work() 方法的 CompletableFuture。 thenAccept() 方法附加一个侦听器，该侦听器将在 CompletableFuture 完成时调用，从而允许非阻塞执行任务。

以上是如何使用 Java Executors 和 CompletableFuture 非阻塞地执行任务？的详细内容。更多信息请关注PHP中文网其他相关文章！