以前很少写这些文档,可后来发现自己所了解的东西慢慢的忘记了好多,所以准备整理一下,不知道说的对不对,如果哪里有不对的地方,请谅解并给出更正,3Q。话不多说直接举例子;
以下为任务的一个池应用,按给出的时间运行事务。
ExecutorService 池应用:
public static void main(String[] args) { MessageJob message = new MessageJob(); ExecutorService pool = Executors.newSingleThreadScheduledExecutor(); while(true){ pool.execute(message); // 将类放到任务池中 try { pool.awaitTermination(10,Tunit.SECONDS);//为每10秒执行一次MessageJob 类 } catch (InterruptedException e) { e.printStackTrace(); } finally{ if(pool.isShutdown()){ pool.shutdown(); // 关闭池 } } }
以下为处理业务的类
public class MessageJob implements Runnable{ @Override public void run() { System.out.println(Thread.currentThread().getName());// 打印线程名 } }
MessageJob 类一定要继承Runnable接口,这样execute()方法才能执行MessageJob方法。
ThreadPoolExecutor池应用:
ThreadPoolExecutor(int corePoolSize, int maximumPoolSize,long keepAliveTime, TimeUnit unit,
BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler)
corePoolSize: 线程池维护线程的最少数量
maximumPoolSize:线程池维护线程的最大数量
keepAliveTime: 线程池维护线程所允许的空闲时间
unit: 线程池维护线程所允许的空闲时间的单位
workQueue: 线程池所使用的缓冲队列
handler: 线程池对拒绝任务的处理策略
/** *如果任务线程越过最大线徎,将保存到队列中,如果队列设置不够大,越出队列会报异常 * * */ public static void main(String[] args){ BlockingQueue<Runnable> queue = new LinkedBlockingDeque<Runnable>();// 无限大的队列 // 10条线程,最大20,10秒无动作释放线程 ThreadPoolExecutor executor = new ThreadPoolExecutor(10,20,10,TimeUnit.SECONDS,queue); MessageJob message[] = new MessageJob[10]; for(int i = 0 ; i < 10 ; i++){ message[i] = new MessageJob(); // 每循环一次实列化一次 executor.execute(message); } if (executo.isShutdown()) { executo.shutdown(); } }
以下为处理业务的类
public class MessageJob implements Runnable{ @Override public void run() { System.out.println(Thread.currentThread().getName());// 打印线程名 } }
相关推荐
JDK自带线程池分析 JDK 自带线程池是 Java 语言中用于管理和执行线程的工具,旨在提高多线程编程的效率和灵活性。本文将详细介绍 JDK 自带线程池的组成、创建方法、优点和常见应用场景。 多线程技术 多线程技术是...
jdk自带线程池实例详解 jdk自带的线程池是Java开发中一个非常重要的概念,特别是在多线程编程中。线程池是线程的容器,每次只执行额定数量的线程,线程池就是用来管理这些额定数量的线程。下面我们来详细了解jdk...
3. **使用JDK自带线程池的阻塞服务器**:通过线程池管理线程资源,提高了资源利用率,减少了线程创建销毁的开销。 4. **NIO基础知识**:介绍了NIO的基本概念,包括缓冲区(Buffer)、通道(Channel)、选择器(Selector)...
“相关的性能参数已经优化好”意味着开发者可能已经调整了Tomcat的默认配置,例如线程池大小、内存分配、连接超时等关键参数,以提高其在特定工作负载下的性能表现。这有助于在服务器高负载下保持良好的响应速度和...
5. `jconsole`:JDK自带的JVM监控工具,提供性能分析和内存管理等功能。 6. `jmap`:用于查看堆内存详细信息,辅助诊断内存泄漏问题。 四、JDK 1.6的开发实践 在实际开发中,JDK 1.6广泛应用于企业级应用、桌面...
Java线程池是一种高效利用系统资源的机制,它允许开发者预先配置一定数量的线程,以便在...通过对JDK自带的`ThreadPoolExecutor`源码的学习,我们可以更深入地了解线程池的工作细节,以便更好地利用这一强大的工具。
实现原理为采用Socket原理、线程池、输入输出流及简单的HTTP协议,麻烦虽小,五脏俱全,...JAR编译的JDK版本1.6,至少要JDK1.5以上,因为其中用到JDK自带的线程池,内附源码,用户可以自已将源码再打包。 下载路径为:
普通JDK自带的线程池时无法实现线程池的自动切换,基于监控与上下文自动切换的需求,封住了一套taxi开头的线程池,接入方式很简单,它的使用方式与Jdk的使用基本方式一致,只需在对应的类前加一个Taxi,现将对应方式...
JDK提供了一系列的线程池实现,包括`ThreadPoolExecutor`、`ScheduledThreadPoolExecutor`以及`Executors`工厂类。`ThreadPoolExecutor`是线程池的核心实现,它接受五个参数进行初始化: 1. `corePoolSize`: 核心...
- **并发工具库增强**:增加了 ExecutorService 接口和一系列实现类,使得线程池的管理更加简单易用。 - **集合框架增强**:新增了并发集合类,如 ConcurrentHashMap 和 CopyOnWriteArrayList,提高了多线程环境下的...
RejectedExecutionHandler 的实现 JDK 自带的默认有 4 种: * AbortPolicy:丢弃任务,抛出运行时异常 * CallerRunsPolicy:由提交任务的线程来执行任务 * DiscardPolicy:丢弃这个任务,但是不抛异常 * ...
这涉及到使用JDK自带的工具如`jstat`、`jmap`、`jhat`和`jfr`(Java飞行记录器)等。 4. **垃圾回收**:垃圾回收是Java性能管理的重要方面,指南提供了关于不同垃圾收集器的详细信息,如G1、Shenandoah、ZGC等,...
MyEclipse自带的JDK可能不是你想要使用的版本,或者你可能希望针对特定项目使用不同的JDK。在Tomcat配置界面,选择“JRE”选项卡,点击“Add”按钮。在弹出的窗口中,浏览并选择你系统中安装的JDK路径,然后点击...
在介绍Java泥潭问题时,文档提到了Runtime.getRuntime().exec()的不稳定性和JDK自带的Timer类的使用场合,以及池的合理设计,例如对象池、线程池和连接池的设计。还特别提醒了JDK1.5线程池和Timer使用的陷阱。 最后...
常用的线程池有两种:JDK 自带的和 Spring 线程池。 在本文中,我们使用 Spring API 来构建一个线程池。线程池可以避免线程无限制的被创建,避免应用资源无限制的被占用导致的系统宕掉的问题。 三、异常的捕获 当...
Java自带的并发框架通过提供高级的并发工具和类,使开发者能够更安全、更高效地编写多线程程序,避免了直接操作底层并发原语带来的复杂性和潜在风险。通过理解和熟练使用这些工具,我们可以构建出更健壮、更具伸缩性...
5. JDK自带的jvisualvm工具可以提供CPU监控、内存分析、线程检查等多方面信息,因此答案是D,都可以。 6. 这段代码涉及到Java的嵌套类。在外部类中直接创建内部类的对象,会先执行外部类的构造器,然后是内部类的...
- 使用JDK自带的`jstack`工具:通过命令行执行`jstack <pid>`,其中`pid`是Java进程的ID,可以得到应用程序的Thread Dump。 - 异常触发:某些情况下,连续三次按下Ctrl+Break(Windows)或Ctrl+\(Unix/Linux)...