Java四种线程池的使用

FixedThreadPool

由Executors的newFixedThreadPool方法建立。它是一种线程数量固定的线程池,当线程处于空闲状态时,他们并不会被回收,除非线程池被关闭。当全部的线程都处于活动状态时,新的任务都会处于等待状态,直到有线程空闲出来。FixedThreadPool只有核心线程,且该核心线程都不会被回收,这意味着它能够更快地响应外界的请求。
FixedThreadPool没有额外线程,只存在核心线程,并且核心线程没有超时机制,并且任务队列没有长度的限制。ide

public class ThreadPoolExecutorTest {
   public static void main(String[] args) {
    ExecutorService fixedThreadPool =Executors. newFixedThreadPool(3);
     for (int i =1; i<=5;i++){
       final int index=i ;
       fixedThreadPool.execute(new Runnable(){
         @Override
         public void run() {
           try {
            System.out.println("第" +index + "个线程" +Thread.currentThread().getName());
            Thread.sleep(1000);
          } catch(InterruptedException e ) {
             e .printStackTrace();
          }
        }
 
      });
    }
  }
}

CachedThreadPool

由Executors的newCachedThreadPool方法建立,不存在核心线程,只存在数量不定的非核心线程,并且其数量最大值为Integer.MAX_VALUE。当线程池中的线程都处于活动时(全满),线程池会建立新的线程来处理新的任务,不然就会利用新的线程来处理新的任务,线程池中的空闲线程都有超时机制,默认超时时长为60s,超过60s的空闲线程就会被回收。和FixedThreadPool不一样的是,CachedThreadPool的任务队列其实至关于一个空的集合,这将致使任何任务都会被执行,由于在这种场景下SynchronousQueue是不能插入任务的,SynchronousQueue是一个特殊的队列,在不少状况下能够理解为一个没法储存元素的队列。从CachedThreadPool的特性看,这类线程比较适合执行大量耗时较小的任务。当整个线程池都处于闲置状态时,线程池中的线程都会由于超时而被中止回收,几乎是不占任何系统资源。线程

ScheduledThreadPool

经过Executors的newScheduledThreadPool方式建立,核心线程数量是固定的,而非核心线程是没有限制的,而且当非核心线程闲置时它会被当即回收,ScheduledThreadPool这类线程池主要用于执行定时任务和具备固定时期的重复任务。
延迟:code

public class ThreadPoolExecutorTest {  
  public static void main(String[] args) {
    ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);   
    scheduledThreadPool.schedule(newRunnable(){     
      @Override
      public void run() {
       System.out.println("延迟三秒");
       }
   }, 3, TimeUnit.SECONDS);
  }
}

定时:队列

public class ThreadPoolExecutorTest {  
  public static void main(String[] args) {
 
    ScheduledExecutorService scheduledThreadPool= Executors.newScheduledThreadPool(3);    
  scheduledThreadPool.scheduleAtFixedRate(newRunnable(){    
    @Override      
    public void run() {
       System.out.println("延迟1秒后每三秒执行一次");
     }
   },1,3,TimeUnit.SECONDS);
 }
 
}

SingleThreadExecutor

经过Executors的newSingleThreadExecutor方法来建立。这类线程池内部只有一个核心线程,它确保全部的任务都在同一个线程中按顺序执行。SingleThreadExecutor的意义在于统一全部外界任务一个线程中,这使得这些任务之间不须要处理线程同步的问题资源

相关文章
相关标签/搜索