关于Java线程池的一点理解

痛定思痛。 2021-06-24 16:09 414阅读 0赞

一：线程池

线程池的作用就是限制系统中执行线程的数量。

根据系统环境的情况，可以自动或者手动设置线程的数量，达到运行的最佳效果。使用线程池可以减少线程的创建和销毁次数，每个工作线程都可以重复被利用，可以执行多个任务。每个线程大约需要1M的内存，可以根据系统的承受能力设置线程池的大小。Java里面线程池的真正接口是ExecutorService。

下面是一些常用的静态工厂，生成一些常用的线程池：

1.newSingleThreadExecutor

创建一个单线程的线程池，这个线程池只有一个线程在工作，此线程池保证所有任务的执行顺序按照任务的提交顺序执行。

2.newFixedTheadPool

创建固定大小的线程池。每次提交一个任务就创建一个线程，知道线程达到线程池的最大大小。线程池的大小一旦达到最大值就保持不变，如果某一个线程因为执行异常结束，那么线程池会补充一个新线程。

3.newCachedThreadPool

创建一个可缓存的线程池，如果线程池的大小超过了处理任务所需要的线程，那么就会回收部分空闲（1分钟不执行）的线程，当任务书增加是，此线程池又可以智能的添加新线程来处理任务，此线程池不会对线程池大小做限制，线程池大小完全依赖于操作系统能够创建线程的大小。

4.newScheduledThreadPool

创建一个大小无限的线程池，此线程池支持定时以及周期性的执行任务的需求。

实例

MyThread 写道

package com.honzh.mwq.test;  
  
import java.io.IOException;  
  
public class MyThread implements Runnable \{  
private int i;  
  
public MyThread(int i) \{  
this.i = i;  
\}  
  
public void run() \{  
try \{  
FileOutUtil.out(Thread.currentThread().getName() + " " + this.i + " 正在执行...");  
\} catch (IOException e) \{  
e.printStackTrace();  
\}  
\}  
\}

public static void main(String[] args) {
    		ExecutorService pool = Executors.newFixedThreadPool(2);
    		for (int i = 0 ; i < 100000000; i++) {
    			pool.execute(new MyThread(i));
    		}
    
    		pool.shutdown();
    		try {
    			FileOutUtil.out("pool is shutdown");
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    
    	}

public static void main(String[] args) {
    		ExecutorService pool = Executors.newCachedThreadPool();
    		for (int i = 0 ; i < 1000000000; i++) {
    			pool.execute(new MyThread(i));
    		}
    
    		pool.shutdown();
    		try {
    			FileOutUtil.out("pool is shutdown");
    		} catch (IOException e) {
    			e.printStackTrace();
    		}
    	}

但是经过测试，以上代码依然没有摆脱内存会溢出的问题。

后面继续寻找好的解决方案。。。。

以上先介绍Java自带线程池的使用方法