Java多线程编程：异步任务处理

原创一时失言乱红尘 2024-11-24 03:36 4阅读 0赞

在Java多线程编程中，异步任务处理通常涉及到回调机制或者使用现代的并发工具如 CompletableFuture 或 java.util.concurrent.FutureTask。

1. **回调函数**：
   当一个任务完成并有结果需要返回时，可以创建一个方法作为回调，当任务完成后调用这个方法。

```java
class AsyncTask {
    void execute(Runnable callback) {
        // 异步执行的任务代码
        // ...
        
        // 完成任务后调用回调函数
        callback.run();
    }
}

// 使用示例
new AsyncTask().execute(new Runnable() {
    @Override
    public void run() {
        System.out.println("Task completed");
    }
}));
```

2. **CompletableFuture**：
   Java 8引入了 CompletableFuture，这是一个异步操作的容器。你可以通过链式调用来添加任务和结果。

```java
import java.util.concurrent.CompletableFuture;

public class CompletableFutureExample {
    public CompletableFuture<String> asyncTask() {
        // 异步执行的任务代码
        return CompletableFuture.supplyAsync(() -> {
            System.out.println("Starting task...");
            try {
                Thread.sleep(2000); // 模拟耗时任务
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
            System.out.println("Task completed.");
            return "Task result";
        }));
    }

public void execute() {
        CompletableFuture<String> future = asyncTask();

// 当任务完成后获取结果
        future.thenAccept(result -> {
            System.out.println("Received result: " + result);
        }));

// 当任务失败时，提供一个错误处理函数
        future.whenComplete((result, error) -> {
            if (error != null) {
                System.out.println("Error occurred: " + error.getMessage());
            } else {
                System.out.println("Received result: " + result);
            }
        }));
    }

public static void main(String[] args) {
        CompletableFutureExample example = new CompletableFutureExample();
        example.execute();
    }
}
```

通过以上的示例，你可以看到如何在Java多线程编程中使用CompletableFuture来处理异步任务。