阿裡推薦的線程使用方法 ThreadPoolExecutor

来源:https://www.cnblogs.com/jianpanwuzhe/archive/2018/03/03/8496918.html
-Advertisement-
Play Games

阿裡推薦原因:使用線程池可以減少創建和銷毀線程上所花的時間以及系統資源的開銷,然後之所以不用Executors自定義線程池,用ThreadPoolExecutor是為了規範線程池的使用,還有讓其他人更好懂線程池的運行規則。先說一下關於線程的概念任務:線程需要執行的代碼,也就是Runnable任務隊列 ...


阿裡推薦原因:使用線程池可以減少創建和銷毀線程上所花的時間以及系統資源的開銷,然後之所以不用Executors自定義線程池,用ThreadPoolExecutor是為了規範線程池的使用,還有讓其他人更好懂線程池的運行規則。

先說一下關於線程的概念

任務:線程需要執行的代碼,也就是Runnable
任務隊列:線程滿了,就任務就放入任務隊列里等待,等其他任務線上程里執行完,這個線程就空出來了,任務隊列就將最早來的未執行的任務放入線程執行。
核心線程:線程池一直存在的線程
最大線程數量:指的是線程池所容納的最多的線程數量

 

ThreadPoolExecutor(int corePoolSize,
                        int maximumPoolSize,
                        long keepAliveTime,
                        TimeUnit unit,
                        BlockingQueue<Runnable> workQueue) 

第一個是核心線程數量,第二個是最大線程數量,第三個是非核心線程的閑置超時時間,超過這個時間就會被回收,第四個是線程池中的任務隊列模式。

我們主要講這個任務隊列模式

 

1.LinkedBlockingDeque

 

我先上一個例子代碼,再來嘮嗑

public class MainActivity extends AppCompatActivity {

    Button button;
    ThreadPoolExecutor executor;
    Runnable myRunnable = new Runnable() {
        @Override
        public void run() {
            try {
                Thread.sleep(2000);
                System.out.println(Thread.currentThread().getName() + " run");
            } catch (InterruptedException e) {
                e.printStackTrace();
            }

        }
    };
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_main);

        button = (Button) findViewById(R.id.btn_record_video);

        button.setOnClickListener(new View.OnClickListener() {
            @Override
            public void onClick(View v) {

                executor.execute(myRunnable);
                executor.execute(myRunnable);
                executor.execute(myRunnable);
            }
        });


        executor = new ThreadPoolExecutor(3, 6, 3, TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>());


    }
}

 

當我們點擊一次按鈕

03-03 15:00:43.503 5292-5333/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:00:43.505 5292-5335/com.example.zth.seven I/System.out: pool-1-thread-3 run
03-03 15:00:43.505 5292-5334/com.example.zth.seven I/System.out: pool-1-thread-2 run

連續點擊兩次

03-03 15:10:47.941 7114-7259/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:10:47.941 7114-7260/com.example.zth.seven I/System.out: pool-1-thread-2 run
03-03 15:10:47.942 7114-7261/com.example.zth.seven I/System.out: pool-1-thread-3 run
03-03 15:10:49.942 7114-7260/com.example.zth.seven I/System.out: pool-1-thread-2 run
03-03 15:10:49.942 7114-7259/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:10:49.942 7114-7261/com.example.zth.seven I/System.out: pool-1-thread-3 run

這個時候就可以看出雖然說是最大線程數量是6,但是只用核心線程,不創建新線程,如果核心線程用完了就在隊列里等待,隊列的大小沒有限制(你可隨便點,他反正後來都會執行)

但是還沒完這個LinkedBlockingDeque還可以設置隊列數量,如果我把隊列設置為2

        executor = new ThreadPoolExecutor(3, 6, 3,
                TimeUnit.SECONDS, new LinkedBlockingDeque<Runnable>(2));

 

然後連續點擊2兩次

03-03 15:19:39.851 8971-9013/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:19:39.851 8971-9014/com.example.zth.seven I/System.out: pool-1-thread-2 run
03-03 15:19:39.851 8971-9015/com.example.zth.seven I/System.out: pool-1-thread-3 run
03-03 15:19:40.045 8971-9016/com.example.zth.seven I/System.out: pool-1-thread-4 run
03-03 15:19:41.851 8971-9013/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:19:41.851 8971-9015/com.example.zth.seven I/System.out: pool-1-thread-3 run

