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

Java线程池需要我们不断的学习，其实我们在使用的时候还是有不少问题需要我们解决。我们实现了一个简单的Java线程池。现在我们就可以使用它了，下面的代码做了一个简单的示例：

创新互联公司成立与2013年，是专业互联网技术服务公司，拥有项目成都网站制作、成都做网站网站策划，项目实施与项目整合能力。我们以让每一个梦想脱颖而出为使命，1280元商城做网站,已为上家服务,为商城各地企业和个人服务,联系电话:13518219792

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 = 0; i < 10; i++) {  
  
  
  service.runTask(new SimpleTaskTest());  
  
  
  }  
  
  
  // 睡眠1秒钟，等待所有任务执行完毕  
  
  
  Thread.sleep(1000);  
  
  
  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 = 0; i < 10; i++) { 
  
  
  service.runTask(new SimpleTaskTest()); 
  
  
  } 
  
  
  // 睡眠1秒钟，等待所有任务执行完毕 
  
  
  Thread.sleep(1000); 
  
  
  service.stop(); 
  
  
  } 
  
  
  }

当然，我们实现的是最简单的，这里只是为了演示Java线程池的实现原理。在实际应用中，根据情况的不同，可以做很多优化。比如：

调整任务队列的规则，给任务设置优先级，级别高的任务优先执行。
动态维护Java线程池，当待执行任务数量较多时，增加线程的数量，加快任务的执行速度；当任务较少时，回收一部分长期闲置的Java线程池，减少对系统资源的消耗。

事实上Java5.0及以上版本已经为我们提供了线程池功能，无需再重新实现。这些类位于java.util.concurrent包中。

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()方法则只在线程池中创建一个线程，来执行所有的任务。

文章标题：Java线程池在使用中的问题解疑
网址分享：http://www.shufengxianlan.com/qtweb/news20/130620.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源：创新互联

猜你还喜欢下面的内容