Java

您所在的位置:网站首页 常用的几种线程池 Java

Java

2024-05-29 13:45| 来源: 网络整理| 查看: 265

Java-五种线程池,四种拒绝策略,三类阻塞队列(常用)

三类阻塞队列:     //1 有界队列     workQueue = new ArrayBlockingQueue(5);//基于数组的先进先出(FIFO)队列,支持公平锁和非公平锁,有界     workQueue = new LinkedBlockingQueue();//基于链表的先进先出(FIFO)队列,默认长度为 Integer.MaxValue 有OOM危险,有界     workQueue = new LinkedBlockingDeque(); //一个由链表结构组成的,双向阻塞队列,有界     //2 无界队列     workQueue = new PriorityBlockingQueue(); //支持优先级排序的无限队列,默认自然排序,可以实现 compareTo()方法指定排序规则,不能保证同优先级元素的顺序,无界。     workQueue = new DelayQueue(); //一个使用优先级队列(PriorityQueue)实现的无界延时队列,在创建时可以指定多久才能从队列中获取当前元素。只有延时期满后才能从队列中获取元素。     workQueue = new LinkedTransferQueue(); //一个由链表结构组成的,无界阻塞队列     //3 同步移交队列     workQueue = new SynchronousQueue();//无缓冲的等待队列,队列不存元素,每个put操作必须等待take操作,否则无法添加元素,支持公平非公平锁,无界

java.util.concurrent 包下的阻塞队列及其依赖关系

 

四种拒绝策略:     RejectedExecutionHandler rejected = null;     rejected = new ThreadPoolExecutor.AbortPolicy();//默认,队列满了丢任务抛出异常     rejected = new ThreadPoolExecutor.DiscardPolicy();//队列满了丢任务不异常     rejected = new ThreadPoolExecutor.DiscardOldestPolicy();//将最早进入队列的任务删,之后再尝试加入队列     rejected = new ThreadPoolExecutor.CallerRunsPolicy();//如果添加到线程池失败,那么主线程会自己去执行该任务

五种线程池:     ExecutorService threadPool = null;     threadPool = Executors.newCachedThreadPool();//有缓冲的线程池,线程数 JVM 控制     threadPool = Executors.newFixedThreadPool(3);//固定大小的线程池     threadPool = Executors.newScheduledThreadPool(2);     threadPool = Executors.newSingleThreadExecutor();//单线程的线程池,只有一个线程在工作     threadPool = new ThreadPoolExecutor();//默认线程池,可控制参数比较多   

public static void main (String[] args) throws Exception { testThreadPoolExecutor(); } public static void testThreadPoolExecutor() throws Exception { //基础参数 int corePoolSize=2;//最小活跃线程数 int maximumPoolSize=5;//最大活跃线程数 int keepAliveTime=5;//指定线程池中线程空闲超过 5s 后将被回收 TimeUnit unit = TimeUnit.SECONDS;//keepAliveTime 单位 //阻塞队列 BlockingQueue workQueue = null; //1 有界队列 workQueue = new ArrayBlockingQueue(5);//基于数组的先进先出(FIFO)队列,支持公平锁和非公平锁,有界 workQueue = new LinkedBlockingQueue();//基于链表的先进先出(FIFO)队列,默认长度为 Integer.MaxValue 有OOM危险,有界 workQueue = new LinkedBlockingDeque(); //一个由链表结构组成的,双向阻塞队列,有界 //2 无界队列 workQueue = new PriorityBlockingQueue(); //支持优先级排序的无限队列,默认自然排序,可以实现 compareTo()方法指定排序规则,不能保证同优先级元素的顺序,无界。 workQueue = new DelayQueue(); //一个使用优先级队列(PriorityQueue)实现的无界延时队列,在创建时可以指定多久才能从队列中获取当前元素。只有延时期满后才能从队列中获取元素。 workQueue = new LinkedTransferQueue(); //一个由链表结构组成的,无界阻塞队列 //3 同步移交队列 workQueue = new SynchronousQueue();//无缓冲的等待队列,队列不存元素,每个put操作必须等待take操作,否则无法添加元素,支持公平非公平锁,无界 //拒绝策略 RejectedExecutionHandler rejected = null; rejected = new ThreadPoolExecutor.AbortPolicy();//默认,队列满了丢任务抛出异常 rejected = new ThreadPoolExecutor.DiscardPolicy();//队列满了丢任务不异常 rejected = new ThreadPoolExecutor.DiscardOldestPolicy();//将最早进入队列的任务删,之后再尝试加入队列 rejected = new ThreadPoolExecutor.CallerRunsPolicy();//如果添加到线程池失败,那么主线程会自己去执行该任务 //使用的线程池 ExecutorService threadPool = null; threadPool = Executors.newCachedThreadPool();//有缓冲的线程池,线程数 JVM 控制 threadPool = Executors.newFixedThreadPool(3);//固定大小的线程池 threadPool = Executors.newScheduledThreadPool(2); threadPool = Executors.newSingleThreadExecutor();//单线程的线程池,只有一个线程在工作 threadPool = new ThreadPoolExecutor( corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue, rejected);//默认线程池,可控制参数比较多 //执行无返回值线程 TaskRunnable taskRunnable = new TaskRunnable(); threadPool.execute(taskRunnable); List futres = new ArrayList(); for(int i=0;i


【本文地址】


今日新闻


推荐新闻


CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3