长春 美容 网站建设,做网站二维码,深圳建设工程交易,装修效果图网站推荐核心线程数1.最大线程5.队列5.存活时间10s
1.场景一
如果核心线程数.被一直占用得不到释放.新进来1个任务.会怎么样?答: 会在队列中中死等. 只要进来的任务.不超过队列的长度,就会一直挡在队列中死等 package com.lin;import java.util.concurrent.Executors;
import java.u…核心线程数1.最大线程5.队列5.存活时间10s
1.场景一
如果核心线程数.被一直占用得不到释放.新进来1个任务.会怎么样?答: 会在队列中中死等. 只要进来的任务.不超过队列的长度,就会一直挡在队列中死等 package com.lin;import java.util.concurrent.Executors;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
import java.util.concurrent.LinkedBlockingQueue;/*** author lin*/
public class ThreadPoolExample {public static void main(String[] args) {// 创建线程池ThreadPoolExecutor threadPoolExecutor new ThreadPoolExecutor(1, // 核心线程数5, // 最大线程数1, // 空闲线程存活时间TimeUnit.MINUTES, // 存活时间的单位new LinkedBlockingQueueRunnable(6) // 任务队列);// 提交第一个永不释放的任务给线程池threadPoolExecutor.execute(() - {try {System.out.println(Task 1 is running and will never complete);while (true) {// 模拟一个永不释放的任务Thread.sleep(1000);}} catch (InterruptedException e) {System.out.println(Task 1 was interrupted);Thread.currentThread().interrupt();}});// 等待一段时间然后提交第二个任务try {System.out.println(等待2秒);Thread.sleep(2000); // 等待2秒确保第一个任务已开始执行} catch (InterruptedException e) {e.printStackTrace();}for (int i 0; i 6; i) { //模拟任务数量int finalI i;threadPoolExecutor.execute(() - {try {System.out.println(Task finalI is running);Thread.sleep(1000); // 模拟任务运行System.out.println(Task finalI is completed);} catch (InterruptedException e) {e.printStackTrace();}});}// 打印线程池状态new Thread(() - {while (true) {try {System.out.println(Active Threads: threadPoolExecutor.getActiveCount());System.out.println(Pool Size: threadPoolExecutor.getPoolSize());System.out.println(Queue Size: threadPoolExecutor.getQueue().size());Thread.sleep(5000); // 每5秒打印一次线程池状态} catch (InterruptedException e) {Thread.currentThread().interrupt();break;}}}).start();// 等待足够的时间观察线程池状态//try {// Thread.sleep(60000); // 主线程等待60秒//} catch (InterruptedException e) {// e.printStackTrace();//}// 关闭线程池//threadPoolExecutor.shutdownNow();//try {// // 等待所有任务完成// if (!threadPoolExecutor.awaitTermination(60, TimeUnit.SECONDS)) {// threadPoolExecutor.shutdownNow();// }//} catch (InterruptedException e) {// threadPoolExecutor.shutdownNow();//}}
} 2.场景二
如果核心线程数,一直被占用.来了6个任务.效果会怎么样答: 这是任务总数超过了队列的长度.线程池会创建新的线程来处理这个任务.根据队列的不同.消费任务的顺序不一样.以LinkedBlockingQueue.1,2,3,4,5添加到队列中.第6个任务来了.会创建线程先消费. 然后再又这个线程来处理1,2,3,4,5来处理.
然后处理完.空闲线程等待存活时间.然后被回收.线程池恢复到最开始的时候. 3.场景三
如果核心线程数和最大线程数的其他线程同时空置了,最大线程数的其他线程还没有被回收.现在队列中的任务,会被那个消费答: 会优先被核心线程先消费
