Bagaimanakah Saya Boleh Tunggu Dengan Cekap Semua Tugasan Selesai dalam Perkhidmatan Pelaksana?

ExecutorService: Menunggu Penyiapan Tugasan

ExecutorService ialah alat yang berguna untuk pelaksanaan tugas yang cekap, tetapi menjeda sehingga semua tugasan selesai boleh menjadi rumit. Mari kita selami isu biasa dan penyelesaian praktikalnya.

Ralat dalam menunggu()

Coretan kod yang dipetik, yang menggunakan ExecutorService kumpulan benang tetap, mengalami IllegalMonitorStateException apabila cuba menggunakan es.wait(). Ini berlaku kerana wait() bertujuan untuk digunakan dengan simpulan bahasa penyegerakan benang tertentu, bukan dengan ExecutorService.

Penyelesaian Paling Mudah: invokeAll()

ExecutorService menawarkan alternatif yang lebih mudah untuk tujuan ini: invokeAll(). Kaedah ini mengambil koleksi tugasan Boleh Panggil, melaksanakannya secara selari dan menyekat sehingga semua tugasan selesai. Begini cara untuk menggunakannya:

ExecutorService es = Executors.newFixedThreadPool(2);
List<Callable<Object>> todo = new ArrayList<>(uniquePhrases.size());

for (DataTable singleTable: uniquePhrases) { 
    todo.add(Executors.callable(new ComputeDTask(singleTable))); 
}

List<Future<Object>> answers = es.invokeAll(todo);

invokeAll() mengembalikan senarai objek Masa Depan, setiap satu mewakili tugas individu. Setelah semua tugasan selesai, mengakses mana-mana Future's isDone() akan kembali benar.

Kelebihan invokeAll()

• Sekat sehingga semua tugasan selesai.
• Mengelakkan penutupan manual dan penyegerakan.
• Membenarkan penggunaan semula ExecutorService untuk berbilang kitaran tugasan.

Kaedah Lain

• tutup() dan tunggu Penamatan() juga boleh digunakan, tetapi ia memerlukan penutupan manual pengendalian.
• serahkan(Boleh Dipanggil) boleh digunakan untuk penyerahan tugas individu, tetapi ia memerlukan penjejakan manual penyelesaian tugas.

Ingat, invokeAll() memerlukan tugas anda untuk melaksanakan Boleh Dipanggil. Jika ComputeDTask ialah Runnable, bungkusnya seperti yang ditunjukkan dalam coretan kod atau gunakan Executors.callable().

Atas ialah kandungan terperinci Bagaimanakah Saya Boleh Tunggu Dengan Cekap Semua Tugasan Selesai dalam Perkhidmatan Pelaksana?. Untuk maklumat lanjut, sila ikut artikel berkaitan lain di laman web China PHP!