Android concurrent(一)—— Executor接口

設(shè)計(jì)理念——為何而存在

先來一發(fā)源碼棠枉。

public interface Executor {
    void execute(Runnable command);
}

就是這么短。那么這么短的一個(gè)接口存在的意義是什么呢泡挺?
下面就來分析一下辈讶。
當(dāng)我們想創(chuàng)建并執(zhí)行一個(gè)線程的時(shí)候,通常是這樣的娄猫。

new Thread(new(RunnableTask())).start()

是不是短贱除!平!快媳溺!月幌。這樣不是很好嗎?但是使用這種方式悬蔽,我們無法控制程序中線程的數(shù)量扯躺,創(chuàng)建過多的線程會(huì)帶來性能問題。我們需要一種方式控制線程的數(shù)量,有時(shí)我們還希望控制各個(gè)任務(wù)之間調(diào)度關(guān)系录语。Executor接口正式為解決這個(gè)問題而來倍啥。

Executor接口官方介紹:An object that executes submitted Runnable tasks. This interface provides a way of decoupling task submission from the mechanics of how each task will be run, including details of thread use, scheduling, etc. An Executor is normally used instead of explicitly creating threads.

意思:Executor是用來提交Runnable的。它可以將Runnable的遞交澎埠、使用的細(xì)節(jié)虽缕、調(diào)度與執(zhí)行解耦。用來代替直接創(chuàng)建Thread的方式蒲稳。

不容易理解氮趋?莫關(guān)系!下面通過一個(gè)實(shí)際應(yīng)用來解釋這段話江耀。

比如剩胁,你想保證任務(wù)的順序執(zhí)行(每個(gè)時(shí)刻只有一個(gè)Runnable在執(zhí)行,只有上一個(gè)Runnable執(zhí)行完畢之后才會(huì)執(zhí)行下一個(gè)Runnable)并且為每一個(gè)Runnable創(chuàng)建一個(gè)新的Thread决记。我們可以這樣做:

  //SerialExecutor提供調(diào)度功能,將用戶提交的Runnable保存到一個(gè)隊(duì)列里面倍踪,然后順序執(zhí)行
  class SerialExecutor implements Executor {
    //隊(duì)列系宫,用來存放提交進(jìn)來的Runnable
    final Queue<Runnable> tasks = new ArrayDeque<Runnable>();
    //提交進(jìn)來的Runnable實(shí)際執(zhí)行的位置。
    final Executor executor;
    //當(dāng)前正在執(zhí)行的Runnable
    Runnable active;
    SerialExecutor(Executor executor) {
      this.executor = executor;
    }
    public synchronized void execute(final Runnable r) {
      //將Runnable包裝建车,并添加到隊(duì)里中扩借。
      tasks.offer(new Runnable() {
        public void run() {
          try {
            r.run();
          } finally {
            //執(zhí)行完畢后,會(huì)自動(dòng)調(diào)用隊(duì)里中的下一個(gè)Runnable
            scheduleNext();
          }
        }
      });
      if (active == null) {
        //首次調(diào)度
        scheduleNext();
      }
    }
    protected synchronized void scheduleNext() {
      if ((active = tasks.poll()) != null) {
        executor.execute(active);
      }
    }
  }}
  
//ThreadPerTaskExecutor是Runnable的實(shí)際執(zhí)行的地方缤至。為每一個(gè)Runnable創(chuàng)建一個(gè)Thread潮罪。
class ThreadPerTaskExecutor implements Executor {
 public void execute(Runnable r) {
     new Thread(r).start();
 }
}}

//執(zhí)行:只有任務(wù)1執(zhí)行完畢后才會(huì)執(zhí)行任務(wù)2
Executor executor = new SerialExecutor(new ThreadPerTaskExecutor());
executor.execute(new Runnable(){
    public void run() {
        //任務(wù)1...     
    }
});
executor.execute(new Runnable(){
    public void run() {
        //任務(wù)2...     
    }
});

在這個(gè)例子中,SerialExecutor用于Runnable的調(diào)度领斥,它將Runnable進(jìn)行簡(jiǎn)單的包裝嫉到,并保存到隊(duì)里中。經(jīng)過包裝后月洛,不僅會(huì)執(zhí)行原始提交Runnable的代碼何恶,并且會(huì)執(zhí)行結(jié)束后調(diào)用隊(duì)列中的下一個(gè)Runnable。就這樣,SerialExecutor實(shí)現(xiàn)了Runnable的順序執(zhí)行嚼黔。而ThreadPerTaskExecutor類則是用來控制Runnable執(zhí)行細(xì)節(jié)的地方细层,在這里,我們簡(jiǎn)單的為每個(gè)Runnable創(chuàng)建了新的Thread唬涧,在實(shí)際應(yīng)用中疫赎,你可以使用線程池來復(fù)用Thread。

總結(jié)

