Java線程池并發調用接口的方法可以通過以下步驟實現:
ExecutorService
的工廠方法創建,如newFixedThreadPool(int nThreads)
創建固定線程數的線程池。Callable
接口的任務類,該任務類負責調用接口的方法,并返回結果。submit(Callable<T> task)
方法提交任務,并返回Future<T>
對象,通過該對象可以獲取任務的執行結果。Future<T>
對象的get()
方法獲取任務的執行結果,該方法是阻塞的,直到任務執行完成并返回結果。List<Future<T>>
來保存所有任務的Future<T>
對象,然后遍歷列表,使用get()
方法獲取每個任務的執行結果。下面是一個簡單的示例代碼:
import java.util.concurrent.*;
public class ThreadPoolExample {
public static void main(String[] args) {
// 創建線程池
ExecutorService executor = Executors.newFixedThreadPool(5);
// 提交任務并獲取Future對象
Future<String> future1 = executor.submit(new MyTask("Task 1"));
Future<String> future2 = executor.submit(new MyTask("Task 2"));
Future<String> future3 = executor.submit(new MyTask("Task 3"));
// 獲取任務的執行結果
try {
String result1 = future1.get();
String result2 = future2.get();
String result3 = future3.get();
System.out.println("Result 1: " + result1);
System.out.println("Result 2: " + result2);
System.out.println("Result 3: " + result3);
} catch (InterruptedException | ExecutionException e) {
e.printStackTrace();
}
// 關閉線程池
executor.shutdown();
}
}
class MyTask implements Callable<String> {
private String name;
public MyTask(String name) {
this.name = name;
}
@Override
public String call() throws Exception {
// 調用接口的方法并返回結果
return "Hello from " + name;
}
}
在上面的示例中,我們創建了一個固定線程數為5的線程池,并提交了3個任務給線程池執行。然后通過Future
對象獲取任務的執行結果,并打印出來。最后關閉線程池。