如何在Java父子线程中实现任务分配

在Java中，可以使用ExecutorService和Future来实现父子线程之间的任务分配

1. 创建一个ExecutorService实例，它将负责管理线程池。线程池的大小取决于你想要同时运行的线程数量。

int threadPoolSize = 4; // 可以根据需要调整线程池大小
ExecutorService executorService = Executors.newFixedThreadPool(threadPoolSize);

2. 将子任务分配给线程池中的线程。为此，需要创建一个Callable实例，该实例表示要执行的任务。然后，使用executorService.submit()方法将任务提交给线程池。submit()方法将返回一个Future对象，表示异步计算的结果。

List<Future<String>> futures = new ArrayList<>();

for (int i = 0; i < 10; i++) { // 假设有10个子任务
    final int taskId = i;
    Callable<String> task = () -> {
        // 在这里执行子任务
        System.out.println("Task " + taskId + " is running by " + Thread.currentThread().getName());
        return "Task " + taskId + " completed";
    };
    Future<String> future = executorService.submit(task);
    futures.add(future);
}

3. 等待所有子任务完成并获取结果。可以使用Future.get()方法来获取每个任务的结果。如果任务尚未完成，get()方法将阻塞，直到任务完成。

for (Future<String> future : futures) {
    String result = future.get(); // 获取子任务的结果，如果任务尚未完成，则阻塞
    System.out.println(result);
}

4. 关闭ExecutorService以释放资源。

executorService.shutdown();

将上述代码片段组合在一起，可以实现一个简单的父子线程任务分配示例：

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

public class ParentChildTaskAssignment {
    public static void main(String[] args) throws InterruptedException, ExecutionException {
        int threadPoolSize = 4;
        ExecutorService executorService = Executors.newFixedThreadPool(threadPoolSize);

        List<Future<String>> futures = new ArrayList<>();

        for (int i = 0; i < 10; i++) {
            final int taskId = i;
            Callable<String> task = () -> {
                System.out.println("Task " + taskId + " is running by " + Thread.currentThread().getName());
                return "Task " + taskId + " completed";
            };
            Future<String> future = executorService.submit(task);
            futures.add(future);
        }

        for (Future<String> future : futures) {
            String result = future.get();
            System.out.println(result);
        }

        executorService.shutdown();
    }
}

这个示例将创建一个固定大小的线程池，将10个子任务分配给线程池中的线程，并等待所有任务完成。然后，它将输出每个任务的结果。