newFixedThreadPool เมธอด
สามารถรับพูลเธรดคงที่ได้โดยเรียกเมธอด newFixedThreadPool () แบบคงที่ของคลาส Executors
ไวยากรณ์
ExecutorService fixedPool = Executors.newFixedThreadPool(2);
ที่ไหน
เธรดสูงสุด 2 เธรดจะแอ็คทีฟเพื่อประมวลผลงาน
หากมีการส่งมากกว่า 2 เธรดเธรดเหล่านั้นจะถูกกักไว้ในคิวจนกว่าเธรดจะพร้อมใช้งาน
เธรดใหม่ถูกสร้างขึ้นเพื่อใช้แทนหากเธรดสิ้นสุดลงเนื่องจากความล้มเหลวในระหว่างการปิดการดำเนินการบนตัวดำเนินการยังไม่ได้เรียกใช้
มีเธรดใด ๆ อยู่จนกว่าพูลจะปิดลง
ตัวอย่าง
โปรแกรม TestThread ต่อไปนี้แสดงการใช้เมธอด newFixedThreadPool ในสภาพแวดล้อมแบบเธรด
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class TestThread {
public static void main(final String[] arguments) throws InterruptedException {
ExecutorService executor = Executors.newFixedThreadPool(2);
// Cast the object to its class type
ThreadPoolExecutor pool = (ThreadPoolExecutor) executor;
//Stats before tasks execution
System.out.println("Largest executions: "
+ pool.getLargestPoolSize());
System.out.println("Maximum allowed threads: "
+ pool.getMaximumPoolSize());
System.out.println("Current threads in pool: "
+ pool.getPoolSize());
System.out.println("Currently executing threads: "
+ pool.getActiveCount());
System.out.println("Total number of threads(ever scheduled): "
+ pool.getTaskCount());
executor.submit(new Task());
executor.submit(new Task());
//Stats after tasks execution
System.out.println("Core threads: " + pool.getCorePoolSize());
System.out.println("Largest executions: "
+ pool.getLargestPoolSize());
System.out.println("Maximum allowed threads: "
+ pool.getMaximumPoolSize());
System.out.println("Current threads in pool: "
+ pool.getPoolSize());
System.out.println("Currently executing threads: "
+ pool.getActiveCount());
System.out.println("Total number of threads(ever scheduled): "
+ pool.getTaskCount());
executor.shutdown();
}
static class Task implements Runnable {
public void run() {
try {
Long duration = (long) (Math.random() * 5);
System.out.println("Running Task! Thread Name: " +
Thread.currentThread().getName());
TimeUnit.SECONDS.sleep(duration);
System.out.println("Task Completed! Thread Name: " +
Thread.currentThread().getName());
} catch (InterruptedException e) {
e.printStackTrace();
}
}
}
}
สิ่งนี้จะให้ผลลัพธ์ดังต่อไปนี้
เอาต์พุต
Largest executions: 0
Maximum allowed threads: 2
Current threads in pool: 0
Currently executing threads: 0
Total number of threads(ever scheduled): 0
Core threads: 2
Largest executions: 2
Maximum allowed threads: 2
Current threads in pool: 2
Currently executing threads: 1
Total number of threads(ever scheduled): 2
Running Task! Thread Name: pool-1-thread-1
Running Task! Thread Name: pool-1-thread-2
Task Completed! Thread Name: pool-1-thread-2
Task Completed! Thread Name: pool-1-thread-1