他這個時候能夠創建四個線程了,為何,首先第一次點擊占了三個核心線程,然後第二次點擊將前兩次任務放入隊列里,然後隊列滿了就創建一個新線程用來執行最後一個任務

如果我們連續點擊三次,程式在我們點擊第三次就崩潰了,因為線程數量超出最大線程數量了

總結:LinkedBlockingDeque就首先使用核心線程,核心線程用完了就把任務放入隊列里等待,如果隊列滿了就創建新線程,註意不設置隊列數量,他就預設無限大。


2.SynchronousQueue


我們還是和以前一樣換掉一行代碼

        executor = new ThreadPoolExecutor(3, 6, 3,
                TimeUnit.SECONDS, new SynchronousQueue<Runnable>());

 

點擊一次

03-03 15:39:31.915 12403-12446/com.example.zth.seven I/System.out: pool-1-thread-2 run
03-03 15:39:31.915 12403-12447/com.example.zth.seven I/System.out: pool-1-thread-3 run
03-03 15:39:31.915 12403-12445/com.example.zth.seven I/System.out: pool-1-thread-1 run

連續點擊兩次

03-03 15:39:53.204 12403-12446/com.example.zth.seven I/System.out: pool-1-thread-2 run
03-03 15:39:53.204 12403-12445/com.example.zth.seven I/System.out: pool-1-thread-1 run
03-03 15:39:53.204 12403-12447/com.example.zth.seven I/System.out: pool-1-thread-3 run
03-03 15:39:53.371 12403-12501/com.example.zth.seven I/System.out: pool-1-thread-5 run
03-03 15:39:53.371 12403-12502/com.example.zth.seven I/System.out: pool-1-thread-6 run
03-03 15:39:53.371 12403-12500/com.example.zth.seven I/System.out: pool-1-thread-4 run

可以看出來當核心線程占滿時他沒有將任務放入隊列里去等待,而是直接創建新線程取執行任務

連續點擊三次

程式崩潰,因為他創建的線程超過了最大線程數量,

總結:SynchronousQueue很單純,不使用隊列,核心線程用完了就創建新線程,

 

參考文章:

http://blog.csdn.net/qq_25806863/article/details/71126867

 


您的分享是我們最大的動力!

-Advertisement-
Play Games
更多相關文章
  • 負載均衡LVS(Linux Virtual Server) 目錄 第1章 LVS負載均衡集群簡介 1.1 為什麼要學LVS 1.2 LVS網站資料: 1.3 LVS內核模塊ip_vs介紹 從2.4.24以後IPVS已經成為Linux官方標準內核的一部分。  LVS無需安裝  安裝的是管理工具,第 ...
  • 保持apache、mysql正在運行 依賴的庫 安裝libiconv庫 安裝php [root@cairui php-7.2.3]# ./configure --prefix=/opt/php7.2.3 --with-apxs2=/opt/apache/bin/apxs --with-openssl ...
  • pkill -kill -t 用戶的TTY pkill -9 用戶的TTY ...
  • 前言 前幾天剛學了Hadoop的安裝,幾乎把Hadoop的雷都踩了一個遍,雖然Hadoop的相關的配置文件以及原理還沒有完全完成,但是現在先總結分享一下筆者因為需要所整理的一些關於Hbase的東西。 一、Hbase概述 1.1什麼是Hbase? 首先我們還是來看看Hbase在百度上面是怎麼解釋的: ...
  • ##用例1:查詢數據 #01.查詢QQ號碼為54789625的所有好友信息,包括QQ號碼,昵稱,年齡 #02.查詢當前線上用戶的信息 #03.查詢北京的、年齡在18至45歲之間的線上用戶的信息 #04.查詢昵稱為青青草的用戶信息 #05.查詢QQ號碼為54789625的用戶的好友中每個省份的總人數, ...
  • 之前看源碼都是在Windows下用SourceInsight看,雖然達到了研究源碼的效果,但終究還是有遺憾。。。趁著周末,準備在Ubuntu虛擬機上下載編譯源碼。 之前下源碼時,有瞭解一些Android源碼的情況。網上的教程很多也是從谷歌官網下源碼,但是最近藍燈不好用,翻牆效率有點低,而且翻牆的網速 ...
  • 接上篇《Android進階之光》--Android新特性 No1: 組件: 1)底部工作條-Bottom Sheets 2)卡片-Cards 3)提示框-Dialogs 4)菜單-Menus 5)選擇器 6)滑塊控制項-Sliders 7)進度和動態 8)Snackbar(底部可操作彈出框)與Toas ...
  • Android 5.0新特性 1)全新的Material Design設計風格 2)支持多種設備 3)全新的通知中心設計--按照優先順序顯示 4)支持64位ART虛擬機 5)多任務視窗Overview 6)設備識別解鎖--比如附近信任設備 7)Ok Google語音指令 8)Face unlock面部 ...
