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 条评论
登录 后参与评论

相关文章

  • 深入理解JVM(线程部分) Note

    由于计算机的存储设备与处理器的运算速度有几个数量级的差距,所以现代计算机系统都不得不加入一层读写速度尽可能接近处理器运算速度的高速缓存(Cache)来作为内存与...

    六月的雨
  • Java多线程知识点

    进程和线程的区别?多线程有什么好处? 进程:正在进行中的程序(直译)。 线程:就是进程中一个负责程序执行的控制单元(执行路径)

    六月的雨
  • Android使用RxJava+Retrofit2+Okhttp+MVP练习的APP

    六月的雨
  • Java 并发核心机制

    Java 的 java.util.concurrent 包(简称 J.U.C)中提供了大量并发工具类,是 Java 并发能力的主要体现(注意,不是全部,有部分并...

    静默虚空
  • 线程池实现原理-1

    这个看起来好像没有用到线程池,其实是因为没有可复用的线程,所以就一直创建新的线程了

    Java识堂
  • 高并发之——ThreadPoolExecutor类居然是这样保证线程池正确运行的...

    作者个人研发的在高并发场景下,提供的简单、稳定、可扩展的延迟消息队列框架,具有精准的定时任务和延迟队列处理功能。自开源半年多以来,已成功为十几家中小型企业提供了...

    冰河
  • (65) 线程的基本概念 / 计算机程序的思维逻辑

    在之前的章节中,我们都是假设程序中只有一条执行流,程序从main方法的第一条语句逐条执行直到结束。从本节开始,我们讨论并发,在程序中创建线程来启动多条执行流,并...

    swiftma
  • linux下进程和线程到底是什么?

    7537367
  • Java之线程,常用方法,线程同步,死锁

    1, 线程的概念 进程与线程 进程:每个进程都有独立的代码和数据空间(进程上下文),进程间的切换会有较大的开销,一个进程包含1--n个线程。(进程是资源分配的最...

    二十三年蝉
  • Java多线程编程

    1)设计更复杂 虽然有一些多线程应用程序比单线程的应用程序要简单,但其他的一般都更复杂。在多线程访问共享数据的时候,这部分代码需要特别的注意。线程之间的交互往往...

    Java团长

扫码关注云+社区

领取腾讯云代金券