/** * ExecutorServiceAnalyze.java */ package com.xxx.common.concurrent; /** * ExecutorService 线程池 */ public class ExecutorServiceAnalyze { // ExecutorService接口 // 实现类有AbstractExecutorService,ScheduledThreadPoolExecutor,ThreadPoolExecutor. // 任务分两类:一类是实现了Runnable接口的类,一类是实现了Callable接口的类. // Runnable任务没有返回值,而Callable任务有返回值. // Callable的call()方法只能通过ExecutorService的submit(Callable<T> task)方法来执行, // 并且返回一个<T> Future<T>,是表示任务等待完成的Future. // Runnable不会返回结果,并且无法抛出经过检查的异常. // shutdown 平滑地关闭ExecutorService,停止接受任何新的任务且等待已经提交的任务执行完成. // awaitTermination 使线程等待timeout时长,当超过timeout时间后,会监测ExecutorService是否已经关闭, // 若关闭则返回true,否则返回false. 和shutdown方法组合使用. // shutdownNow 强制关闭ExecutorService,取消所有运行中的任务和在工作队列中等待的任务, // 这个方法返回一个List列表,列表中返回的是等待在工作队列中的任务. // List<Runnable> runs = service.shutdownNow(); // isTerminated 校验ExecutorService当前的状态是否关闭状态. // isShutdown 在ExecutorService关闭后返回true,否则返回false. // execute 将一个实现了Runnable类型的类的实例作为参数传入execute方法并执行. // submit 提交一个有返回值的任务用于执行,参数为Runnable或Callable. /** * Application entry point. */ public static void main(String[] args) { // 创建一个使用单个 worker 线程的 Executor // ExecutorService executorService = Executors.newSingleThreadExecutor(); // 创建一个可重用固定线程数的线程池 // ExecutorService executorService = Executors.newFixedThreadPool(10); // 可安排在给定的延迟后运行或定期执行的命令 // ExecutorService executorService = Executors.newScheduledThreadPool(10); // 可根据需要创建新线程的线程池 // ExecutorService executorService = Executors.newCachedThreadPool(); } }
相关推荐
运用JAVA的concurrent.ExecutorService线程池实现socket的TCP和UDP连接
运用JAVA的concurrent.ExecutorService线程池实现socket的TCP和UDP连接.doc
本程序实现了ExecutorService线程池,内置说明txt说明,可以参考
今天小编就为大家分享一篇关于在spring boot中使用java线程池ExecutorService的讲解,小编觉得内容挺不错的,现在分享给大家,具有很好的参考价值,需要的朋友一起跟随小编来看看吧
在main方法中,创建了一个BankAccountManager对象和ExecutorService线程池,并初始化了1000个账户和10个线程。然后循环遍历每个账户,将每个账户提交给线程池执行转账操作。在transfer方法中,获取两个账户对象和...
在系统的设计和实现过程中,采用了多种技术和方法,例如 Okhttp3 框架、socket 通信、ExecutorService 线程池、Bezier 曲线绘制、mob 发送短信、libqrencode 库生成二维码、SMSSDK For Android 进行注册登录时的短信...
作为爬虫框架,它使用httpclient作为获取网页工具、使用Jsoup作为分析页面定位抓取内容、使用ExecutorService线程池作为定时增量抓取、Jdiy作为持久层框架。不熟悉这些名词的同学们可以先行百度一下这些都是什么,起...
主要介绍了Java ExecutorService四种线程池使用详解,小编觉得挺不错的,现在分享给大家,也给大家做个参考。一起跟随小编过来看看吧
主要介绍了Java 线程池ExecutorService详解及实例代码的相关资料,线程池减少在创建和销毁线程上所花的时间以及系统资源的开销.如果不使用线程池,有可能造成系统创建大量线程而导致消耗系统内存以及”过度切换
NULL 博文链接:https://x125858805.iteye.com/blog/2191873
接口 java.util.concurrent.ExecutorService 表述了异步执行的机制,并且...壹個 ExecutorService 实例因此特别像壹個线程池。事实上,在 java.util.concurrent 包中的 ExecutorService 的实现就是壹個线程池的实现。
//Runtime的availableProcessors()方法返回当前系统的CPU的数目 //系统的CPU越多,线程池中工作线程的数目也越多 executorService= Executors.newFixedThreadPool( Runtime.getRuntime()....
Java中的线程池Executors java中的线程池Executors是Java并发编程中的一种重要概念,它提供了一种高效、灵活的线程管理机制。使用线程池可以降低资源消耗,提高响应速度,提高线程的可管理性。 线程池的优点 1. ...
该组件中,Executor 和 ExecutorService 接口 定义了线程池最核心的几个方法,提交任务 submit ()、关闭线程池 shutdown()。抽象类 AbstractExecutorService 主要对公共行为 submit()系列方法进行了实现,这些 ...
Executors: 是java.util.concurrent包下的一个类,提供了若干个静态方法,用于生成不同类型的线程池。Executors一共可以创建下面这四类线程池: 1.newFixedThreadPool创建一个可缓存线程池,如果线程池长度超过...
美团动态线程池实践思路开源项目(DynamicTp)线程池源码解析及通知告警篇 本文详细介绍了美团动态线程池实践思路开源项目(DynamicTp)的通知告警模块,该模块提供了多种通知告警功能,每一个通知项都可以独立配置...
这段代码实现了一个简单的线程池ExecutorService,其中使用了Java的匿名内部类。在类的构造方法中,首先创建了一个固定大小为5的线程池。然后通过循环提交了10个任务到线程池中执行。每个任务都是一个匿名内部类实现...
ExecutorService 可以将任务提交给线程池,线程池中的线程将执行任务,从而提高服务器端的并发处理能力。 在示例代码中,使用了 Java 5 的 ExecutorService 来实现线程池。服务器端使用 ServerSocket 来监听客户端...
线程池执行者 ThreadPoolExecutor,定时执行者服务 ScheduledExecutorService, 使用 ForkJoinPool 进行分叉和合并,锁 Lock,读写锁 ReadWriteLock 原子性长整型 AtomicLong,原子性引用型 AtomicReference 修改数据:...
一、线程池 1、什么是线程池 自定义的线程类不管是继承...public static ExecutorService newFixedThreadPool(int nThreads); 得到一个线程对象,初始化参数是要求的当前线程池中的线程数 public Future submit(Runnab