第七色在线视频,2021少妇久久久久久久久久,亚洲欧洲精品成人久久av18,亚洲国产精品特色大片观看完整版,孙宇晨将参加特朗普的晚宴

為了賬號(hào)安全,請(qǐng)及時(shí)綁定郵箱和手機(jī)立即綁定

線程池的創(chuàng)建以及隊(duì)列選擇

標(biāo)簽:
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();
}


點(diǎn)擊查看更多內(nèi)容
TA 點(diǎn)贊

若覺得本文不錯(cuò),就分享一下吧!

評(píng)論

作者其他優(yōu)質(zhì)文章

正在加載中
  • 推薦
  • 評(píng)論
  • 收藏
  • 共同學(xué)習(xí),寫下你的評(píng)論
感謝您的支持,我會(huì)繼續(xù)努力的~
掃碼打賞,你說多少就多少
贊賞金額會(huì)直接到老師賬戶
支付方式
打開微信掃一掃,即可進(jìn)行掃碼打賞哦
今天注冊(cè)有機(jī)會(huì)得

100積分直接送

付費(fèi)專欄免費(fèi)學(xué)

大額優(yōu)惠券免費(fèi)領(lǐng)

立即參與 放棄機(jī)會(huì)
微信客服

購課補(bǔ)貼
聯(lián)系客服咨詢優(yōu)惠詳情

幫助反饋 APP下載

慕課網(wǎng)APP
您的移動(dòng)學(xué)習(xí)伙伴

公眾號(hào)

掃描二維碼
關(guān)注慕課網(wǎng)微信公眾號(hào)

舉報(bào)

0/150
提交
取消