4.线程池

由于不需要每次处理复杂逻辑耗时操作,比如加载网络并不需要都开启一个新的线程,可以用线程池处理,把线程存起来,用的时候在取出来,在ondestory里去销毁线程,这样就会节省内存

线程池的原理(看看就行):

public class ThreadPool {	int maxCount = 3;	AtomicInteger count =new AtomicInteger(0);// 当前开的线程数  count=0	LinkedList<Runnable> runnables = new LinkedList<Runnable>();	public void execute(Runnable runnable) {		runnables.add(runnable);		if(count.incrementAndGet()<=3){			createThread();// 最大开三个线程		}	}	private void createThread() {		new Thread() {			@Override			public void run() {				super.run();				while (true) {					// 取出来一个异步任务					if (runnables.size() > 0) {						Runnable remove = runnables.remove(0); //在集合中移除第一个对象 返回值正好是移除的对象						if (remove != null) {							remove.run();						}					}else{						//  等待状态   wake();					}				}			}		}.start();	}}

线程池的用法:在本项目中新建一个类管理线程池,主要用的就是ThreadPoolExecutor这个类

public class ThreadManager {	private ThreadManager() {	}	private static ThreadManager instance = new ThreadManager();	private ThreadPoolProxy longPool;	private ThreadPoolProxy shortPool;	public static ThreadManager getInstance() {		return instance;	}	// 联网比较耗时	// 开启线程数一般是cpu的核数*2+1	public synchronized ThreadPoolProxy createLongPool() {		if (longPool == null) {			longPool = new ThreadPoolProxy(5, 5, 5000L);		}		return longPool;	}	// 操作本地文件	public synchronized ThreadPoolProxy createShortPool() {		if(shortPool==null){			shortPool = new ThreadPoolProxy(3, 3, 5000L);		}		return shortPool;	}	public class ThreadPoolProxy {		private ThreadPoolExecutor pool;		private int corePoolSize;		private int maximumPoolSize;		private long time;		public ThreadPoolProxy(int corePoolSize, int maximumPoolSize, long time) {			this.corePoolSize = corePoolSize;			this.maximumPoolSize = maximumPoolSize;			this.time = time;		}		/**		 * 执行任务		 * @param runnable		 */		public void execute(Runnable runnable) {			if (pool == null) {				// 创建线程池				/*				 * 1. 线程池里面管理多少个线程2. 如果排队满了, 额外的开的线程数3. 如果线程池没有要执行的任务 存活多久4.				 * 时间的单位 5 如果 线程池里管理的线程都已经用了,剩下的任务 临时存到LinkedBlockingQueue对象中 排队				 */				pool = new ThreadPoolExecutor(corePoolSize, maximumPoolSize,						time, TimeUnit.MILLISECONDS,						new LinkedBlockingQueue<Runnable>(10));			}			pool.execute(runnable); // 调用线程池 执行异步任务		}		/**		 * 取消任务		 * @param runnable		 */		public void cancel(Runnable runnable) {			if (pool != null && !pool.isShutdown() && !pool.isTerminated()) {				pool.remove(runnable); // 取消异步任务			}		}	}}

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏Golang语言社区

游戏服务器之多线程发送(中)

4、拷贝数据到会话的发送缓冲区 交换发送队列和添加队列,拷贝会话的发送队列的数据到会话的发送缓冲区 BOOL ExecSockDataMgr::CopyWait...

34430
来自专栏技术博文

excel导入与导出

基本上导出的文件分为两种: 1:类Excel格式,这个其实不是传统意义上的Excel文件,只是因为Excel的兼容能力强,能够正确打开而已。修改这种文件后再保存...

31160
来自专栏菩提树下的杨过

spring集成kafka

一、添加依赖项 compile 'org.springframework.kafka:spring-kafka:1.2.2.RELEASE' 二、发消息(生产者...

23580
来自专栏猿天地

spring data mongodb 代码连接数据库方式

平时我们用spring data mongodb都是采用xml配置的方式来链接数据库 但是往往有的时候需要用代码的方式来实现。 比如说我们有可能要同时操作多个d...

377140
来自专栏博客园迁移

线程池ThreadPoolExecutor整理

  java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类

18910
来自专栏搞前端的李蚊子

基于Vue.js的大型报告页项目实现过程及问题总结(一)

今年5月份的时候做了一个测评报告项目,需要在网页正常显示的同时且可打印为pdf,当时的技术方案采用jquery+template的方式,因为是固定模板所以并没有...

57860
来自专栏IT笔记

SpringBoot开发案例之多任务并行+线程池处理

前几篇文章着重介绍了后端服务数据库和多线程并行处理优化,并示例了改造前后的伪代码逻辑。当然了,优化是无止境的,前人栽树后人乘凉。作为我们开发者来说,既然站在了巨...

1.8K190
来自专栏阿杜的世界

Java线程池监控小结

最近我们组杨青同学遇到一个使用线程池不当的问题:异步处理的线程池线程将主线程hang住了,分析代码发现是线程池的拒绝策略设置得不合理,设置为CallerRuns...

16410
来自专栏林冠宏的技术文章

通俗易懂,各常用线程池的执行 流程图

corePoolSize,maximumPoolSize,workQueue之间关系。

60240
来自专栏finleyMa

Laravel 前后台共享数据

5.5以后可以这么写, 用 @json Blade 指令替代手动 json_encode

21840

扫码关注云+社区

领取腾讯云代金券