CompletableFuture | laluTerapkan vs lalu Tulis

Saya tidak bisa memahami perbedaan antara thenApply() dan thenCompose().

Jadi, dapatkah seseorang memberikan kasus penggunaan yang valid?

Dari dokumen Java:

thenApply(Function<? super T,? extends U> fn)

Mengembalikan yang baru CompletionStage, ketika tahapan ini selesai secara normal, dieksekusi dengan hasil tahapan ini sebagai argumen ke fungsi yang disediakan.

thenCompose(Function<? super T,? extends CompletionStage<U>> fn)

Mengembalikan yang baru CompletionStage, ketika tahap ini selesai secara normal, dijalankan dengan tahap ini sebagai argumen ke fungsi yang disediakan.

Saya mengerti bahwa argumen ke-2 thenComposememperluas CompletionStage di mana thenApplytidak.

Bisakah seseorang memberikan contoh dalam hal apa saya harus menggunakan thenApplydan kapan thenCompose?

thenApply digunakan jika Anda memiliki fungsi pemetaan sinkron.

CompletableFuture<Integer> future = 
    CompletableFuture.supplyAsync(() -> 1)
                     .thenApply(x -> x+1);

thenComposedigunakan jika Anda memiliki fungsi pemetaan asinkron (yaitu fungsi yang mengembalikan a CompletableFuture). Ini kemudian akan mengembalikan masa depan dengan hasil secara langsung, daripada masa depan bersarang.

CompletableFuture<Integer> future = 
    CompletableFuture.supplyAsync(() -> 1)
                     .thenCompose(x -> CompletableFuture.supplyAsync(() -> x+1));

Saya pikir jawaban yang diposting oleh @Joe C menyesatkan.

Izinkan saya mencoba menjelaskan perbedaan antara thenApplydan thenComposedengan contoh.

Misalkan kita memiliki 2 metode: getUserInfo(int userId)dan getUserRating(UserInfo userInfo):

public CompletableFuture<UserInfo> getUserInfo(userId)

public CompletableFuture<UserRating> getUserRating(UserInfo)

Kedua tipe pengembalian metode tersebut CompletableFuture.

Kami ingin menelepon getUserInfo()dulu, dan setelah selesai, panggil getUserRating()dengan hasil UserInfo.

Setelah menyelesaikan getUserInfo()metode, mari kita coba thenApplydan thenCompose. Perbedaannya terletak pada tipe pengembalian:

CompletableFuture<CompletableFuture<UserRating>> f =
    userInfo.thenApply(this::getUserRating);

CompletableFuture<UserRating> relevanceFuture =
    userInfo.thenCompose(this::getUserRating);

thenCompose()bekerja seperti ScalaflatMap yang meratakan masa depan bersarang.

thenApply()mengembalikan masa depan bersarang seperti sebelumnya, tetapi thenCompose()meratakannya CompletableFuturessehingga lebih mudah untuk merangkai lebih banyak panggilan metode ke sana.

Javadocs yang diperbarui di Java 9 mungkin akan membantu memahaminya dengan lebih baik:

laluLamar

<U> CompletionStage<U> thenApply​(Function<? super T,? extends U> fn)

Mengembalikan yang baru CompletionStage, ketika tahapan ini selesai secara normal, dieksekusi dengan hasil tahapan ini sebagai argumen ke fungsi yang disediakan.

Metode ini analog dengan Optional.mapdan Stream.map.

Lihat CompletionStagedokumentasi untuk aturan yang mencakup penyelesaian luar biasa.

laluCompose

<U> CompletionStage<U> thenCompose​(Function<? super T,? extends CompletionStage<U>> fn)

Mengembalikan nilai baru CompletionStageyang diselesaikan dengan nilai yang sama seperti yang CompletionStagedikembalikan oleh fungsi yang diberikan.

Ketika tahapan ini selesai secara normal, fungsi yang diberikan dipanggil dengan hasil tahapan ini sebagai argumen, mengembalikan yang lain CompletionStage. Ketika tahapan itu selesai secara normal, pengembalian CompletionStagedengan metode ini diselesaikan dengan nilai yang sama.

Untuk memastikan kemajuan, fungsi yang disediakan harus mengatur penyelesaian akhirnya dari hasilnya.

Metode ini analog dengan Optional.flatMapdan Stream.flatMap .

Lihat CompletionStagedokumentasi untuk aturan yang mencakup penyelesaian luar biasa.

thenApplydan thenComposemerupakan metode CompletableFuture. Gunakan jika Anda berniat melakukan sesuatu untuk mendapatkan CompleteableFuturehasil dengan a Function.

thenApplydan thenComposekeduanya mengembalikan CompletableFuturesebagai hasil mereka sendiri. Anda dapat merantai beberapa thenApplyatau thenComposebersama. Berikan a Functionke setiap panggilan, yang hasilnya akan menjadi masukan ke panggilan berikutnya Function.

Yang FunctionAnda berikan terkadang perlu melakukan sesuatu secara sinkron. Tipe pengembalian Anda Functionharus non- Futuretipe. Dalam hal ini Anda harus menggunakan thenApply.

CompletableFuture.completedFuture(1)
    .thenApply((x)->x+1) // adding one to the result synchronously, returns int
    .thenApply((y)->System.println(y)); // value of y is 1 + 1 = 2

Di lain waktu Anda mungkin ingin melakukan pemrosesan asinkron dalam hal ini Function. Dalam hal ini Anda harus menggunakan thenCompose. Jenis pengembalian Anda Functionharus a CompletionStage. FunctionRantai berikutnya akan mendapatkan hasil CompletionStagesebagai masukan, sehingga membuka bungkus CompletionStage.

// addOneAsync may be implemented by using another thread, or calling a remote method
abstract CompletableFuture<Integer> addOneAsync(int input);

CompletableFuture.completedFuture(1)
    .thenCompose((x)->addOneAsync(x)) // doing something asynchronous, returns CompletableFuture<Integer>
    .thenApply((y)->System.println(y)); // y is an Integer, the result of CompletableFuture<Integer> above

Ini adalah ide yang mirip dengan Javascript Promise. Promise.thendapat menerima fungsi yang mengembalikan nilai atau Promisenilai. Alasan mengapa kedua metode ini memiliki nama yang berbeda di Java adalah karena penghapusan yang umum . Function<? super T,? extends U> fndan Function<? super T,? extends CompletionStage<U>> fndianggap sebagai jenis Runtime yang sama - Function. Jadi thenApplydan thenComposeharus diberi nama yang berbeda, atau kompiler Java akan mengeluh tentang tanda tangan metode yang identik. Hasil akhirnya adalah, Javascript Promise.thendiimplementasikan dalam dua bagian - thenApplydanthenCompose - di Java.

Anda dapat membaca jawaban saya yang lain jika Anda juga bingung tentang fungsi terkait thenApplyAsync.