Bagaimana cara menggunakan penyelesaian yang boleh diselesaikan untuk memastikan konsistensi pesanan keputusan permintaan antara muka batch?

Pemprosesan secara serentak pemprosesan permintaan antara muka batch: pastikan susunan hasilnya konsisten

Panggilan serentak ke pelbagai antara muka pihak ketiga dapat meningkatkan kecekapan apabila memproses sejumlah besar data dengan cekap. Walau bagaimanapun, kesesuaian multithreaded mudah boleh menyebabkan susunan hasil pulangan tidak konsisten dan tidak sesuai dengan senarai data asal. Artikel ini akan memperkenalkan cara menyelesaikan masalah ini menggunakan Java's CompletableFuture untuk memastikan bahawa hasil panggilan antara muka adalah sama seperti urutan data asal.

Soalan:

Katakan bahawa lebih daripada 1000 antara muka pihak ketiga perlu dipanggil serentak dan diproses untuk mengembalikan hasil. Jika pelbagai benang dimulakan menggunakan for mudah, urutan panggilan antara muka tidak dapat dijamin, dan urutan keputusan akhir tidak sepadan dengan senarai data asal. Sesetengah kod sampel menggunakan CompletableFuture.runAsync .

Penyelesaian:

Untuk memastikan bahawa susunan keputusan adalah konsisten dengan senarai data asal, kunci adalah menggunakan CompletableFuture.supplyAsync CompletableFuture.runAsync Kaedah supplyAsync boleh mengembalikan hasil, sementara runAsync tidak mengembalikan nilai. Kembalikan hasil setiap panggilan antara muka melalui supplyAsync , dan kemudian kumpulkan hasil ke dalam senarai dengan pemprosesan streaming untuk memastikan urutan hasilnya konsisten dengan senarai data asal.

Kod yang lebih baik:

 public static void main (string [] args) {
    Senarai<string> datalist = arrayList baru  (); // Senarai Data Asal // ... Inisialisasi DataList ...

    Executorservice executorservice = threadpoolexecutor baru (
            // bilangan thread teras runtime.getRuntime ().
            // bilangan maksimum benang runtime.getRuntime (). TersediaProcessors () * 2,
            // thread survival time 60l, timeunit.seconds,
            New LinkedBlockingQueue  (),,
            baru threadpoolexecutor.callerrunspolicy ());

    Senarai <completablefuture> > niaga hadapan = arraylist baru  ();
    untuk (data rentetan: datalist) {
        Futures.Add (siap bolehFuture.SupplyAsync (() -> {
            logger.info ("Mula pelaksanaan thread asynchronous->>" data);
            // panggil antara muka dan lulus data
            // Hakim sama ada padanan data berdasarkan nilai pulangan antara muka // mengembalikan hasil proses pulangan yang diproses (data); // data proses dan mengembalikan hasil}, executorservice)); // Gunakan kolam benang tersuai}

    // Setelah memproses logik semua permintaan selesai, siap bolehFuture.allOf (Futures.ToArray (baru boleh diselesaikan [0]))). Thenrun (() -> {
        Senarai<string> hasil = niaga hadapan.stream ()
                .map (siap sedia :: bergabung)
                .kolect (collectors.tolist ());
        logger.info ("Pelaksanaan thread selesai: {}", json.tojsonstring (hasil));
        // panggilan untuk menghantar sms}). Thenrun (() -> executOrservice.shutdown ());
}

// kaedah pemprosesan data, ubah suai processData string statik peribadi (data string) {
    // ... panggilan antara muka dan logik pemprosesan data ...
    mengembalikan data "hasil yang diproses";
}</string></completablefuture></string>

Dengan menyimpan hasil setiap CompletableFuture dalam senarai futures dan mengumpul hasil pada akhir menggunakan futures.stream().map(CompletableFuture::join).collect(Collectors.toList()) , urutan hasil dipastikan konsisten dengan senarai data asal. CompletableFuture::join Blok Kaedah sehingga hasil dari CompletableFuture yang boleh diperolehi. Ini berkesan menyelesaikan masalah hasil yang tidak konsisten dalam kod asal.

Atas ialah kandungan terperinci Bagaimana cara menggunakan penyelesaian yang boleh diselesaikan untuk memastikan konsistensi pesanan keputusan permintaan antara muka batch?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!