Antara muka ExecutorService

Mengapa anda memerlukan antara muka Pelaksana?

Sebelum Java 5, anda perlu menulis semua pengurusan benang kod anda sendiri dalam aplikasi anda. Selain itu, mewujudkan aBenang baruobjek ialah operasi intensif sumber, dan tidak masuk akal untuk mencipta benang baharu untuk setiap tugas yang ringan. Dan kerana masalah ini sudah biasa kepada setiap pembangun aplikasi berbilang benang, mereka memutuskan untuk membawa fungsi ini ke dalam Java sebagai rangka kerja Pelaksana .

Apakah idea besarnya? Ianya mudah: daripada mencipta utas baharu untuk setiap tugasan baharu, utas disimpan dalam sejenis "storan", dan apabila tugasan baharu tiba, kami mendapatkan semula utas sedia ada dan bukannya membuat yang baharu.

Antara muka utama rangka kerja ini ialah Executor , ExecutorService dan ScheduledExecutorService , setiap satunya memanjangkan fungsi yang sebelumnya.

Antara muka Pelaksana ialah antara muka asas. Ia mengisytiharkan kaedah laksanakan kekosongan tunggal (Arahan Boleh Dijalankan) yang dilaksanakan oleh objek Boleh Dijalankan .

Antara muka ExecutorService lebih menarik. Ia mempunyai kaedah untuk menguruskan penyiapan kerja, serta kaedah untuk mengembalikan beberapa jenis hasil. Mari kita lihat lebih dekat kaedahnya:

Mari lihat contoh kecil bekerja dengan ExecutorService .

import java.util.List;
import java.util.concurrent.*;

public class ExecutorServiceTest {
   public static void main(String[] args) throws InterruptedException, ExecutionException, TimeoutException {
//Create an ExecutorService for 2 threads
       java.util.concurrent.ExecutorService executorService = new ThreadPoolExecutor(2, 2, 60, TimeUnit.SECONDS, new ArrayBlockingQueue<>(10));
// Create 5 tasks
       MyRunnable task1 = new MyRunnable();
       MyRunnable task2 = new MyRunnable();
       MyRunnable task3 = new MyRunnable();
       MyRunnable task4 = new MyRunnable();
       MyRunnable task5 = new MyRunnable();

       final List<MyRunnable> tasks = List.of(task1, task2, task3, task4, task5);
// Pass a list that contains the 5 tasks we created
       final List<Future<Void>> futures = executorService.invokeAll(tasks, 6, TimeUnit.SECONDS);
       System.out.println("Futures received");

// Stop the ExecutorService
       executorService.shutdown();

       try {
           TimeUnit.SECONDS.sleep(3);
       } catch (InterruptedException e) {
           e.printStackTrace();
       }

       System.out.println(executorService.isShutdown());
       System.out.println(executorService.isTerminated());
   }

   public static class MyRunnable implements Callable<Void> {

       @Override
       public void call() {
// Add 2 delays. When the ExecutorService is stopped, we will see which delay is in progress when the attempt is made to stop execution of the task
           try {
               TimeUnit.SECONDS.sleep(3);
           } catch (InterruptedException e) {
               System.out.println("sleep 1: " + e.getMessage());
           }
           try {
               TimeUnit.SECONDS.sleep(2);
           } catch (InterruptedException e) {
               System.out.println("sleep 2: " + e.getMessage());
           }
           System.out.println("done");
           return null;
       }
   }
}

Pengeluaran:

Setiap tugasan berjalan selama 5 saat. Kami mencipta kolam untuk dua utas, jadi dua baris output pertama masuk akal.

Enam saat selepas program bermula, kaedah invokeAll tamat masa dan hasilnya dikembalikan sebagai senarai Niaga Hadapan . Ini boleh dilihat daripada rentetan keluaran Niaga hadapan diterima .

Selepas dua tugasan pertama selesai, dua lagi bermula. Tetapi kerana tamat masa yang ditetapkan dalam kaedah invokeAll berlalu, kedua-dua tugas ini tidak mempunyai masa untuk diselesaikan. Mereka menerima arahan "batal" . Itulah sebabnya output mempunyai dua baris dengan sleep 1: sleep interrupted .

Dan kemudian anda boleh melihat dua baris lagi dengan selesai . Ini adalah kesan sampingan yang saya nyatakan semasa menerangkan kaedah invokeAll .

Tugasan kelima dan terakhir tidak pernah dimulakan, jadi kami tidak melihat apa-apa tentangnya dalam output.

Dua baris terakhir adalah hasil daripada memanggil kaedah isShutdown dan isTerminated .

Ia juga menarik untuk menjalankan contoh ini dalam mod nyahpepijat dan melihat status tugas selepas tamat masa berlalu (tetapkan titik putus pada baris dengan executorService.shutdown(); ):

Kami melihat bahawa dua tugasan Selesai seperti biasa , dan tiga tugasan telah "Dibatalkan" .

ScheduledExecutorService

Untuk mengakhiri perbincangan kita tentang pelaksana, mari kita lihat pada ScheduledExecutorService .

Ia mempunyai 4 kaedah: