Bagaimanakah Saya Boleh Mengendalikan Ralat dan Penamatan Awal Dengan Cekap Apabila Bekerja dengan Niaga Hadapan?

Menunggu Penamatan Awal untuk Senarai Niaga Hadapan

Apabila berurusan dengan tugas tak segerak yang diwakili oleh niaga hadapan, selalunya penting untuk menunggu sehingga semua pemprosesan selesai selesai atau ralat berlaku. Walau bagaimanapun, menunggu tanpa perlu untuk semua tugasan selesai walaupun selepas ralat telah berlaku adalah tidak diingini.

Untuk menangani isu ini, pertimbangkan langkah berikut:

1. Gunakan a CompletionService:

   • Buat CompletionService untuk menerima niaga hadapan apabila ia tersedia.
   • Serahkan tugasan menggunakan objek Boleh Panggil yang merangkumkan pemprosesan.

2. Pantau Niaga Hadapan Secara Berurutan:

   • Gunakan gelung untuk melelang melalui niaga hadapan yang diterima daripada CompletionService.
   • Cuba untuk mendapatkan semula keputusan setiap masa hadapan menggunakan Future.get().
   • Jika mana-mana masa hadapan memberikan pengecualian, tetapkan bendera untuk menunjukkan ralat berlaku.

3. Batalkan Baki Tugasan:

   • Setelah ralat dikesan, batalkan sebarang tugas yang tinggal untuk mengelakkan menunggu yang tidak perlu.

Berikut ialah contoh yang menunjukkan pendekatan ini:

<code class="java">Executor executor = Executors.newFixedThreadPool(4);
CompletionService<SomeResult> completionService = 
       new ExecutorCompletionService<SomeResult>(executor);

// 4 tasks
for(int i = 0; i < 4; i++) {
   completionService.submit(new Callable<SomeResult>() {
       public SomeResult call() {
           // Processing code
           return result;
       }
   });
}

int received = 0;
boolean errors = false;

while(received < 4 && !errors) {
      Future<SomeResult> resultFuture = completionService.take(); // Blocks until available
      try {
         SomeResult result = resultFuture.get();
         received ++;
         // Process the result
      }
      catch(Exception e) {
         // Log or handle the error
         errors = true;
      }

      if (errors) {
         // Cancel any remaining tasks
         executor.shutdown();
         break;
      }
}</code>

Atas ialah kandungan terperinci Bagaimanakah Saya Boleh Mengendalikan Ralat dan Penamatan Awal Dengan Cekap Apabila Bekerja dengan Niaga Hadapan?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!