Java线程池的一个测验

因为项目需要，学习了一下Java的线程池，即ExecutorService的使用。ExecutorService有很多实现，具体《Thinking in Java》上面说的很清楚。比较常用的一种就是FixedThreadPool，表示生成固定大小的线程池。

下面的例子也主要是围绕FixedThreadPool展开的。

 

下面的例子主要讨论两个问题。

问题1.线程池固定大小，假设为5.那么向线程池放入10个线程，运行效果如何？其他线程的状态？

问题2.那么如何从线程池中移除某一个线程，确切说是使某一个线程成为空闲线程？

 

代码如下：

package job;

import java.util.concurrent.TimeUnit;

import Test.MainThread;
/***
 * @author 两手空空
 * 线程类
 */
public class JobThread extends Thread {
	
	//为线程命名
	public JobThread(String name, long threadId) {
		super(name);
	}
	//自定义的线程
	public void run() {
		while(MainThread.threadNameMap.containsKey(this.getName())) {	//如果包含此名称就一直运行
			try {
				System.out.println("线程名称-----" + this.getName());
				TimeUnit.SECONDS.sleep(4);
			} catch (InterruptedException e) {
				e.printStackTrace();
			}
		}
		System.out.println("线程结束，线程名称:" + this.getName());
	}
}

 

 

package Test;
import java.util.HashMap;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;

import job.JobThread;

/***
 * @author Administrator
 * 测试类
 */
public class MainThread {

	public static final int THREADPOOL_SIZE = 5;
	public static ExecutorService exec = Executors.newFixedThreadPool(THREADPOOL_SIZE);	//线程池
	public static HashMap<String, String> threadNameMap = new HashMap();	//用来存储线程名称的Map

	public static void main(String[] args) {
		//Thread.setDefaultUncaughtExceptionHandler();

		/*向线程池中插入10个线程，但是线程池只允许最大5个线程，所以其他5个线程等待中*/
		for(int i = 0; i< THREADPOOL_SIZE + 5; i++) {	
			String threadName = getTreadName(i);
			threadNameMap.put(threadName, threadName);
			exec.execute(new JobThread(threadName, i));
		}

		try {
			System.out.println("主线程睡一会儿！");
			TimeUnit.SECONDS.sleep(8);
		} catch (InterruptedException e) {
			e.printStackTrace();
			System.out.println("醒了！");
		}	//睡10秒

		//注释的部分
		//removeThread(0);

	}

	//移除线程
	public static void removeThread(int i) {
		threadNameMap.remove(getTreadName(i));
		System.out.println("删除线程Thread" + i + ",Hash表的Size" + threadNameMap.size());
	}

	//根据一定规则生成线程的名称
	private static String getTreadName(int i) {
		return "theadname" + i;
	}
}

 

1.直接运行代码，打印结果如下：

线程名称-----theadname0
主线程睡一会儿！
线程名称-----theadname2
线程名称-----theadname4
线程名称-----theadname1
线程名称-----theadname3
线程名称-----theadname3
线程名称-----theadname0
线程名称-----theadname1
线程名称-----theadname4
线程名称-----theadname2
线程名称-----theadname3
线程名称-----theadname2
线程名称-----theadname0
线程名称-----theadname4
线程名称-----theadname1
。。。。。。。。。。。

发现，打印的线程名称一直从threadname1到threadname4，没有其他的名称。

由此证明，向线程池中放入10个线程，但是线程池的大小为5，只能给5个线程分配CPU，运行的就是最先放入线程池中的5个线程，其他线程都处于就绪状态（阻塞状态）。

 

2.去掉//removeThread(0);这句的注释。打印结果如下：

线程名称-----theadname0
主线程睡一会儿！
线程名称-----theadname1
线程名称-----theadname3
线程名称-----theadname2
线程名称-----theadname4
线程名称-----theadname1
线程名称-----theadname0
线程名称-----theadname3
线程名称-----theadname2
线程名称-----theadname4
线程名称-----theadname4
删除线程Thread0,Hash表的Size9
线程结束，线程名称:theadname0
线程名称-----theadname1
线程名称-----theadname5
线程名称-----theadname2
线程名称-----theadname3

 

从结果中可以看出，在移除线程之前，运行的线程还是从thread0到thread4。当移除线程thread0后，新的线程thread5开始运行。 

 

结论如下：

1.线程池固定大小，假设为5.那么向线程池放入10个线程，运行效果如何？其他线程的状态？

a.线程池的概念就是你不断的向其中push请求，但是它只能处理规定额度的线程，多余的线程都会在其中等待。
b.当其中一个线程处理完毕（业务执行完毕或退出while循环），线程池就会自动从等待的队列中取出一个作业，使用空闲的线程来运行这个作业。运行线程池中的哪个线程完全随机。

 

2.那么如何从线程池中移除某一个线程，确切说是使某一个线程成为空闲线程？
线程池无法获取其中某一个线程并杀掉他，因为使用线程池的主线程和主线程开启的线程是平级的，谁都无权主宰另一方的存亡。但是可以换一个方式，委婉的达到目的。
a.主线程维护一个Hash表可以是一个HashMap。key值任意，但是要唯一，可以唯一标示一个线程。
b.所有放入线程池的线程，都要生成一个key值，然后存入这个HashMap中。
c.对于循环类的线程，如while(true)的线程。需要增加一个条件，每一轮循环校验这个线程的key是否存在于上面HashMap中。如果不存在则退出while循环。
d.虽然主线程不可以主宰其他线程的存亡，但是可以对自己的HashMap进行put或是remove操作。到此，只要从HashMap中移除线程对应的Key值，这个线程在下次循环的时候就会自动退出了。

 

其他操作，请参考JDK中描述。以上只是我对Java线程池做的一点测验和心得，欢迎大家交流~