亚洲在线久爱草,狠狠天天香蕉网,天天搞日日干久草,伊人亚洲日本欧美

為了賬號安全,請及時綁定郵箱和手機立即綁定

線程池的創建以及隊列選擇

標簽:
Java
一、队列选择
SynchronousQueue:队列中仅容纳一个元素,对其操作必须是放和取交替进行;
ArrayBlockingQueue:有界队列,初始化时必须指定容量大小,并且无法修改,先入先出原则。
LinkedBlockingQueue:无界队列,初始化时指定容量就是有界队列,未指定容量就是无边界的,其实是Integer.MAX_VALUE的容量,内部实现是链表,先入先出。

二、创建线程池的几种方式
1、创建一个可重用固定个数的线程池,以共享的无界队列方式(LinkedBlockingQueue)来运行这些线程。
public static void newFixedThreadPool(){
    ExecutorService executorService = Executors.newFixedThreadPool(Runtime.getRuntime().availableProcessors());
    for (int i = 0; i < 10; i++) {
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("固长的线程池-" + Thread.currentThread().getName());
                try {
                    Thread.sleep(2000L);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
        });
    }
}
2、创建一个单线程化的线程池,它只会用唯一的工作线程来执行任务,保证所有任务按照指定顺序(FIFO, LIFO, 优先级)执行,默认LinkedBlockingQueue。
public static void newSingleThreadExecutor(){
   ExecutorService executorService = Executors.newSingleThreadExecutor();

   for (int i = 0; i < 10; i++) {
       final int idx = i;
       executorService.execute(new Runnable() {
           @Override
           public void run() {
               System.out.println("单线程线程池-"+Thread.currentThread().getName() + "-" + idx);
           }
       });
   }
}
3、创建一个可缓存的线程池,先看看池中有没有以前建立的线程,有的话,就直接使用,没有,就新创建一个线程执行,默认SynchronousQueue。
public static void newCacheThreadPool(){
    ExecutorService executorService = Executors.newCachedThreadPool();
    for (int i = 0; i < 10; i++) {
        try {//验证线程被复用
            Thread.sleep(1000L);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        executorService.execute(new Runnable() {
            @Override
            public void run() {
                System.out.println("可缓存的线程池-" + Thread.currentThread().getName());
            }
        });
    }
}
4、可定时调度的线程池,默认DelayedWorkQueue。
public static void newScheduledThreadPool(){
    ScheduledExecutorService scheduledExecutorService = Executors.newScheduledThreadPool(3);
    scheduledExecutorService.scheduleAtFixedRate(new Runnable() {
        @Override
        public void run() {
            System.out.println("定长周期调度线程-" + Thread.currentThread().getName());
        }
    }, 1, 3, TimeUnit.SECONDS);
}
5、自定义线程池:corePoolSize  maximumPoolSize  keepAliveTime  blockingQueue
public static void newThreadPoolExecutor(){
    ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(3, 3,
            1, TimeUnit.SECONDS, new ArrayBlockingQueue<Runnable>(10));
    Runnable runnable = new Runnable() {
        @Override
        public void run() {
            System.out.println("线程-" + Thread.currentThread().getName());
        }
    };
    for (int i = 0; i < 10; i++) {
        threadPoolExecutor.execute(runnable);
    }
    threadPoolExecutor.shutdown();
}


點擊查看更多內容
TA 點贊

若覺得本文不錯,就分享一下吧!

評論

作者其他優質文章

正在加載中
JAVA開發工程師
手記
粉絲
0
獲贊與收藏
1

關注作者,訂閱最新文章

閱讀免費教程

  • 推薦
  • 評論
  • 收藏
  • 共同學習,寫下你的評論
感謝您的支持,我會繼續努力的~
掃碼打賞,你說多少就多少
贊賞金額會直接到老師賬戶
支付方式
打開微信掃一掃,即可進行掃碼打賞哦
今天注冊有機會得

100積分直接送

付費專欄免費學

大額優惠券免費領

立即參與 放棄機會
微信客服

購課補貼
聯系客服咨詢優惠詳情

幫助反饋 APP下載

慕課網APP
您的移動學習伙伴

公眾號

掃描二維碼
關注慕課網微信公眾號

舉報

0/150
提交
取消