ThreadPoolExecutor

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

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

Thread PoolและThreadPoolExecutorมาช่วยเราที่นี่

เธรดพูลคือชุดของเธรดที่เตรียมใช้งานล่วงหน้า ขนาดสามารถคงที่หรือเปลี่ยนแปลงได้

หากมีงานมากกว่าเธรด งานจะรออยู่ในคิวงาน เธรดที่ N ในพูลรับงานจากคิว และหลังจากเสร็จสิ้น เธรดจะรับงานใหม่จากคิว เมื่อดำเนินการงานทั้งหมดในคิวแล้ว เธรดจะยังคงทำงานอยู่และรองานใหม่ เมื่องานใหม่ปรากฏขึ้น เธรดจะเริ่มดำเนินการเช่นกัน

ThreadPoolExecutor

เริ่มต้นด้วย Java 5, Executor frameworkได้รับโซลูชันแบบมัลติเธรด โดยทั่วไป มีองค์ประกอบมากมายและจุดประสงค์คือช่วยให้เราจัดการคิวและเธรดพูลได้อย่างมีประสิทธิภาพ

อินเท อร์เฟซหลักคือExecutorและExecutorService

Executorเป็นอินเตอร์เฟสที่มีเมธอด execute(Runnable runnable) ตัวเดียว

เมื่อส่งงานไปยังการนำวิธีนี้ไปใช้ โปรดทราบว่ามันจะถูกดำเนินการแบบอะซิงโครนัสในอนาคต

ExecutorService — อินเทอร์เฟซที่ขยาย อิน เทอ ร์เฟซ Executor เพิ่มความสามารถในการดำเนินการ นอกจากนี้ยังมีวิธีการขัดจังหวะงานที่กำลังรันอยู่และยุติเธรดพูล

ThreadPoolExecutorใช้ อินเทอร์เฟซ Executorและ ExecutorServiceและแยกการสร้างงานออกจากการดำเนินการงาน เราจำเป็นต้องนำ วัตถุ ที่รันได้ไปใช้และส่งไปยังตัวดำเนินการ จากนั้น ThreadPoolExecutorจะรับผิดชอบในการดำเนินการงาน ตลอดจนสร้างและทำงานกับเธรด

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

ThreadPoolExecutorมีตัวสร้าง 4 ตัว:

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit, 
BlockingQueue<Runnable> workQueue)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
RejectedExecutionHandler handler)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory)
    

ThreadPoolExecutor(
int corePoolSize,
int maximumPoolSize,
long keepAliveTime, 
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory, 
RejectedExecutionHandler handler)
    

ตัว สร้าง ThreadPoolExecutorมีพารามิเตอร์ต่อไปนี้:

การสร้าง ThreadPoolExecutor

คลาส ยูทิลิตี้ Executorsสามารถทำให้การสร้างThreadPoolExecutorง่าย ขึ้น เมธอดของคลาสยูทิลิตี้นี้ช่วยให้เราเตรียมกThreadPoolExecutorวัตถุ.

ExecutorService executor = Executors.newFixedThreadPool(10);
                    

ExecutorService executor = Executors.newWorkStealingPool(4);
                    

ExecutorService executor = Executors.newSingleThreadExecutor();
                    

ExecutorService executor = Executors.newCachedThreadPool();
                    

ScheduledExecutorService executor = Executors.newScheduledThreadPool(10);
                    

เราจะพิจารณาพูลแต่ละประเภทในบทเรียนต่อไปนี้