`
w54653520
  • 浏览: 23137 次
  • 性别: Icon_minigender_1
  • 来自: 北京
社区版块
存档分类
最新评论

jdk 自带线程池

阅读更多

 

以前很少写这些文档,可后来发现自己所了解的东西慢慢的忘记了好多,所以准备整理一下,不知道说的对不对,如果哪里有不对的地方,请谅解并给出更正,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自带线程池分析 JDK 自带线程池是 Java 语言中用于管理和执行线程的工具,旨在提高多线程编程的效率和灵活性。本文将详细介绍 JDK 自带线程池的组成、创建方法、优点和常见应用场景。 多线程技术 多线程技术是...

    jdk自带线程池实例详解

    jdk自带线程池实例详解 jdk自带的线程池是Java开发中一个非常重要的概念,特别是在多线程编程中。线程池是线程的容器,每次只执行额定数量的线程,线程池就是用来管理这些额定数量的线程。下面我们来详细了解jdk...

    Mina2.0学习笔记(重点)

    3. **使用JDK自带线程池的阻塞服务器**:通过线程池管理线程资源,提高了资源利用率,减少了线程创建销毁的开销。 4. **NIO基础知识**:介绍了NIO的基本概念,包括缓冲区(Buffer)、通道(Channel)、选择器(Selector)...

    tomcat7内置jdk版

    “相关的性能参数已经优化好”意味着开发者可能已经调整了Tomcat的默认配置,例如线程池大小、内存分配、连接超时等关键参数,以提高其在特定工作负载下的性能表现。这有助于在服务器高负载下保持良好的响应速度和...

    jdk_api_1_6中文版

    5. `jconsole`:JDK自带的JVM监控工具,提供性能分析和内存管理等功能。 6. `jmap`:用于查看堆内存详细信息,辅助诊断内存泄漏问题。 四、JDK 1.6的开发实践 在实际开发中,JDK 1.6广泛应用于企业级应用、桌面...

    _JAVA线程池介绍以及简单实例.doc

    Java线程池是一种高效利用系统资源的机制,它允许开发者预先配置一定数量的线程,以便在...通过对JDK自带的`ThreadPoolExecutor`源码的学习,我们可以更深入地了解线程池的工作细节,以便更好地利用这一强大的工具。

    简单的JAVA HTML服务器

    实现原理为采用Socket原理、线程池、输入输出流及简单的HTTP协议,麻烦虽小,五脏俱全,...JAR编译的JDK版本1.6,至少要JDK1.5以上,因为其中用到JDK自带的线程池,内附源码,用户可以自已将源码再打包。 下载路径为:

    MThread:实现线程池已有的功能,同时对线程池的本身的使用与运行情况提供监控;与ILog组件配合使用,可以实现线程上下文的自动切换

    普通JDK自带的线程池时无法实现线程池的自动切换,基于监控与上下文自动切换的需求,封住了一套taxi开头的线程池,接入方式很简单,它的使用方式与Jdk的使用基本方式一致,只需在对应的类前加一个Taxi,现将对应方式...

    Java 高并发六:JDK并发包2详解

    JDK提供了一系列的线程池实现,包括`ThreadPoolExecutor`、`ScheduledThreadPoolExecutor`以及`Executors`工厂类。`ThreadPoolExecutor`是线程池的核心实现,它接受五个参数进行初始化: 1. `corePoolSize`: 核心...

    [Java参考文档].JDK_API_1_6_zh_CN.CHM百度网盘下载地址

    - **并发工具库增强**:增加了 ExecutorService 接口和一系列实现类,使得线程池的管理更加简单易用。 - **集合框架增强**:新增了并发集合类,如 ConcurrentHashMap 和 CopyOnWriteArrayList,提高了多线程环境下的...

    7000字+24张图带你彻底弄懂线程池.doc

    RejectedExecutionHandler 的实现 JDK 自带的默认有 4 种: * AbortPolicy:丢弃任务,抛出运行时异常 * CallerRunsPolicy:由提交任务的线程来执行任务 * DiscardPolicy:丢弃这个任务,但是不抛异常 * ...

    JDK12-java-se-monitoring-and-management-guide.pdf

    这涉及到使用JDK自带的工具如`jstat`、`jmap`、`jhat`和`jfr`(Java飞行记录器)等。 4. **垃圾回收**:垃圾回收是Java性能管理的重要方面,指南提供了关于不同垃圾收集器的详细信息,如G1、Shenandoah、ZGC等,...

    如何查看服务器配置 Myeclipse如何配置Tomcat服务器和JDK.pdf

    MyEclipse自带的JDK可能不是你想要使用的版本,或者你可能希望针对特定项目使用不同的JDK。在Tomcat配置界面,选择“JRE”选项卡,点击“Add”按钮。在弹出的窗口中,浏览并选择你系统中安装的JDK路径,然后点击...

    Java问题定位技术.pdf

    在介绍Java泥潭问题时,文档提到了Runtime.getRuntime().exec()的不稳定性和JDK自带的Timer类的使用场合,以及池的合理设计,例如对象池、线程池和连接池的设计。还特别提醒了JDK1.5线程池和Timer使用的陷阱。 最后...

    子线程任务发生异常,主线程事务如何回滚

    常用的线程池有两种:JDK 自带的和 Spring 线程池。 在本文中,我们使用 Spring API 来构建一个线程池。线程池可以避免线程无限制的被创建,避免应用资源无限制的被占用导致的系统宕掉的问题。 三、异常的捕获 当...

    java自带并发框架

    Java自带的并发框架通过提供高级的并发工具和类,使开发者能够更安全、更高效地编写多线程程序,避免了直接操作底层并发原语带来的复杂性和潜在风险。通过理解和熟练使用这些工具,我们可以构建出更健壮、更具伸缩性...

    亿阳信通java编程题

    5. JDK自带的jvisualvm工具可以提供CPU监控、内存分析、线程检查等多方面信息,因此答案是D,都可以。 6. 这段代码涉及到Java的嵌套类。在外部类中直接创建内部类的对象,会先执行外部类的构造器,然后是内部类的...

    java故障排查ThreadDump

    - 使用JDK自带的`jstack`工具:通过命令行执行`jstack &lt;pid&gt;`,其中`pid`是Java进程的ID,可以得到应用程序的Thread Dump。 - 异常触发:某些情况下,连续三次按下Ctrl+Break(Windows)或Ctrl+\(Unix/Linux)...

Global site tag (gtag.js) - Google Analytics