凡科建的网站可以做seo吗,怎么开发手机网页,黄石本地做网站的,wordpress可以放视频播放器一、基本概念与关系
程序 程序是含有指令和数据的文件#xff0c;静态地存储在磁盘等存储设备上。它是软件的实体#xff0c;但未被激活。
进程 进程是程序的一次执行过程#xff0c;是系统运行程序的基本单位。当程序被操作系统加载并执行时#xff0c;就成为一个进程静态地存储在磁盘等存储设备上。它是软件的实体但未被激活。
进程 进程是程序的一次执行过程是系统运行程序的基本单位。当程序被操作系统加载并执行时就成为一个进程具有动态性。进程拥有独立的内存空间和系统资源如CPU时间、内存、I/O设备等是一个正在执行中的程序实例。进程之间相互独立不共享内存空间。
线程 线程是进程内部的一个执行单元是进程中实际运作的小单位也是CPU调度的基本单位。相比进程线程更轻量同类线程共享同一块内存空间和系统资源。线程之间可以共享数据但也可能相互影响特别是在同一个进程中。线程的引入提高了程序的并发执行能力。
三者之间的关系
程序到进程程序通过加载执行转变为进程实现了从静态代码到动态执行实体的转变。进程到线程一个进程可以包含多个线程这些线程共享进程的资源在同一进程环境下并发执行不同的任务提高了效率和响应速度。线程相比进程降低了资源开销提高了通信效率但同时也可能因为资源共享引发同步问题。
二、线程的基本状态
Java 线程在其生命周期中会经历以下6种基本状态之一并且随着代码执行和系统调度在这些状态之间转换
新建New线程刚被创建尚未启动。可运行Runnable线程可以被调度执行包括已经获得CPU时间片正在运行的线程和等待CPU分配时间片的线程。阻塞Blocked线程等待某个监视器锁例如进入synchronized代码块时或者等待I/O操作完成等。等待Waiting线程等待其他线程执行特定操作如调用Object.wait()方法不可被中断直到等待条件满足。超时等待Timed Waiting与等待状态相似但线程在指定时间后会自动醒来如调用Thread.sleep(long millis)方法。终止Terminated线程已结束执行无论是正常结束还是异常结束。
这些状态描述了线程从创建到执行完毕的完整生命周期理解这些状态对于调试多线程程序和避免死锁等问题至关重要。 Java 线程状态如下图所示
三、 线程池的原理与创建原因及方式
原理
线程池是一种基于池化思想管理线程的机制其核心在于重用线程资源减少创建和销毁线程的开销。线程池的工作流程主要包括以下几个步骤
创建线程池初始化时预先创建一定数量的线程并将其置于待命状态等待任务分配。任务提交当有新任务到达时将其加入到任务队列中。任务调度线程池中的空闲线程会从任务队列中取出任务并执行。若所有线程均在忙状态且任务队列已满则根据策略决定是否创建新线程或拒绝任务。任务执行完毕线程不会立即销毁而是返回线程池等待下一个任务。线程管理根据系统负载动态调整线程数量避免过多线程导致资源耗尽或过少线程影响任务处理速度。
优点
资源重用通过重复利用已创建的线程减少了线程创建和销毁的开销。提高响应速度任务到达时无需等待新线程创建即可立即执行。管理灵活性可根据系统状况动态调整线程数量有效控制资源使用防止资源耗尽。简化编程模型提供统一的接口给开发者提交任务隐藏了线程管理的复杂细节。提高系统稳定性通过控制最大线程数防止了过多线程导致的资源竞争和调度开销增强了系统的稳定性和可预测性。
创建线程池的方式 手动创建基础方式使用语言提供的线程创建API如Java中的Thread类配合同步机制如队列、锁等自行实现线程池逻辑。 使用标准库 Java: 通过Executors类提供的工厂方法创建不同类型线程池如newFixedThreadPool创建固定大小线程池newCachedThreadPool创建可缓存线程池等。C/POSIX: 利用std::thread结合std::queue等容器自建线程池或使用第三方库如boost::thread_pool。其他语言如Python的concurrent.futures.ThreadPoolExecutorNode.js的worker_threads模块等都提供了线程池或类似机制的封装。 第三方库使用成熟的第三方线程池库如Java的Apache Commons ThreadPoolExecutorC#的Microsoft TPLTask Parallel Library等这些库通常提供了更高级的特性如线程池监控、任务调度策略等。
选择合适的创建方式需根据项目需求、性能要求以及目标平台的支持程度综合考虑。
四、线程池的创建与参数解析
在Java中通过ThreadPoolExecutor类来创建自定义线程池其构造函数提供了高度灵活的配置选项以便根据具体需求调整线程池的行为。下面是构造函数及其参数的详细介绍 public ThreadPoolExecutor(int corePoolSize, // 核心线程数int maximumPoolSize, // 最大线程数long keepAliveTime, // 空闲线程存活时间TimeUnit unit, // 存活时间的单位BlockingQueueRunnable workQueue, // 任务队列RejectedExecutionHandler handler // 拒绝策略
)参数解释 corePoolSize核心线程数 线程池中常驻的核心线程数量。即使线程空闲这部分线程也会保留在线程池中不会被回收。只有在工作队列满并且当前线程数小于最大线程数时才会创建新的线程。 maximumPoolSize最大线程数 线程池能容纳的最大线程数量。当活动线程达到这个数值后新来的任务如果不能放入任务队列将被拒绝处理。 keepAliveTime空闲线程存活时间 当线程池中的线程数量超过核心线程数时多余的空闲线程在等待新任务最长时间达到keepAliveTime后如果还没有新任务到来那么这些线程将被终止以节省资源。 unit存活时间的单位 keepAliveTime参数的时间单位如TimeUnit.SECONDS秒、TimeUnit.MILLISECONDS毫秒等。 workQueue任务队列 用于保存等待执行的任务的阻塞队列。不同的队列实现会影响线程池的行为常见的有ArrayBlockingQueue固定大小、LinkedBlockingQueue无界或有限界限、SynchronousQueue直接传递没有容量等。 handler拒绝策略 当线程池和任务队列都达到饱和状态时即无法再接受新任务如何处理新提交的任务。JDK内置了几种拒绝策略 AbortPolicy默认策略丢弃任务并抛出RejectedExecutionException异常。CallerRunsPolicy调用者运行策略直接在调用者线程中执行被拒绝的任务。DiscardPolicy静默丢弃任务不抛出任何异常。DiscardOldestPolicy丢弃队列中最旧的任务并尝试重新提交当前任务。
通过调整这些参数可以创建符合特定应用场景需求的线程池以达到资源最优利用和任务高效执行的目的。
五、 线程池原理
1. 固定大小线程池FixedThreadPool
特点 固定大小线程池维护一个固定数量的线程确保所有任务都会在一个控制好的线程集合中执行适合于负载较为稳定、任务执行时间相对均衡的场景。由于使用了无界队列LinkedBlockingQueue如果任务提交速率超过处理能力队列可能会无限增长导致内存溢出风险。 参数分析 corePoolSize等于最大线程数一旦创建就不会改变保证线程数量恒定。 workQueue默认为LinkedBlockingQueue队列容量无上限。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class FixedThreadPoolDemo {public static void main(String[] args) {ExecutorService executor Executors.newFixedThreadPool(3);for (int i 0; i 10; i) {final int taskId i;executor.execute(() - {System.out.println(Task ID : taskId , Thread Name : Thread.currentThread().getName());try {Thread.sleep(1000);} catch (InterruptedException e) {e.printStackTrace();}});}executor.shutdown();}
}2. 可缓存线程池CachedThreadPool
特点 可缓存线程池会根据任务的需求动态创建线程空闲线程超过一定时间默认60秒则会被回收。这种线程池适合执行大量短期异步任务能够迅速响应突发请求但不适合长时间运行的任务因为线程数量可能无限增长导致资源耗尽。 参数分析
corePoolSize0初始时无核心线程。maximumPoolSizeInteger.MAX_VALUE理论上允许无限增长。keepAliveTime1分钟空闲线程等待新任务的最长时间。workQueueSynchronousQueue直接传递不保留任务。
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class CachedThreadPoolDemo {public static void main(String[] args) {ExecutorService executor Executors.newCachedThreadPool();for (int i 0; i 10; i) {final int taskId i;executor.execute(() - {System.out.println(Task ID : taskId , Thread Name : Thread.currentThread().getName());});}executor.shutdown();}
}3. 定时任务线程池ScheduledThreadPool
特点 定时任务线程池用于执行定时或周期性的任务如定时检查、定时清理等。它维护了一个固定大小的核心线程池并使用DelayedWorkQueue作为任务队列来存放将要执行的任务。 参数分析
corePoolSize线程池的基本大小即使没有任务执行线程也会保持存活。支持schedule系列方法设定任务的执行时间或周期。
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;public class ScheduledThreadPoolDemo {public static void main(String[] args) {ScheduledExecutorService executor Executors.newScheduledThreadPool(3);for (int i 0; i 3; i) {final int taskId i;executor.scheduleAtFixedRate(() - {System.out.println(Task ID : taskId , Thread Name : Thread.currentThread().getName());}, 0, 1, TimeUnit.SECONDS);}}
}以上介绍了Java中三种常用的线程池类型通过实例展示了它们的使用方法和特性。在实际应用中应根据具体需求选择合适的线程池类型并考虑是否需要进一步自定义线程池参数以达到最佳的性能与资源利用率。尽管Executors类提供了简便的工厂方法但在生产环境中推荐直接使用ThreadPoolExecutor构造函数来实现更细致的控制以避免潜在的资源耗尽问题 六、常用的线程池
提交一个任务到线程池中线程池的处理流程如下
1、判断线程池里的核心线程是否都在执行任务如果不是核心线程空闲或者还有核心线程没有被创 建则创建一个新的工作线程来执行任务。如果核心线程都在执行任务则进入下个流程。2、线程池判断工作队列是否已满如果工作队列没有满则将新提交的任务存储在这个工作队列里。如 果工作队列满了则进入下个流程。3、判断线程池里的线程是否都处于工作状态如果没有则创建一个新的工作线程来执行任务。如果已经满了则交给饱和策略来处理这个任务。
1、ThreadPoolExecutor的execute()方法
public void execute(Runnable command) {if (command null) {throw new NullPointerException();}// 如果线程数大于等于核心线程数或者线程创建失败将任务加入队列if (poolSize corePoolSize || !addIfUnderCorePoolSize(command)) {// 线程池处于运行状态并且加入队列成功if (runState RUNNING workQueue.offer(command)) {if (runState ! RUNNING || poolSize 0) {ensureQueuedTaskHandled(command);}} // 线程池不处于运行状态或者加入队列失败则创建线程创建的是非核心线程else if (!addIfUnderMaximumPoolSize(command)) {// 创建线程失败则采取阻塞处理的方式reject(command); // is shutdown or saturated}}
}2、创建线程的方法addIfUnderCorePoolSize(command)
private boolean addIfUnderCorePoolSize(Runnable firstTask) {Thread t null;final ReentrantLock mainLock this.mainLock;mainLock.lock();try {if (poolSize corePoolSize runState RUNNING) {t addThread(firstTask);}} finally {mainLock.unlock();}if (t null) {return false;}t.start();return true;
}我们重点来看第7行
private Thread addThread(Runnable firstTask) {Worker w new Worker(firstTask);Thread t threadFactory.newThread(w);if (t ! null) {w.thread t;workers.add(w);int nt poolSize;if (nt largestPoolSize) {largestPoolSize nt;}}return t;
}这里将线程封装成工作线程worker并放入工作线程组里worker类的方法run方法 public void run() {try {Runnable task firstTask;firstTask null;while (task ! null || (task getTask()) ! null) {runTask(task);task null;}} finally {workerDone(this);}
}worker在执行完任务后还会通过getTask方法循环获取工作队里里的任务来执行。 我们通过一个程序来观察线程池的工作原理 3、创建一个线程
public class ThreadPoolTest implements Runnable {Overridepublic void run() {try {Thread.sleep(300);} catch (InterruptedException e) {e.printStackTrace();}}
}4、线程池循环运行11个线程
public static void main(String[] args) {LinkedBlockingQueueRunnable queue new LinkedBlockingQueue(5);ThreadPoolExecutor threadPool new ThreadPoolExecutor(5, // 核心线程数10, // 最大线程数60, // 空闲线程存活时间TimeUnit.SECONDS, // 时间单位queue // 任务队列);for (int i 0; i 11; i) {threadPool.execute(new Thread(new ThreadPoolTest(), Thread i));System.out.println(活跃的线程数 threadPool.getPoolSize());if (queue.size() 0) {System.out.println(----------------队列阻塞的线程数 queue.size());}}threadPool.shutdown();
}执行结果
活跃的线程数 1
活跃的线程数 2
活跃的线程数 3
活跃的线程数 4
活跃的线程数 5
活跃的线程数 5
----------------队列阻塞的线程数1
活跃的线程数 5
----------------队列阻塞的线程数2
活跃的线程数 5
----------------队列阻塞的线程数3
活跃的线程数 5
----------------队列阻塞的线程数4
活跃的线程数 5
----------------队列阻塞的线程数5
活跃的线程数 6
----------------队列阻塞的线程数5
活跃的线程数 7
----------------队列阻塞的线程数5
活跃的线程数 8
----------------队列阻塞的线程数5
活跃的线程数 9
----------------队列阻塞的线程数5
活跃的线程数 10
----------------队列阻塞的线程数5
Exception in thread main java.util.concurrent.RejectedExecutionException: Task
Thread[Thread15,5,main] rejected from
java.util.concurrent.ThreadPoolExecutor232204a1[Running, pool size 10, active
threads 10, queued tasks 5, completed tasks 0]
at
java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPool
Executor.java:2047)
at
java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:823)
at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1369)
at test.ThreadTest.main(ThreadTest.java:17)分析结果
观察与分析 线程池配置概览创建的线程池具体配置为核心线程数量为5个最大线程总数为10个关联的工作队列容量为5个任务。 工作队列监控通过queue.size()方法实时监测工作队列中的任务数量帮助理解线程池的工作状态。 运行机制解析
初始阶段随着任务的提交线程池会创建核心线程直至达到5个。当核心线程满载后新任务被加入到工作队列中直至队列也达到其容量上限5个。队列饱和后线程池会继续创建非核心线程直至线程总数达到最大限制10个。若线程数和队列均达到上限此时线程池进入饱和状态需依据饱和策略处理后续提交的任务。
饱和策略RejectedExecutionHandler调整 当线程池和队列均达到饱和即无法接纳新任务时JDK提供了四种预设的饱和策略处理新提交的任务
AbortPolicy默认直接抛出RejectedExecutionException异常。CallerRunsPolicy将任务回退给调用线程直接执行。DiscardOldestPolicy丢弃队列中最旧的任务尝试重新提交当前任务。DiscardPolicy直接丢弃新提交的任务不抛出异常。 修改示例现在我们将上述示例中的饱和策略改为DiscardPolicy即丢弃新提交的任务而不抛出异常。
public static void main(String[] args) {// ... 线程池初始化代码保持不变 ...// 设置饱和策略为DiscardPolicythreadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());// 任务提交逻辑保持不变 ...threadPool.shutdown();
}基于之前的讨论让我们整合并扩展这部分内容包括修改线程池的饱和策略为DiscardPolicy并进行相应排版
观察与分析 线程池配置概览创建的线程池具体配置为核心线程数量为5个最大线程总数为10个关联的工作队列容量为5个任务。 工作队列监控通过queue.size()方法实时监测工作队列中的任务数量帮助理解线程池的工作状态。 运行机制解析 初始阶段随着任务的提交线程池会创建核心线程直至达到5个。当核心线程满载后新任务被加入到工作队列中直至队列也达到其容量上限5个。队列饱和后线程池会继续创建非核心线程直至线程总数达到最大限制10个。若线程数和队列均达到上限此时线程池进入饱和状态需依据饱和策略处理后续提交的任务。
饱和策略RejectedExecutionHandler调整
当线程池和队列均达到饱和即无法接纳新任务时JDK提供了四种预设的饱和策略处理新提交的任务
AbortPolicy默认直接抛出RejectedExecutionException异常。CallerRunsPolicy将任务回退给调用线程直接执行。DiscardOldestPolicy丢弃队列中最旧的任务尝试重新提交当前任务。DiscardPolicy直接丢弃新提交的任务不抛出异常。
修改示例现在我们将上述示例中的饱和策略改为DiscardPolicy即丢弃新提交的任务而不抛出异常。
public static void main(String[] args) {// ... 线程池初始化代码保持不变 ...// 设置饱和策略为DiscardPolicythreadPool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy());// 任务提交逻辑保持不变 ...threadPool.shutdown();
}通过这样的调整当线程池和队列达到饱和状态后任何新提交的任务将被默默地丢弃这种方式适用于那些可以安全丢弃的任务场景避免了因任务拒绝而引发的异常中断提高了程序的健壮性。
