JAVA 并发编程-线程池
Posted mfmdaoyou
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了JAVA 并发编程-线程池相关的知识，希望对你有一定的参考价值。
线程池的作用：
线程池作用就是限制系统中运行线程的数量。
依据系统的环境情况。能够自己主动或手动设置线程数量，达到运行的最佳效果；少了浪费了系统资源，多了造成系统拥挤效率不高。用线程池控制线程数量，其它线程排队等候。一个任务运行完毕，再从队列的中取最前面的任务開始运行。
为什么要用线程池:
1.降低了创建和销毁线程的次数，每一个工作线程都能够被反复利用。可运行多个任务。
2.能够依据系统的承受能力，调整线程池中工作线线程的数目，防止由于消耗过多的内存，而把server累趴下
Java里面线程池的顶级接口是Executor。可是严格意义上讲Executor并非一个线程池，而仅仅是一个运行线程的工具。
真正的线程池接口是ExecutorService。
要配置一个线程池是比較复杂的。尤其是对于线程池的原理不是非常清楚的情况下，非常有可能配置的线程池不是较优的。因此在Executors类里面提供了一些静态工厂。生成一些经常使用的线程池。
1.newSingleThreadExecutor
创建一个单线程的线程池。这个线程池仅仅有一个线程在工作，也就是相当于单线程串行运行全部任务。假设这个唯一的线程由于异常结束，那么会有一个新的线程来替代它。此线程池保证全部任务的运行顺序依照任务的提交顺序运行。
2.newFixedThreadPool
创建固定大小的线程池。
每次提交一个任务就创建一个线程。直到线程达到线程池的最大大小。线程池的大小一旦达到最大值就会保持不变。假设某个线程由于运行异常而结束。那么线程池会补充一个新线程。
3. newCachedThreadPool
创建一个可缓存的线程池。假设线程池的大小超过了处理任务所须要的线程，
那么就会回收部分空暇（60秒不运行任务）的线程，当任务数添加时。此线程池又能够智能的加入新线程来处理任务。此线程池不会对线程池大小做限制，线程池大小全然依赖于操作系统（或者说JVM）能够创建的最大线程大小。
4.newScheduledThreadPool(int corePoolSize)
（定时及周期性运行任务，稍后会具体介绍）
创建corePoolSize大小的线程池。此线程池支持定时以及周期性运行任务的需求。
newSingleThreadExecutor：
public class ThreadPoolTest {
/**
* @param args
*/
public static void main(String[] args) {
//固定线程池大小
// ExecutorService threadPool = Executors.newFixedThreadPool(3);
//可缓存的线程池
//ExecutorService threadPool = Executors.newCachedThreadPool();
//单线程的线程池
ExecutorService threadPool = Executors.newSingleThreadExecutor();
//向线程池中放入10个任务。每次仅仅能为一个任务服务（单线程的线程池）
for(int i=1;i<=10;i++){
final int task = i;
//运行任务（能够与new Thread（new Runnable(){}）相比，相当于10个任务创建10个线程，而此时仅仅有一个线程）
threadPool.execute(new Runnable(){
@Override
public void run() {
for(int j=1;j<=10;j++){
try {
Thread.sleep(20);
} catch (InterruptedException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
System.out.println(Thread.currentThread().getName() + " is looping of " + j + " for task of " + task);
}
}
});
}
//10个任务放入线程池后，才会运行以下的代码，打印出此提示信息。说明已经放入了10个任务
System.out.println("all of 10 tasks have committed! ");
//当线程池内存在线程时。是不会停止的，想要停止使用例如以下语句
//threadPool.shutdownNow();
//定时运行任务
// Executors.newScheduledThreadPool(3).scheduleAtFixedRate(
// new Runnable(){
// @Override
// public void run() {
// System.out.println("bombing!");
//
// }},
// 6,
// 2,
// TimeUnit.SECONDS);
}
}
运行结果：
all of 10 tasks havecommitted!
pool-1-thread-1 islooping of 1 for task of 1
pool-1-thread-1 islooping of 2 for task of 1
pool-1-thread-1 islooping of 3 for task of 1
pool-1-thread-1 islooping of 4 for task of 1
pool-1-thread-1 islooping of 5 for task of 1
pool-1-thread-1 islooping of 6 for task of 1
pool-1-thread-1 islooping of 7 for task of 1
pool-1-thread-1 islooping of 8 for task of 1
pool-1-thread-1 islooping of 9 for task of 1
pool-1-thread-1 islooping of 10 for task of 1
pool-1-thread-1 islooping of 1 for task of 2
pool-1-thread-1 islooping of 2 for task of 2
pool-1-thread-1 islooping of 3 for task of 2
pool-1-thread-1 islooping of 4 for task of 2
newFixedThreadPool：
运行结果：
all of 10 tasks havecommitted!
pool-1-thread-1 islooping of 1 for task of 1
pool-1-thread-3 islooping of 1 for task of 3
pool-1-thread-2 islooping of 1 for task of 2
pool-1-thread-3 islooping of 2 for task of 3
pool-1-thread-2 islooping of 2 for task of 2
pool-1-thread-1 islooping of 2 for task of 1
pool-1-thread-3 islooping of 3 for task of 3
pool-1-thread-2 islooping of 3 for task of 2
pool-1-thread-1 islooping of 3 for task of 1
pool-1-thread-1 islooping of 4 for task of 1
pool-1-thread-2 islooping of 4 for task of 2
pool-1-thread-3 islooping of 4 for task of 3
pool-1-thread-1 islooping of 5 for task of 1
pool-1-thread-2 islooping of 5 for task of 2
pool-1-thread-3 islooping of 5 for task of 3
pool-1-thread-1 islooping of 6 for task of 1
pool-1-thread-2 islooping of 6 for task of 2
pool-1-thread-3 islooping of 6 for task of 3
pool-1-thread-3 islooping of 7 for task of 3
pool-1-thread-1 islooping of 7 for task of 1
pool-1-thread-2 islooping of 7 for task of 2
pool-1-thread-3 islooping of 8 for task of 3
pool-1-thread-1 islooping of 8 for task of 1
pool-1-thread-2 islooping of 8 for task of 2
pool-1-thread-1 islooping of 9 for task of 1
pool-1-thread-3 islooping of 9 for task of 3
pool-1-thread-2 islooping of 9 for task of 2
pool-1-thread-3 islooping of 10 for task of 3
pool-1-thread-2 islooping of 10 for task of 2
pool-1-thread-1 islooping of 10 for task of 1
pool-1-thread-1 islooping of 1 for task of 6
pool-1-thread-2 islooping of 1 for task of 5
pool-1-thread-3 islooping of 1 for task of 4
pool-1-thread-3 islooping of 2 for task of 4
pool-1-thread-1 islooping of 2 for task of 6
pool-1-thread-2 islooping of 2 for task of 5
newCachedThreadPool：
运行结果：
all of 10 tasks havecommitted!
pool-1-thread-5 islooping of 1 for task of 5
pool-1-thread-1 islooping of 1 for task of 1
pool-1-thread-4 islooping of 1 for task of 4
pool-1-thread-2 islooping of 1 for task of 2
pool-1-thread-3 islooping of 1 for task of 3
pool-1-thread-6 islooping of 1 for task of 6
pool-1-thread-10 islooping of 1 for task of 10
pool-1-thread-7 islooping of 1 for task of 7
pool-1-thread-8 islooping of 1 for task of 8
pool-1-thread-9 islooping of 1 for task of 9
pool-1-thread-1 islooping of 2 for task of 1
pool-1-thread-3 islooping of 2 for task of 3
pool-1-thread-5 islooping of 2 for task of 5
pool-1-thread-2 islooping of 2 for task of 2
pool-1-thread-6 islooping of 2 for task of 6
pool-1-thread-4 islooping of 2 for task of 4
pool-1-thread-7 islooping of 2 for task of 7
pool-1-thread-9 islooping of 2 for task of 9
pool-1-thread-10 islooping of 2 for task of 10
pool-1-thread-8 islooping of 2 for task of 8
pool-1-thread-1 islooping of 3 for task of 1
总结：
创建一个单线程的线程池，依据输出结果我们能够知道在整个运行过程中共同拥有唯一的一个线程创建，仅仅有当前的任务完毕后，这个线程才会给其它任务提供服务。
创建固定大小的线程池。以上demo是以3个线程为例，那么线程池中会创建3个线程，每一个线程完毕各自的任务，仅仅有各自任务完毕后，才会给其它的任务提供服务。
创建一个可缓存的线程池，即须要几个线程，创建几个线程，每一个线程服务完毕各自的任务就可以。
附：
package com.tgb.hjy;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class TestSingleThreadExecutor {
public static void main(String[] args) {
//创建一个可重用固定线程数的线程池--单线程的线程池
ExecutorService pool = Executors. newSingleThreadExecutor();
//创建实现了Runnable接口对象，Thread对象当然也实现了Runnable接口
Thread t1 = new MyPoolThread();
Thread t2 = new MyPoolThread2();
Thread t3 = new MyPoolThread();
Thread t4 = new MyPoolThread();
Thread t5 = new MyPoolThread();
//将线程放入池中进行运行
pool.execute(t1);
pool.execute(t2);
pool.execute(t3);
pool.execute(t4);
pool.execute(t5);
//关闭线程池
pool.shutdown();
}
}
class MyPoolThread extends Thread {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "正在运行。。
。");
}
}
class MyPoolThread2 extends Thread {
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "正在运行2。
。。");
}
}
运行结果：
pool-1-thread-1正在运行。。
。
pool-1-thread-1正在运行2。。
。
pool-1-thread-1正在运行。。。
pool-1-thread-1正在运行。
。。
pool-1-thread-1正在运行。。。
以上这样的使用线程池的方式，个人认为存在歧义，尽管处理任务的线程一直为线程一（复用线程）。可是在最初我们就创建了5个线程，这样并不能体现线程池的优势，由于我们并没有做到降低创建和销毁线程的次数
以上是关于JAVA 并发编程-线程池的主要内容，如果未能解决你的问题，请参考以下文章
Java 并发编程线程池机制 ( 线程池示例 | newCachedThreadPool | newFixedThreadPool | newSingleThreadExecutor )