线程池满了 Java线程池在使用中的问题解疑

Java线程池在使用中的问题解疑  

　　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();

　　 service start();

　　 // 执行十次任务

　　 for (int i = ; i < ; i++) {

　　 service runTask(new SimpleTaskTest());

　　 }

　　 // 睡眠 秒钟 等待所有任务执行完毕

　　 Thread sleep( );

　　 service stop();

　　 }

　　 }

　　 public class SimpleTaskTest extends Task {

　　 @Override

　　 public void deal() {

　　 // do something

　　 }

　　 public static void main(String[] args) throws InterruptedException {

　　 ThreadPoolService service = new ThreadPoolService();

　　 service start();

　　 // 执行十次任务

　　 for (int i = ; i < ; i++) {

　　 service runTask(new SimpleTaskTest());

　　 }

　　 // 睡眠 秒钟 等待所有任务执行完毕

　　 Thread sleep( );

　　 service stop();

　　 }

　　 }

　　当然 我们实现的是最简单的 这里只是为了演示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

　　 }