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

最新问答

相关标签