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

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

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

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

将子任务分配给线程池中的线程。为此，需要创建一个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);}

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

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

关闭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个子任务分配给线程池中的线程，并等待所有任务完成。然后，它将输出每个任务的结果。