java 多线程异步处理任务集中统一处理结果

在Java中，可以使用多线程异步处理任务集中统一处理结果的方式有很多，其中比较常用的方式是使用线程池和Future对象。

1. 线程池：Java提供了Executor框架，可以通过创建线程池来管理多个线程。你可以使用ThreadPoolExecutor类来创建一个线程池，并将任务提交给线程池进行执行。通过使用线程池，你可以控制并发线程的数量，避免创建过多的线程导致资源浪费。当所有任务执行完成后，你可以通过线程池的回调机制来处理任务的结果。

2. Future对象：Future是Java提供的一个接口，它表示一个异步计算的结果。你可以通过ExecutorService.submit()方法提交一个任务，并返回一个Future对象。通过Future对象，你可以检查任务是否完成、取消任务的执行、获取任务的执行结果等。当所有任务都提交完成后，你可以遍历Future对象集合，获取每个任务的执行结果，并进行统一处理。

下面是一个示例代码，演示了如何使用线程池和Future对象来实现多线程异步处理任务集中统一处理结果：

import java.util.ArrayList;
import java.util.List;
import java.util.concurrent.*;

public class AsyncTaskProcessor {
    public static void main(String[] args) {
        // 创建线程池
        ExecutorService executor = Executors.newFixedThreadPool(5);

        // 创建任务列表
        List<Callable<Integer>> tasks = new ArrayList<>();
        tasks.add(new Task(1));
        tasks.add(new Task(2));
        tasks.add(new Task(3));

        try {
            // 提交任务并获取Future对象列表
            List<Future<Integer>> futures = executor.invokeAll(tasks);

            // 处理任务结果
            for (Future<Integer> future : futures) {
                if (future.isDone()) {
                    int result = future.get();
                    System.out.println("Task result: " + result);
                    // 统一处理任务结果
                    // ...
                }
            }
        } catch (InterruptedException | ExecutionException e) {
            e.printStackTrace();
        }

        // 关闭线程池
        executor.shutdown();
    }

    static class Task implements Callable<Integer> {
        private int taskId;

        public Task(int taskId) {
            this.taskId = taskId;
        }

        @Override
        public Integer call() throws Exception {
            // 执行任务逻辑
            Thread.sleep(1000);
            return taskId * 10;
        }
    }
}