java基础——多线程（线程池）

一、线程池

概念原理理解：

首先介绍在Tcp服务器编程模型的原理，每一个客户端连接用一个单独的线程为之服务，当与客户端的会话结束时，线程也就结束了，即每来一个客户端连接，服务器端就要创建一个新线程。这好比假设每个报名学员都要通过我来亲自接待，以便给每个学员一种好的感觉，但每个学员报名手续要花费半个小时，对于50名同学，我一个个接待和为之办理手续，显然不实际，我会怎么做呢？我会先接待每一个学员，打完招呼后，再把他分配给一名工作人员去办理手续，这样，我就接待了每名学员。
如果访问服务器的客户端很多，那么服务器要不断地创建和销毁线程，这将严重影响服务器的性能。如果真的来一名学员，我们都安排一名新工作人员为之服务，也是不可能的，那公司岂不是要招聘很多工作人员？而是应该一名工作人员服务完一名学员，空闲下来后，一旦有新的学员要服务，我又立即安排该工作人员为新学员服务。线程池的概念与此类似，首先创建一些线程，它们的集合称为线程池，当服务器接受到一个客户请求后，就从线程池中取出一个空闲的线程为之服务，服务完后不关闭该线程，而是将该线程还回到线程池中。

在线程池的编程模式下，任务是提交给整个线程池，而不是直接交给某个线程，线程池在拿到任务后，它就在内部找有无空闲的线程，再把任务交给内部某个空闲的线程，这就是封装。记住，任务是提交给整个线程池，一个线程同时只能执行一个任务，但可以同时向一个线程池提交多个任务。

1、线程池的概念与Executors类的应用

1）创建固定大小的线程池

2）创建缓存线程池
3）创建单一线程池（如何实现线程死掉后重新启动？）

import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class ThreadPoolTest {
public static void main(String[] args) {
/*1、固定线程池
// 创建一个线程池,每次只执行固定的3个线程任务
ExecutorService pool = Executors.newFixedThreadPool(3);*/

/*2、缓存线程池，内部执行线程的任务不定,实现线程死掉后重新启动*/
//ExecutorService pool = Executors.newCachedThreadPool();

/*3、创建单一线程池*/
ExecutorService pool = Executors.newSingleThreadExecutor();

//向pool池提交了10个任务，有十个Runnable
for (int i = 1; i <= 3; i++) {
final int task = i;
pool.execute(new Runnable() {
@Override
public void run() {
//每个任务执行10次循环
for (int j = 1; j <= 5; j++) {
try {
Thread.sleep(20);
} catch (InterruptedException e) {
e.printStackTrace();
}
//线程x，正在循环第j次 ，在第i个任务里
System.out.println(Thread.currentThread().getName()
+ " loop of  " + j+"  for task of  "+task);
}
}
});
}
//执行完所有的任务，结束线程池
pool.shutdown();

//只要程序执行到这，立即结束线程
//pool.shutdownNow();
}
}

打印：

1）创建固定大小的线程池

pool-1-thread-3 loop of  1  for task of  3

pool-1-thread-2 loop of  1  for task of  2

pool-1-thread-1 loop of  1  for task of  1

pool-1-thread-3 loop of  2  for task of  3

pool-1-thread-2 loop of  2  for task of  2

pool-1-thread-1 loop of  2  for task of  1

pool-1-thread-1 loop of  3  for task of  1

pool-1-thread-2 loop of  3  for task of  2

pool-1-thread-3 loop of  3  for task of  3

2）创建缓存线程池

pool-1-thread-1 loop of  1  for task of  1

pool-1-thread-2 loop of  1  for task of  2

pool-1-thread-3 loop of  1  for task of  3

pool-1-thread-2 loop of  2  for task of  2

pool-1-thread-1 loop of  2  for task of  1

pool-1-thread-3 loop of  2  for task of  3

pool-1-thread-1 loop of  3  for task of  1

pool-1-thread-2 loop of  3  for task of  2

pool-1-thread-3 loop of  3  for task of  3

3）创建单一线程池

pool-1-thread-1 loop of  1  for task of  1

pool-1-thread-1 loop of  2  for task of  1

pool-1-thread-1 loop of  3  for task of  1

pool-1-thread-1 loop of  1  for task of  2

pool-1-thread-1 loop of  2  for task of  2

pool-1-thread-1 loop of  3  for task of  2

pool-1-thread-1 loop of  1  for task of  3

pool-1-thread-1 loop of  2  for task of  3

pool-1-thread-1 loop of  3  for task of  3

2、关闭线程池

shutdown与shutdownNow的比较

3|用线程池启动定时器

1）调用ScheduledExecutorService的schedule方法，返回的ScheduleFuture对象可以取消任务。
2）支持间隔重复任务的定时方式，不直接支持绝对定时方式，需要转换成相对时间方式。

//3、用线程池启动定时器
ScheduledExecutorService scheduledService = Executors.newScheduledThreadPool(1);
scheduledService.scheduleAtFixedRate(
new Runnable(){
public void run() {
System.out.println("bomb!!!");
}},  //实例一个Runable对象
5, // 起始延迟 时间
1,//每隔一秒爆炸一次
TimeUnit.SECONDS);//秒为单位

}