Java线程池需要我们不断的学习其实我们在使用的时候还是有不少问题需要我们解决我们实现了一个简单的Java线程池现在我们就可以使用它了下面的代码做了一个简单的示例
Java代码
public class SimpleTaskTest extends Task {
@Override
public void deal() {
// do something
}
public static void main(String[] args) throws InterruptedException {
ThreadPoolService service = new ThreadPoolService();
servicestart();
// 执行十次任务
for (int i = ; i < ; i++) {
servicerunTask(new SimpleTaskTest());
}
// 睡眠秒钟等待所有任务执行完毕
Threadsleep();
servicestop();
}
}
public class SimpleTaskTest extends Task {
@Override
public void deal() {
// do something
}
public static void main(String[] args) throws InterruptedException {
ThreadPoolService service = new ThreadPoolService();
servicestart();
// 执行十次任务
for (int i = ; i < ; i++) {
servicerunTask(new SimpleTaskTest());
}
// 睡眠秒钟等待所有任务执行完毕
Threadsleep();
servicestop();
}
}
当然我们实现的是最简单的这里只是为了演示Java线程池的实现原理在实际应用中根据情况的不同可以做很多优化比如
调整任务队列的规则给任务设置优先级级别高的任务优先执行
动态维护Java线程池当待执行任务数量较多时增加线程的数量加快任务的执行速度当任务较少时回收一部分长期闲置的Java线程池减少对系统资源的消耗
事实上Java及以上版本已经为我们提供了线程池功能无需再重新实现这些类位于ncurrent包中
Executors类提供了一组创建Java线程池对象的方法常用的有一下几个
Java代码
public static ExecutorService newCachedThreadPool() {
// other code
}
public static ExecutorService newFixedThreadPool(int nThreads) {
// other code
}
public static ExecutorService newSingleThreadExecutor() {
// other code
}
public static ExecutorService newCachedThreadPool() {
// other code
}
public static ExecutorService newFixedThreadPool(int nThreads) {
// other code
}
public static ExecutorService newSingleThreadExecutor() {
// other code
}
newCachedThreadPool()方法创建一个动态的线程池其中线程的数量会根据实际需要来创建和回收适合于执行大量短期任务的情况newFixedThreadPool(int nThreads)方法创建一个包含固定数量线程对象的Java线程池nThreads代表要创建的线程数如果某个线程在运行的过程中因为异常而终止了那么一个新的线程会被创建和启动来代替它而newSingleThreadExecutor()方法则只在线程池中创建一个线程来执行所有的任务