Executor被創(chuàng)造的原因:將任務(wù)的執(zhí)行碎节、任務(wù)的調(diào)度捧搞、任務(wù)的執(zhí)行細(xì)節(jié)進(jìn)行解耦。

  1. 任務(wù)是如何調(diào)度的,你是想一個(gè)個(gè)的順序執(zhí)行实牡,還是想多個(gè)任務(wù)一起并發(fā)并能自由的控制并發(fā)數(shù)量上線陌僵,都可以通過自己實(shí)現(xiàn)Executor接口進(jìn)行定制。你只需要將任務(wù)通過Executor#execute(Runnable)方法提交進(jìn)來就可以了创坞,具體的調(diào)度方案碗短,Runnable不需要關(guān)注。這樣就實(shí)現(xiàn)了任務(wù)執(zhí)行和調(diào)度的解耦题涨。
  2. 對(duì)于任務(wù)的執(zhí)行細(xì)節(jié)偎谁,你是想為每個(gè)任務(wù)都創(chuàng)建新的線程,還是想復(fù)用已有的線程纲堵,也可以通過實(shí)現(xiàn)Executor接口進(jìn)行定制巡雨。同樣,你只需要將任務(wù)通過Executor#execute(Runnable)方法提交進(jìn)來就可以了席函,具體的執(zhí)行細(xì)節(jié)铐望,Runnable不需要關(guān)注。這樣就實(shí)現(xiàn)了任務(wù)執(zhí)行和執(zhí)行細(xì)節(jié)的解耦茂附。

設(shè)計(jì)模式的使用:中介者模式

在這里正蛙,使用了設(shè)計(jì)模式中的中介者模式,下面是中介者模式的定義和UML類圖营曼。

中介者模式(Mediator Pattern):定義一個(gè)中介對(duì)象來封裝系列對(duì)象之間的交互乒验。中介者使各個(gè)對(duì)象不需要顯示地相互引用,從而使其耦合性松散蒂阱,而且可以獨(dú)立地改變他們之間的交互锻全。

  1. 抽象中介者(Mediator)角色:抽象中介者角色定義統(tǒng)一的接口用于各同事角色之間的通信。
  2. 具體中介者(Concrete Mediator)角色:具體中介者角色通過協(xié)調(diào)各同事角色實(shí)現(xiàn)協(xié)作行為录煤。為此它要知道并引用各個(gè)同事角色鳄厌。
  3. 同事(Colleague)角色:每一個(gè)同事角色都知道對(duì)應(yīng)的具體中介者角色,而且與其他的同事角色通信的時(shí)候妈踊,一定要通過中介者角色協(xié)作部翘。——《設(shè)計(jì)模式》

UML類圖:

Mediator_Pattern.jpg

其中Executor就是一個(gè)抽象中介者角色响委,Executor的具體實(shí)現(xiàn)就是一個(gè)具體中介者角色新思,每個(gè)Runnable就相當(dāng)于同事角色,Executor的execute(Runnable...)方法即是各個(gè)Runnable之間通信的接口赘风,每個(gè)Runnable都被提交到Executor的具體實(shí)現(xiàn)類中夹囚,由Executor的具體實(shí)現(xiàn)類來協(xié)調(diào)各Runnable之間的實(shí)現(xiàn)協(xié)作行為。

