Cara menggunakan fungsi CompletableFuture thenCompose dan thenCombine untuk operasi gabungan tak segerak dalam Java

Di Java, kami sering menghadapi senario yang memerlukan operasi tak segerak. Untuk situasi ini, Java 8 memperkenalkan kelas CompletableFuture, yang memberikan kami alat pengaturcaraan tak segerak yang kaya untuk menjadikan pengaturcaraan tak segerak lebih mudah dan lebih mudah. Antaranya, thenCompose dan thenCombine ialah dua kaedah operasi tak segerak gabungan yang biasa digunakan dalam kelas CompletableFuture.

1. Penggunaan kaedah thenCompose

ThethenCompose digunakan untuk menukar tika CompletableFuture kepada contoh CompletableFuture yang lain. Khususnya, ia menerima parameter Fungsi yang mengambil sebagai input hasil yang dikembalikan oleh CompletableFuture sebelumnya dan mengembalikan objek CompletableFuture baharu. Berikut ialah contoh:

CompletableFuture<Integer> future = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 10;
});

CompletableFuture<Integer> result = future.thenCompose(value -> CompletableFuture.supplyAsync(() -> value * 2));

result.whenComplete((res, ex) -> {
    if (ex != null) {
        ex.printStackTrace();
    } else {
        System.out.println(res);
    }
});

Dalam kod di atas, mula-mula kita mencipta contoh CompletableFuture, yang akan mensimulasikan masa pengiraan dalam urutan lain. Seterusnya, kami menggunakan kaedah thenCompose untuk menukarnya menjadi contoh CompletableFuture baharu, yang mendarabkan hasil yang dikembalikan oleh CompletableFuture sebelumnya dengan 2. Akhir sekali, kami menggunakan kaedah whenComplete untuk mengeluarkan keputusan atau mesej ralat.

2. Penggunaan kaedah thenCombine

ThenCombine digunakan untuk menggabungkan dua kejadian CompletableFuture menjadi satu. Khususnya, ia menerima satu lagi contoh CompletableFuture dan parameter BiFunction yang mengambil sebagai input hasil yang dikembalikan oleh dua CompletableFuture dan mengembalikan objek CompletableFuture baharu. Berikut ialah contoh:

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 10;
});

CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 5;
});

CompletableFuture<Integer> result = future1.thenCombine(future2, (value1, value2) -> value1 + value2);

result.whenComplete((res, ex) -> {
    if (ex != null) {
        ex.printStackTrace();
    } else {
        System.out.println(res);
    }
});

Dalam kod di atas, kami mencipta dua kejadian CompletableFuture, yang masing-masing mensimulasikan pelaksanaan dua tugas pengkomputeran. Seterusnya, kami menggunakan kaedah thenCombine untuk menggabungkan dua tika CompletableFuture ke dalam tika baharu yang menambah hasil yang dikembalikan oleh dua CompletableFuture yang pertama. Akhir sekali, kami menggunakan kaedah whenComplete untuk mengeluarkan keputusan atau mesej ralat.

3. Gunakan thenCompose dan thenCombine untuk melaksanakan operasi tak segerak yang kompleks

Kami telah pun memperkenalkan penggunaan kaedah thenCompose dan thenCombine sebelum ini, dan kedua-duanya adalah kaedah operasi tak segerak yang sangat berguna. Malah, kami juga boleh menggunakannya untuk melaksanakan operasi tak segerak yang lebih kompleks, seperti operasi pengagregatan pada berbilang hasil pengiraan.

CompletableFuture<Integer> future1 = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(2000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 10;
});

CompletableFuture<Integer> future2 = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(1000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 5;
});

CompletableFuture<Integer> future3 = CompletableFuture.supplyAsync(() -> {
    // 模拟计算耗时
    try {
        Thread.sleep(3000);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    return 20;
});

CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2, future3);

CompletableFuture<Integer> result = combinedFuture.thenCompose(
        voidResult -> CompletableFuture.supplyAsync(() -> {
            int sum = future1.join() + future2.join() + future3.join();
            return sum;
        }));

result.whenComplete((res, ex) -> {
    if (ex != null) {
        ex.printStackTrace();
    } else {
        System.out.println(res);
    }
});

Dalam kod di atas, kami mencipta tiga kejadian CompletableFuture, setiap satunya mensimulasikan pelaksanaan tugas pengkomputeran dan mengembalikan hasil yang sepadan. Seterusnya, kami menggunakan kaedah CompletableFuture.allOf untuk menggabungkan ketiga-tiga kejadian ini dan mencipta tika CompletableFuture baharu. Perlu diingatkan di sini bahawa kaedah allOf mengembalikan contoh CompletableFuture jenis Void, dan nilai pulangannya adalah batal.

Kemudian, kami menggunakan kaedah thenCompose untuk menukar tika CompletableFuture di atas yang mengembalikan null kepada tika CompletableFuture baharu, yang menambah hasil yang dikembalikan oleh tiga CompletableFuture sebelumnya. Dalam fungsi panggil balik kaedah thenCompose, kami menggunakan kaedah join() untuk mendapatkan nilai hasil setiap contoh CompletableFuture dan melakukan pengiraan yang sepadan. Akhir sekali, kami menggunakan kaedah whenComplete untuk mengeluarkan keputusan atau mesej ralat.

Secara amnya, thenCompose dan thenCombine adalah kaedah yang sangat berguna dalam kelas CompletableFuture Ia boleh membantu kami melaksanakan operasi tak segerak dengan lebih mudah dan meningkatkan kecekapan serentak dan pelaksanaan program.

Atas ialah kandungan terperinci Cara menggunakan fungsi CompletableFuture thenCompose dan thenCombine untuk operasi gabungan tak segerak dalam Java. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!