อินเตอร์เฟส ExecutorService

อินเทอร์เฟซ java.util.concurrent.ExecutorService เป็นอินเทอร์เฟซย่อยของอินเตอร์เฟส Executor และเพิ่มคุณสมบัติในการจัดการวงจรชีวิตทั้งของแต่ละงานและของตัวดำเนินการเอง

วิธีการให้บริการ

ซีเนียร์ วิธีการและคำอธิบาย
1

boolean awaitTermination(long timeout, TimeUnit unit)

บล็อกจนกว่างานทั้งหมดจะเสร็จสิ้นการดำเนินการหลังจากการร้องขอการปิดระบบหรือการหมดเวลาเกิดขึ้นหรือเธรดปัจจุบันถูกขัดจังหวะขึ้นอยู่กับว่าสิ่งใดจะเกิดขึ้นก่อน

2

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks)

ดำเนินการตามภารกิจที่กำหนดส่งคืนรายการ Futures ที่มีสถานะและผลลัพธ์เมื่อทั้งหมดเสร็จสมบูรณ์

3

<T> List<Future<T>> invokeAll(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)

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

4

<T> T invokeAny(Collection<? extends Callable<T>> tasks)

ดำเนินการงานที่กำหนดส่งคืนผลลัพธ์ของงานที่ทำสำเร็จ (กล่าวคือโดยไม่มีข้อยกเว้น) หากมี

5

<T> T invokeAny(Collection<? extends Callable<T>> tasks, long timeout, TimeUnit unit)

ดำเนินการงานที่กำหนดส่งคืนผลลัพธ์ของงานที่ทำสำเร็จ (กล่าวคือโดยไม่ทิ้งข้อยกเว้น) หากมีการดำเนินการก่อนที่จะหมดเวลาที่กำหนด
6

boolean isShutdown()

ส่งคืนจริงหากตัวดำเนินการนี้ถูกปิด

7

boolean isTerminated()

ส่งคืนค่าจริงหากงานทั้งหมดเสร็จสิ้นหลังจากปิดเครื่อง

8

void shutdown()

เริ่มต้นการปิดระบบอย่างเป็นระเบียบซึ่งมีการดำเนินงานที่ส่งไปก่อนหน้านี้ แต่จะไม่มีการยอมรับงานใหม่

9

List<Runnable> shutdownNow()

พยายามหยุดงานที่กำลังดำเนินการอยู่ทั้งหมดหยุดการประมวลผลของงานที่รอและส่งคืนรายการงานที่รอการดำเนินการ

10

<T> Future<T> submit(Callable<T> task)

ส่งงานคืนค่าสำหรับการดำเนินการและส่งคืนอนาคตที่แสดงถึงผลลัพธ์ที่รอดำเนินการของงาน

11

Future<?> submit(Runnable task)

ส่งงานที่รันได้เพื่อดำเนินการและส่งคืนอนาคตที่แสดงถึงภารกิจนั้น

12

<T> Future<T> submit(Runnable task, T result)

ส่งงานที่รันได้เพื่อดำเนินการและส่งคืนอนาคตที่แสดงถึงภารกิจนั้น

ตัวอย่าง

โปรแกรม TestThread ต่อไปนี้แสดงการใช้อินเตอร์เฟส ExecutorService ในสภาพแวดล้อมแบบเธรด

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

public class TestThread {

   public static void main(final String[] arguments) throws InterruptedException {
      ExecutorService executor = Executors.newSingleThreadExecutor();

      try {
         executor.submit(new Task());
         System.out.println("Shutdown executor");
         executor.shutdown();
         executor.awaitTermination(5, TimeUnit.SECONDS);
      } catch (InterruptedException e) {
         System.err.println("tasks interrupted");
      } finally {

         if (!executor.isTerminated()) {
            System.err.println("cancel non-finished tasks");
         }
         executor.shutdownNow();
         System.out.println("shutdown finished");
      }
   }

   static class Task implements Runnable {
      
      public void run() {
         
         try {
            Long duration = (long) (Math.random() * 20);
            System.out.println("Running Task!");
            TimeUnit.SECONDS.sleep(duration);
         } catch (InterruptedException e) {
            e.printStackTrace();
         }
      }
   }	   
}

สิ่งนี้จะให้ผลลัพธ์ดังต่อไปนี้

เอาต์พุต

Shutdown executor
Running Task!
shutdown finished
cancel non-finished tasks
java.lang.InterruptedException: sleep interrupted
	at java.lang.Thread.sleep(Native Method)
	at java.lang.Thread.sleep(Thread.java:302)
	at java.util.concurrent.TimeUnit.sleep(TimeUnit.java:328)
	at TestThread$Task.run(TestThread.java:39)
	at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:439)
	at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
	at java.util.concurrent.FutureTask.run(FutureTask.java:138)
	at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:895)
	at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:918)
	at java.lang.Thread.run(Thread.java:662)