学习Java多线程运行原理
一直在多线程这块存在问题,不敢去看,了解其运行原理,今天终于学习了,其实没有想的那么复杂,不罗嗦了,开始记录吧。
线程池的实现原理:
- 判断线程池里的核心线程是否都在执行任务,如果不是(核心线程空闲或者还有核心线程没用被创建)则创建一个新的工作线程来执行任务。如果核心线程都在执行任务,则进入下个流程。
- 线程池判断工作队列是否已满,如果工作队列没有满,则将新提交的任务存储在这个工作队列里。如果工作队列满了,则进入下个流程。
- 判断线程池里的线程是否都处理工作状态,如果没有,则创建一个新的工作线程来执行任务。如果满了,则交给饱和策略来处理这个任务。
代码测试demo:
package com.cc.day02;
import java.util.concurrent.LinkedBlockingQueue;
import java.util.concurrent.RejectedExecutionHandler;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;
public class ThreadTest2 {
public static void main(String[] args) {
LinkedBlockingQueue<Runnable> queue = new LinkedBlockingQueue<Runnable>(3);
RejectedExecutionHandler handler = new ThreadPoolExecutor.DiscardPolicy();
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(2, 5, 60, TimeUnit.SECONDS, queue,handler);
for (int i = 0; i < 9; i++) {
threadPool.execute(new Thread(new ThreadPoolTest(), "Thread".concat(i+"")));
System.out.println("线程池中活跃的线程数: " + threadPool.getPoolSize());
if (queue.size() > 0) {
System.out.println("----------------队列中阻塞的线程数"+queue.size());
}
}
threadPool.shutdown();
}
}
代码运行结果,如下: