อินเทอร์เฟซ ExecutorService

เหตุใดคุณจึงต้องการส่วนต่อประสานผู้ดำเนินการ

ก่อน Java 5 คุณต้องเขียนการจัดการเธรดโค้ดของคุณเองในแอปพลิเคชันของคุณ นอกจากนี้ยังสร้างหัวข้อใหม่ออบเจกต์เป็นการดำเนินการที่ใช้ทรัพยากรมาก และไม่สมเหตุสมผลที่จะสร้างเธรดใหม่สำหรับทุกงานที่มีน้ำหนักเบา และเนื่องจากปัญหานี้เป็นที่คุ้นเคยกันดีสำหรับนักพัฒนาแอปพลิเคชันแบบมัลติเธรดทุกคน พวกเขาจึงตัดสินใจนำฟังก์ชันนี้มาไว้ใน Java เป็นเฟรมเวิร์กExecutor

ความคิดที่ยิ่งใหญ่คืออะไร? ง่ายมาก แทนที่จะสร้างเธรดใหม่สำหรับงานใหม่แต่ละงาน เธรดจะถูกเก็บไว้ในประเภท "ที่เก็บข้อมูล" และเมื่อมีงานใหม่เข้ามา เราจะดึงเธรดที่มีอยู่แทนที่จะสร้างเธรดใหม่

อินเทอร์เฟซหลักของเฟรมเวิร์กนี้คือExecutor , ExecutorServiceและScheduledExecutorServiceซึ่งแต่ละอินเทอร์เฟซจะขยายการทำงานของอินเทอร์เฟซก่อนหน้า

อินเทอร์เฟซ Executor เป็นอินเทอร์เฟซพื้นฐาน มันประกาศเป็นโมฆะ วิธี การดำเนินการ (คำสั่งที่รันได้) เดียว ที่นำไปใช้โดยวัตถุที่รันได้

อินเทอร์เฟ ซ ExecutorServiceน่าสนใจยิ่งขึ้น มีวิธีการจัดการการทำงานให้เสร็จสิ้นตลอดจนวิธีการส่งคืนผลลัพธ์บางประเภท มาดูวิธีการของมันให้ละเอียดยิ่งขึ้น:

มาดูตัวอย่างการทำงานกับ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;
       }
   }
}

เอาท์พุต:

แต่ละงานทำงานเป็นเวลา 5 วินาที เราสร้างพูลสำหรับสองเธรด ดังนั้นเอาต์พุตสองบรรทัดแรกจึงเหมาะสมอย่างยิ่ง

หกวินาทีหลังจากเริ่มโปรแกรม เมธอด invokeAllจะหมดเวลาและผลลัพธ์จะถูกส่งกลับเป็นรายการFutures สามารถดูได้จากสตริงเอาต์พุตFutures ที่ได้รับ

หลังจากงานสองงานแรกเสร็จสิ้น งานอีกสองงานก็เริ่มต้นขึ้น แต่เนื่องจากการหมดเวลาที่ตั้งค่าไว้ใน เมธอด invokeAllผ่านไป งานทั้งสองนี้จึงไม่มีเวลาดำเนินการให้เสร็จ พวกเขาได้รับคำสั่ง"ยกเลิก" นั่นเป็นสาเหตุที่เอาต์พุตมีสองบรรทัดที่มีโหมดสลีป 1: โหมดสลีปถูกขัดจังหวะ

จากนั้นคุณจะเห็นอีกสองบรรทัดด้วยdone นี่คือผลข้างเคียงที่ฉันกล่าวถึงเมื่ออธิบายเมธอดinvokeAll

งานที่ห้าและสุดท้ายไม่เคยเริ่มต้นด้วยซ้ำ ดังนั้นเราจึงไม่เห็นอะไรเกี่ยวกับมันในผลลัพธ์

สองบรรทัดสุดท้ายเป็นผลมาจากการเรียกใช้เมธอดisShutdownและisTerminated

นอกจากนี้ยังน่าสนใจที่จะเรียกใช้ตัวอย่างนี้ในโหมดดีบักและดูสถานะงานหลังจากหมดเวลา (ตั้งค่าเบรกพอยต์ในบรรทัดด้วยexecutorService.shutdown(); ):

เราเห็นว่าสองงาน เสร็จ สมบูรณ์ตามปกติและสามงานถูก"ยกเลิก"

บริการผู้ดำเนินการตามกำหนดเวลา

เพื่อสรุปการสนทนาของเราเกี่ยวกับตัว ดำเนินการ ลองมาดูที่ScheduledExecutorService

มันมี 4 วิธี: