如何通过函数式接口处理并发任务

在Java中，您可以使用函数式接口来处理并发任务。函数式接口是只有一个抽象方法的接口，它们可以与Lambda表达式和方法引用一起使用。为了处理并发任务，您可以使用Java的ExecutorService和Future接口。以下是一个简单的示例，说明如何使用函数式接口处理并发任务：

1. 首先，创建一个函数式接口：

@FunctionalInterface
public interface Task<T> {
    T execute() throws Exception;
}

2. 然后，创建一个方法来执行并发任务：

import java.util.concurrent.*;

public class ConcurrentTaskExecutor {

    public static <T> Future<T> submitTask(Task<T> task) {
        ExecutorService executor = Executors.newSingleThreadExecutor();
        return executor.submit(() -> {
            try {
                return task.execute();
            } catch (Exception e) {
                throw new RuntimeException("Task execution failed", e);
            }
        });
    }

    public static void main(String[] args) {
        // 创建一个任务
        Task<Integer> task = () -> {
            Thread.sleep(1000); // 模拟耗时操作
            return 42;
        };

        // 提交任务并获取Future
        Future<Integer> future = submitTask(task);

        // 在任务完成之前，您可以在这里执行其他操作

        try {
            // 获取任务结果
            Integer result = future.get();
            System.out.println("Task result: " + result);
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        } finally {
            // 关闭线程池
            executor.shutdown();
        }
    }
}

在这个示例中，我们创建了一个名为Task的函数式接口，它有一个名为execute的抽象方法。我们还创建了一个名为ConcurrentTaskExecutor的类，其中包含一个名为submitTask的方法，该方法接受一个Task接口实例并返回一个Future对象。Future对象表示异步计算的结果。

在main方法中，我们创建了一个名为task的Task实例，该实例执行一个耗时操作并返回一个整数结果。然后，我们使用submitTask方法提交任务并获取一个Future对象。最后，我们使用future.get()方法获取任务结果，并在任务完成后关闭线程池。