Buka kunci Pengaturcaraan Async yang Lebih Pantas dengan Java Futures

Dalam artikel kami sebelum ini, kami meneroka dunia ListenableFuture. Sekarang, mari kita mendalami teknik yang lebih maju, khususnya memfokuskan pada transformasi dan rantaian. Bayangkan kita mempunyai ListenableFuture yang diperoleh daripada perkhidmatan tak segerak. Selain itu, kami mempunyai kaedah mudah:

Document parse(String xml) {//...

Daripada bekerja dengan String itu sendiri, kami memerlukan Dokumen. Satu pendekatan adalah untuk menyelesaikan Masa Depan dan memproses String. Walau bagaimanapun, penyelesaian yang lebih elegan ialah menggunakan transformasi sebaik sahaja keputusan tersedia, menjadikan kaedah kami berkelakuan seolah-olah ia sentiasa mengembalikan ListenableFuture. Ini sangat mudah:

final ListenableFuture future = //...
 
final ListenableFuture documentFuture = Futures.transform(future, new Function() {
    @override    public Document apply(String contents) {
        return parse(contents);
    }
});

Atau, untuk kebolehbacaan yang lebih baik:

final Function parseFun = new Function() {
    @override    public Document apply(String contents) {
        return parse(contents);
    }
};
 
final ListenableFuture future = //...
 
final ListenableFuture documentFuture = Futures.transform(future, parseFun);

Walaupun sintaks Java mungkin mempunyai hadnya, mari fokus pada perkara yang telah kita capai. Futures.transform() tidak menunggu ListenableFuture yang mendasari untuk menggunakan transformasi parse(). Sebaliknya, ia mendaftarkan panggilan balik, sedia untuk dimaklumkan apabila masa hadapan yang diberikan selesai. Transformasi ini diterapkan secara dinamik dan telus untuk kami pada masa yang tepat. Kami masih mempunyai Masa Depan, tetapi kali ini membungkus Dokumen.

Sekarang, mari kita melangkah lebih jauh. Kami juga mempunyai kaedah tak segerak, mungkin berjalan lama yang mengira perkaitan (apa pun maksudnya dalam konteks ini) Dokumen yang diberikan:

ListenableFuture calculateRelevance(Document pageContents) {//...

Bolehkah kita merantainya dengan ListenableFuture yang sudah kita miliki? Percubaan pertama:

final Function> relevanceFun = new Function>() {
    @override    public ListenableFuture apply(Document input) {
        return calculateRelevance(input);
    }
};
 
final ListenableFuture future = //...
final ListenableFuture documentFuture = Futures.transform(future, parseFun);
final ListenableFuture> relevanceFuture = Futures.transform(documentFuture, relevanceFun);

Untuk mendapatkan maklumat lanjut tentang kemungkinan pengaturcaraan tak segerak yang dipertingkatkan, lawati pautan ini.

Atas ialah kandungan terperinci Buka kunci Pengaturcaraan Async yang Lebih Pantas dengan Java Futures. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!