الرئيسية / Concurrency / طلبات HTTP متزامنة مع الخيوط الافتراضية
Concurrency متوسط

طلبات HTTP متزامنة مع الخيوط الافتراضية

اجلب عناوين URL كثيرة بالتوازي باستخدام الخيوط الافتراضية و HttpClient.

مقارنة الكود
✕ Java 8 
ExecutorService pool =
    Executors.newFixedThreadPool(10);
List<Future<String>> futures =
    urls.stream()
    .map(u -> pool.submit(
        () -> fetchUrl(u)))
    .toList();
// manual shutdown, blocking get()
✓ Java 21+ 
try (var exec = Executors
    .newVirtualThreadPerTaskExecutor()) {
    var results = urls.stream()
        .map(u -> exec.submit(
            () -> client.send(req(u),
                ofString()).body()))
        .toList().stream()
        .map(Future::join).toList();
}
هل ترى مشكلة في هذا الكود؟ أخبرنا.
لماذا يتفوق الأسلوب الحديث
♾️

خيط لكل طلب

لا حاجة لضبط حجم المجمع — خيط افتراضي لكل عنوان URL.

📖

كود بسيط

اكتب كوداً حجبياً مباشراً.

⚡

إنتاجية عالية

آلاف الطلبات المتزامنة بموارد ضئيلة.

الأسلوب القديم
مجمع خيوط + URLConnection
الأسلوب الحديث
الخيوط الافتراضية + HttpClient
منذ JDK
21
الصعوبة
متوسط
دعم JDK
طلبات HTTP متزامنة مع الخيوط الافتراضية
متاح

متاح على نطاق واسع منذ JDK 21 LTS (سبتمبر 2023)

كيف يعمل

تجعل الخيوط الافتراضية إنشاء خيط لكل طلب HTTP أمراً عملياً. مع HttpClient يستبدل ذلك أنماط ردود الاتصال غير المتزامنة المعقدة بكود حجب بسيط يتوسّع بشكل جيد.

توثيق ذو صلة
Virtual Threads (JEP 444) ↗ HttpClient ↗
أنماط ذات صلة
Concurrency متقدم

Structured concurrency

Java 8
ExecutorService exec =
    Executors.newFixedThreadPool(2);
Future<User> u = exec.submit(this::fetchUser);
Future<Order> o = exec.submit(this::fetchOrder);
try {
    return combine(u.get(), o.get());
} finally { exec.shutdown(); }
Java 25 (Preview)
try (var scope = new StructuredTaskScope
        .ShutdownOnFailure()) {
    var u = scope.fork(this::fetchUser);
    var o = scope.fork(this::fetchOrder);
    scope.join().throwIfFailed();
    return combine(u.get(), o.get());
}
مرر للرؤية الحديث ←
JDK 25+ →
Concurrency متقدم

Stable values

Java 8
private volatile Logger logger;
Logger getLogger() {
    if (logger == null) {
        synchronized (this) {
            if (logger == null)
                logger = createLogger();
        }
    }
    return logger;
}
Java 25 (Preview)
private final StableValue<Logger> logger =
    StableValue.of(this::createLogger);

Logger getLogger() {
    return logger.get();
}
مرر للرؤية الحديث ←
JDK 25+ →
Concurrency متقدم

Lock-free lazy initialization

Java 8
class Config {
    private static volatile Config inst;
    static Config get() {
        if (inst == null) {
            synchronized (Config.class) {
                if (inst == null)
                    inst = load();
            }
        }
        return inst;
    }
}
Java 25 (Preview)
class Config {
    private static final
        StableValue<Config> INST =
            StableValue.of(Config::load);

    static Config get() {
        return INST.get();
    }
}
مرر للرؤية الحديث ←
JDK 25+ →
مشاركة 𝕏 🦋 in ⬡