java线程池
Posted 只为成功找方法，不为失败找借口
tags:
篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了java线程池相关的知识，希望对你有一定的参考价值。
线程池的作用：
提供系统效率；如果每个请求到达就创建一个线程，开销是相当大的，服务器创建和销毁线程花费的时间和系统资源都相当大；如果线程数量太多，线程之间的切换也会消耗大量时间和资源。通过对多个任务重复使用线程，那么线程创建和销毁的开销就分摊到了多个任务上，平均每个任务所花费的时间和资源就少了很多。
1、 newCachedThreadPool
创建可缓存线程池，如果线程池的大小超过处理需要的大小，可灵活回收空闲线程，如果不能回收，就创建线程，回收的线程可以用作执行新的任务
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class CachedThreadPool {
@Override
public void run() {
ExecutorService cachedThreadPool = Executors.newCachedThreadPool();
for(int i = 0; i < 10; i++) {
final int index = i;
try {
Thread.sleep(index * 1000);
} catch (InterruptedException e) {
e.printStackTrace();
}
cachedThreadPool.execute(new Runnable() {
@Override
public void run() {
System.out.println(index);
}
});
}
}
}
2、 newFixedThreadPool
创建定长线程，可控制线程的最大并发数，超出的线程需在队列中等待
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class FixedThreadPool {
@Override
public void run() {
ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);
for (int i = 0; i < 10; i++) {
final int index = i;
fixedThreadPool.execute(new Runnable() {
@Override
public void run() {
try {
System.out.println(index);
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}
}
3、 newScheduledThreadPool
创建定长线程，支持按照设定的时间延迟执行或者周期性执行
import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
public class ScheduledThreadPool {
@Override
public void run() {
ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);
scheduledThreadPool.scheduleAtFixedRate(new Runnable() {
@Override
public void run() {
System.out.println("3 seconds delay");
}
}, 1, 3, TimeUnit.SECONDS);
}
}
4、 newSingleThreadPool
单线程化的线程池，所有的任务的执行顺序按照指定的顺序执行（FIFO、LIFO、优先级等）
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class SingleThreadPool {
@Override
public void run() {
ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();
for (int i = 0 ; i < 10; i++) {
final int index = i;
singleThreadPool.execute(new Runnable() {
@Override
public void run() {
try {
System.out.println(index);
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
});
}
}
}
以上是关于java线程池的主要内容，如果未能解决你的问题，请参考以下文章