在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個子任務分配給線程池中的線程,并等待所有任務完成。然后,它將輸出每個任務的結果。