Java

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

小樊
82
2024-09-07 12:11:05
栏目: 编程语言

在Java中,可以使用ExecutorServiceFuture来实现父子线程之间的任务分配

  1. 创建一个ExecutorService实例,它将负责管理线程池。线程池的大小取决于你想要同时运行的线程数量。
int threadPoolSize = 4; // 可以根据需要调整线程池大小
ExecutorService executorService = Executors.newFixedThreadPool(threadPoolSize);
  1. 将子任务分配给线程池中的线程。为此,需要创建一个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);
}
  1. 等待所有子任务完成并获取结果。可以使用Future.get()方法来获取每个任务的结果。如果任务尚未完成,get()方法将阻塞,直到任务完成。
for (Future<String> future : futures) {
    String result = future.get(); // 获取子任务的结果,如果任务尚未完成,则阻塞
    System.out.println(result);
}
  1. 关闭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个子任务分配给线程池中的线程,并等待所有任务完成。然后,它将输出每个任务的结果。

0
看了该问题的人还看了