当前位置：首页 > news >正文

解锁 Java 回调函数：异步编程与事件处理的利器

news 来源：原创 2025/5/10 17:12:05

什么是 Java 回调函数

在 Java 中，回调函数是一种编程模式，允许将一个方法作为参数传递给另一个方法，当某个特定事件发生或某个任务完成时，调用该方法。回调机制可以使代码更加灵活和可扩展，因为它允许在运行时动态地决定要执行的操作。

回调函数的工作原理

回调函数的实现通常依赖于接口。定义一个接口，其中包含一个抽象方法，这个方法就是回调方法。然后，在需要使用回调的地方，接收一个实现了该接口的对象，并在适当的时候调用接口中的回调方法。

经典案例代码示例

1. 简单的同步回调示例

下面的示例展示了一个简单的同步回调，用于计算两个数的和，并在计算完成后调用回调函数输出结果。

// 定义回调接口
interface CalculatorCallback {
    void onResult(int result);
}

// 计算器类，包含一个使用回调的方法
class Calculator {
    public void add(int a, int b, CalculatorCallback callback) {
        int result = a + b;
        // 调用回调函数
        callback.onResult(result);
    }
}

// 主类，用于测试回调
public class SynchronousCallbackExample {
    public static void main(String[] args) {
        Calculator calculator = new Calculator();
        // 实现回调接口
        CalculatorCallback callback = new CalculatorCallback() {
            @Override
            public void onResult(int result) {
                System.out.println("计算结果是: " + result);
            }
        };
        // 调用计算器的 add 方法并传入回调
        calculator.add(3, 5, callback);
    }
}

代码解释：

CalculatorCallback 是一个函数式接口，包含一个抽象方法 onResult，用于在计算完成后接收结果。
Calculator 类的 add 方法接收两个整数和一个 CalculatorCallback 对象作为参数，在计算完成后调用回调对象的 onResult 方法。
在 main 方法中，创建了一个 Calculator 对象和一个实现了 CalculatorCallback 接口的匿名内部类对象，然后调用 add 方法并传入回调对象。

2. 异步回调示例

异步回调通常用于处理耗时的操作，避免阻塞主线程。下面的示例模拟一个异步任务，在任务完成后调用回调函数。

// 定义回调接口
interface TaskCallback {
    void onComplete(String result);
}

// 模拟异步任务类
class AsyncTask {
    public void executeTask(TaskCallback callback) {
        // 模拟耗时操作
        new Thread(() -> {
            try {
                Thread.sleep(2000); // 模拟 2 秒的耗时操作
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            String result = "任务完成";
            // 任务完成后调用回调函数
            callback.onComplete(result);
        }).start();
    }
}

// 主类，用于测试异步回调
public class AsynchronousCallbackExample {
    public static void main(String[] args) {
        AsyncTask asyncTask = new AsyncTask();
        // 实现回调接口
        TaskCallback callback = new TaskCallback() {
            @Override
            public void onComplete(String result) {
                System.out.println("收到结果: " + result);
            }
        };
        // 执行异步任务并传入回调
        asyncTask.executeTask(callback);
        System.out.println("任务正在执行...");
    }
}

代码解释：

TaskCallback 是一个函数式接口，包含一个抽象方法 onComplete，用于在任务完成后接收结果。
AsyncTask 类的 executeTask 方法接收一个 TaskCallback 对象作为参数，在一个新线程中模拟耗时操作，操作完成后调用回调对象的 onComplete 方法。
在 main 方法中，创建了一个 AsyncTask 对象和一个实现了 TaskCallback 接口的匿名内部类对象，然后调用 executeTask 方法并传入回调对象。由于任务是异步执行的，主线程不会被阻塞，可以继续执行后续代码。