google的guava實(shí)現(xiàn)一個(gè)有100次請(qǐng)求網(wǎng)絡(luò)的線程池代碼處理

google的guava實(shí)現(xiàn)一個(gè)有100次請(qǐng)求網(wǎng)絡(luò)的線程池代碼處理

import com.google.common.util.concurrent.*;
import java.util.concurrent.Callable;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
public class GuavaExecutorsExample {
    public static void main(String[] args) {
        // 創(chuàng)建一個(gè) ListeningExecutorService，該 executor 會(huì)在調(diào)用 submit() 時(shí)自動(dòng)開始執(zhí)行任務(wù)
        ListeningExecutorService service = MoreExecutors.listeningDecorator(Executors.newFixedThreadPool(100));
        try {
            // 提交100個(gè)任務(wù)并獲取 Future 列表
            List<ListenableFuture<String>> futures = new ArrayList<>();
            for (int i = 0; i < 100; i++) {
                Callable<String> task = () -> {
                    // 這里執(zhí)行你的網(wǎng)絡(luò)請(qǐng)求邏輯，返回結(jié)果為 String 類型
                    return "Network Response " + i;
                };
                futures.add(service.submit(task));
            }
            // 使用 Guava 的 Futures 工具類等待所有任務(wù)完成，并獲取所有結(jié)果
            Futures.allAsList(futures).get(30, TimeUnit.SECONDS); // 設(shè)置超時(shí)時(shí)間
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 記得關(guān)閉 executor，防止資源泄露
            service.shutdown();
        }
    }
}

maven 導(dǎo)入jar

mvn倉(cāng)庫(kù)

<dependency>
    <groupId>com.google.guava</groupId>
    <artifactId>guava</artifactId>
    <version>32.1.2-jre</version>
</dependency>

Gradle 導(dǎo)入jar

// https://mvnrepository.com/artifact/com.google.guava/guava
implementation group: 'com.google.guava', name: 'guava', version: '32.1.2-jre'

在這個(gè)示例中，我創(chuàng)建了一個(gè) ListeningExecutorService，這是一個(gè)可以提交 ListenableFuture 任務(wù)的 ExecutorService。然后我提交了100個(gè)任務(wù)，并使用 Futures.allAsList() 來等待所有任務(wù)完成并獲取結(jié)果。最后，記得在所有任務(wù)完成后關(guān)閉 executor。