最后編輯于
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請(qǐng)聯(lián)系作者
  • 序言:七十年代末邀窃,一起剝皮案震驚了整個(gè)濱河市荸哟,隨后出現(xiàn)的幾起案子假哎,更是在濱河造成了極大的恐慌,老刑警劉巖鞍历,帶你破解...
    沈念sama閱讀 216,402評(píng)論 6 499
  • 序言:濱河連續(xù)發(fā)生了三起死亡事件舵抹,死亡現(xiàn)場(chǎng)離奇詭異,居然都是意外死亡劣砍,警方通過查閱死者的電腦和手機(jī)惧蛹,發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 92,377評(píng)論 3 392
  • 文/潘曉璐 我一進(jìn)店門,熙熙樓的掌柜王于貴愁眉苦臉地迎上來刑枝,“玉大人香嗓,你說我怎么就攤上這事∽俺” “怎么了靠娱?”我有些...
    開封第一講書人閱讀 162,483評(píng)論 0 353
  • 文/不壞的土叔 我叫張陵,是天一觀的道長(zhǎng)掠兄。 經(jīng)常有香客問我像云,道長(zhǎng),這世上最難降的妖魔是什么蚂夕? 我笑而不...
    開封第一講書人閱讀 58,165評(píng)論 1 292
  • 正文 為了忘掉前任迅诬,我火速辦了婚禮,結(jié)果婚禮上双抽,老公的妹妹穿的比我還像新娘百框。我一直安慰自己闲礼,他們只是感情好牍汹,可當(dāng)我...
    茶點(diǎn)故事閱讀 67,176評(píng)論 6 388
  • 文/花漫 我一把揭開白布。 她就那樣靜靜地躺著柬泽,像睡著了一般慎菲。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上锨并,一...
    開封第一講書人閱讀 51,146評(píng)論 1 297
  • 那天露该,我揣著相機(jī)與錄音,去河邊找鬼第煮。 笑死解幼,一個(gè)胖子當(dāng)著我的面吹牛,可吹牛的內(nèi)容都是我干的包警。 我是一名探鬼主播撵摆,決...
    沈念sama閱讀 40,032評(píng)論 3 417
  • 文/蒼蘭香墨 我猛地睜開眼,長(zhǎng)吁一口氣:“原來是場(chǎng)噩夢(mèng)啊……” “哼害晦!你這毒婦竟也來了特铝?” 一聲冷哼從身側(cè)響起,我...
    開封第一講書人閱讀 38,896評(píng)論 0 274
  • 序言:老撾萬榮一對(duì)情侶失蹤,失蹤者是張志新(化名)和其女友劉穎鲫剿,沒想到半個(gè)月后鳄逾,有當(dāng)?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體,經(jīng)...
    沈念sama閱讀 45,311評(píng)論 1 310
  • 正文 獨(dú)居荒郊野嶺守林人離奇死亡灵莲,尸身上長(zhǎng)有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點(diǎn)故事閱讀 37,536評(píng)論 2 332
  • 正文 我和宋清朗相戀三年雕凹,在試婚紗的時(shí)候發(fā)現(xiàn)自己被綠了。 大學(xué)時(shí)的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片笆呆。...
    茶點(diǎn)故事閱讀 39,696評(píng)論 1 348
  • 序言:一個(gè)原本活蹦亂跳的男人離奇死亡请琳,死狀恐怖,靈堂內(nèi)的尸體忽然破棺而出赠幕,到底是詐尸還是另有隱情俄精,我是刑警寧澤,帶...
    沈念sama閱讀 35,413評(píng)論 5 343
  • 正文 年R本政府宣布榕堰,位于F島的核電站竖慧,受9級(jí)特大地震影響,放射性物質(zhì)發(fā)生泄漏逆屡。R本人自食惡果不足惜圾旨,卻給世界環(huán)境...
    茶點(diǎn)故事閱讀 41,008評(píng)論 3 325
  • 文/蒙蒙 一、第九天 我趴在偏房一處隱蔽的房頂上張望魏蔗。 院中可真熱鬧砍的,春花似錦、人聲如沸莺治。這莊子的主人今日做“春日...
    開封第一講書人閱讀 31,659評(píng)論 0 22
  • 文/蒼蘭香墨 我抬頭看了看天上的太陽(yáng)谣旁。三九已至床佳,卻和暖如春,著一層夾襖步出監(jiān)牢的瞬間榄审,已是汗流浹背砌们。 一陣腳步聲響...
    開封第一講書人閱讀 32,815評(píng)論 1 269
  • 我被黑心中介騙來泰國(guó)打工, 沒想到剛下飛機(jī)就差點(diǎn)兒被人妖公主榨干…… 1. 我叫王不留搁进,地道東北人浪感。 一個(gè)月前我還...
    沈念sama閱讀 47,698評(píng)論 2 368
  • 正文 我出身青樓,卻偏偏與公主長(zhǎng)得像饼问,于是被迫代替她去往敵國(guó)和親影兽。 傳聞我的和親對(duì)象是個(gè)殘疾皇子,可洞房花燭夜當(dāng)晚...
    茶點(diǎn)故事閱讀 44,592評(píng)論 2 353

推薦閱讀更多精彩內(nèi)容

  • 一.線程與進(jìn)程相關(guān) 1.進(jìn)程 ??定義:進(jìn)程是具有獨(dú)立功能的程序關(guān)于某個(gè)數(shù)據(jù)集合上的一次運(yùn)行活動(dòng)匆瓜,進(jìn)程是操作系統(tǒng)分...
    Geeks_Liu閱讀 1,713評(píng)論 2 4
  • 下面是我自己收集整理的Java線程相關(guān)的面試題赢笨,可以用它來好好準(zhǔn)備面試未蝌。 參考文檔:-《Java核心技術(shù) 卷一》-...
    阿呆變Geek閱讀 14,819評(píng)論 14 507
  • Spring Cloud為開發(fā)人員提供了快速構(gòu)建分布式系統(tǒng)中一些常見模式的工具(例如配置管理,服務(wù)發(fā)現(xiàn)茧妒,斷路器萧吠,智...
    卡卡羅2017閱讀 134,651評(píng)論 18 139
  • 記得前些年有個(gè)劉德華投資的小成本電影《瘋狂的石頭》,一部投資幾百萬的小制作電影桐筏,票房超過2000萬纸型,并捧紅了后來的...
    未來十年新零售閱讀 137評(píng)論 0 1
  • 歲月流逝 你容顏老矣 曾經(jīng)的輝煌業(yè)績(jī) 早載入歷史 留下時(shí)光痕跡 注入夢(mèng)海追憶 ……
    六月天氣閱讀 291評(píng)論 33 27