一周排行
    -Advertisement-
    Play Games
  • 移動開發(一):使用.NET MAUI開發第一個安卓APP 對於工作多年的C#程式員來說,近來想嘗試開發一款安卓APP,考慮了很久最終選擇使用.NET MAUI這個微軟官方的框架來嘗試體驗開發安卓APP,畢竟是使用Visual Studio開發工具,使用起來也比較的順手,結合微軟官方的教程進行了安卓 ...
  • 前言 QuestPDF 是一個開源 .NET 庫,用於生成 PDF 文檔。使用了C# Fluent API方式可簡化開發、減少錯誤並提高工作效率。利用它可以輕鬆生成 PDF 報告、發票、導出文件等。 項目介紹 QuestPDF 是一個革命性的開源 .NET 庫,它徹底改變了我們生成 PDF 文檔的方 ...
  • 項目地址 項目後端地址: https://github.com/ZyPLJ/ZYTteeHole 項目前端頁面地址: ZyPLJ/TreeHoleVue (github.com) https://github.com/ZyPLJ/TreeHoleVue 目前項目測試訪問地址: http://tree ...
  • 話不多說,直接開乾 一.下載 1.官方鏈接下載: https://www.microsoft.com/zh-cn/sql-server/sql-server-downloads 2.在下載目錄中找到下麵這個小的安裝包 SQL2022-SSEI-Dev.exe,運行開始下載SQL server; 二. ...
  • 前言 隨著物聯網(IoT)技術的迅猛發展,MQTT(消息隊列遙測傳輸)協議憑藉其輕量級和高效性,已成為眾多物聯網應用的首選通信標準。 MQTTnet 作為一個高性能的 .NET 開源庫,為 .NET 平臺上的 MQTT 客戶端與伺服器開發提供了強大的支持。 本文將全面介紹 MQTTnet 的核心功能 ...
  • Serilog支持多種接收器用於日誌存儲,增強器用於添加屬性,LogContext管理動態屬性,支持多種輸出格式包括純文本、JSON及ExpressionTemplate。還提供了自定義格式化選項,適用於不同需求。 ...
  • 目錄簡介獲取 HTML 文檔解析 HTML 文檔測試參考文章 簡介 動態內容網站使用 JavaScript 腳本動態檢索和渲染數據,爬取信息時需要模擬瀏覽器行為,否則獲取到的源碼基本是空的。 本文使用的爬取步驟如下: 使用 Selenium 獲取渲染後的 HTML 文檔 使用 HtmlAgility ...
  • 1.前言 什麼是熱更新 游戲或者軟體更新時,無需重新下載客戶端進行安裝,而是在應用程式啟動的情況下,在內部進行資源或者代碼更新 Unity目前常用熱更新解決方案 HybridCLR,Xlua,ILRuntime等 Unity目前常用資源管理解決方案 AssetBundles,Addressable, ...
  • 本文章主要是在C# ASP.NET Core Web API框架實現向手機發送驗證碼簡訊功能。這裡我選擇是一個互億無線簡訊驗證碼平臺,其實像阿裡雲,騰訊雲上面也可以。 首先我們先去 互億無線 https://www.ihuyi.com/api/sms.html 去註冊一個賬號 註冊完成賬號後,它會送 ...
  • 通過以下方式可以高效,並保證數據同步的可靠性 1.API設計 使用RESTful設計,確保API端點明確,並使用適當的HTTP方法(如POST用於創建,PUT用於更新)。 設計清晰的請求和響應模型,以確保客戶端能夠理解預期格式。 2.數據驗證 在伺服器端進行嚴格的數據驗證,確保接收到的數據符合預期格 ...