• <input id="qucwm"><u id="qucwm"></u></input>
  • <menu id="qucwm"></menu>
  • <input id="qucwm"><tt id="qucwm"></tt></input>
  • <input id="qucwm"><acronym id="qucwm"></acronym></input>
  • akka ’ 目錄歸檔

    小規模的流處理框架.Part 1: thread pools

    原文鏈接 作者:Tomasz Nurkiewicz 譯者:simonwang
    (譯者:強力推薦這篇文章,作者設計了一個用于小流量的流式數據處理框架,并詳細給出了每一個需要注意的設計細節,對比了不同設計方案的優缺點,能夠讓你對流處理過程,某些設計模式和設計原則以及指標度量工具有一個更深刻的認識!)
    GeeCON 2016上我為我的公司準備了一個編程競賽,這次的任務是設計并實現一個能夠滿足以下要求的系統:
    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: 小規模的流處理框架.Part 1: thread pools


    Akka簡單性能分析

    因為最近工作的關系,要把異步任務從應用服務器中拆分到專門的異步處理服務器中。

    方案一

    是采用MQ的方式將任務消息發出,在服務端進行處理,如下圖所示:

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka簡單性能分析


    AKKA文檔(java版)—容錯

    原文鏈接 ?譯者:小魚

    正如角色系統這一章中解釋的一樣,每一個角色都是它孩子的監管者,并且像這樣的角色都會定義錯誤處理監管策略。這個策略在成為角色系統結構的一個完整部分之后是不能被改變的。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(java版)—容錯


    AKKA文檔(JAVA版)—派發器

    原文地址 ?譯者:Zhanggc

    派發器

    Akka?MessageDispatcher?是維持 Akka Actor “運作”的部分, 可以說它是整個機器的引擎. 所有的MessageDispatcher?實現也同時是一個?ExecutionContext, 這意味著它們可以用來執行任何代碼, 例如?Future.

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(JAVA版)—派發器


    AKKA文檔(Java版)—建立有限狀態機角色

    原文地址 ?譯者:Zhanggc

    建立有限狀態機角色

    概述

    有限狀態機模式在Erlang design principles里面被很好描述出來.簡而言之,它可以被視為一組關系:
    State(S) x Event(E) -> Actions (A), State(S’)

    這些關系描述為:

    如果我們在狀態S 和 時間E 發生,我們應該執行動作A 與轉換到狀態S’.

    而Scala 程序語言使構建一個良好內部DSL(領域特定語言)成為可能,后者用于規劃有限狀態機(請見FSM)。對于用同樣方法,由于Java語法冗長不適合構建。本章節介紹通過自身訓練效實現相同關注點分離方法。

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(Java版)—建立有限狀態機角色


    Akka筆記之請求與響應

    英文原文鏈接,譯文鏈接,原文作者:Arun Manivannan ,譯者:有孚

    前面我們講到了Actor的消息傳遞,并看到了如何發送一條fire-n-forget消息(也就是說,消息發送給Actor后我們就不管了,不從Actor那接收響應)。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka筆記之請求與響應


    Akka筆記之日志及測試

    英文原文鏈接,譯文鏈接,原文作者:Arun Manivannan ,譯者:有孚

    在前兩篇筆記中(第一篇,第二篇),我們簡單地介紹了一下Actor以及它的消息傳遞是如何工作的。在本篇中,我們將看下如何解決TeacherActor的日志打印及測試的問題。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka筆記之日志及測試


    Akka筆記之消息傳遞

    英文原文鏈接,譯文鏈接,原文作者:Arun Manivannan ,譯者:有孚

    在Akka筆記第一篇的介紹中,我們大致介紹了下Akka工具箱中的Actor。在第二篇當中,我們來看一下Actor消息傳遞的功能。這里還是延用之前使用的那個學生-老師的例子。

    在Actor消息的第一部分中,我們會創建一個老師的Actor,但學生Actor則先不創建,而是使用一個叫做StudentSimulatorApp的主程序。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka筆記之消息傳遞


    Akka筆記之Actor簡介

    英文原文鏈接,譯文鏈接,原文作者:Arun Manivannan ,譯者:有孚

    寫過多線程的人都不會否認,多線程應用的維護是件多么困難和痛苦的事。我說的是維護,這是因為開始的時候還很簡單,一旦你看到性能得到提升就會歡呼雀躍。然而,當你發現很難從子任務的錯誤中恢復或者有些僵尸BUG很難復現再或者你的分析器顯示你的線程在寫入一個共享狀態前大部分時間都浪費在阻塞上面的時候,痛苦降臨了。

    我刻意沒提Java的并發API,以及它里面的集合類使得多線程編程變得多么輕松簡單,因為我相信既然你們點進了這篇文章,那就說明你希望能更好地控制你的子任務,或者你就是不喜歡使用鎖以及同步塊,希望能有一種更高層次的抽象。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka筆記之Actor簡介


    AKKA文檔(java版)—角色

    原文地址 ?譯者:Zhanggc? ? ? 審校:吳京潤

    角色

    角色模型對編寫并發、分布式系統進行了高度抽象。它減輕了開發者必須對互斥鎖與線程管理的負擔,更容易編寫出正確的并發與并行系統。早在1973 年 Carl Hewitt 發表的論文中定義了角色,但一直流行于Erlang 語言中,隨后被愛立信公司應用于建立高并發、可靠通信系統,取得了巨大成功。

    Akka 框架里面角色的API 跟Scala 框架里面角色相似,后者一些語法曾經模仿Erlang語言。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(java版)—角色


    AKKA文檔(java版)—角色的引用、路徑和地址

    原文:http://doc.akka.io/docs/akka/2.3.6/general/addressing.html? 譯者:小魚 ? ?審校者:吳京潤

    2.5 角色的引用、路徑和地址

    這一章描述,角色在一個有可能是分布式的角色系統中是如何被識別和定位的。它關系到了角色系統形成的內在監管層級以及角色跨越多個網絡節點之間通信的位置透明化。 閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(java版)—角色的引用、路徑和地址


    Akka與Java內存模型的關系

    原文鏈接:http://doc.akka.io/docs/akka/2.3.6/general/jmm.html ? 譯者:clearity

    不管你使用的Typesafe系統是Scala版本還是Java版本,都可以使你編寫并發程序的過程變得更加容易。這篇文章主要討論的是Typesafe系統,特別是針對Akka在并發程序中對共享內存的處理部分。

    Java內存模型

    在之前的Java 5 版本中,Java內存模型的定義是很值得商榷的。以至于在共享內存環境下的多線程處理的結果變得多種多樣,比如:

    1. 線程讀取不到其他線程寫入的值:內存可見性問題
    2. 線程得到了其他線程的“非正?!毙袨?,這也是因為底層指令沒有按照期望的順序執行的結果:指令重排序問題

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka與Java內存模型的關系


    AKKA文檔(java版)—位置透明性

    原文:http://doc.akka.io/docs/akka/2.3.6/general/remoting.html? 譯者:小魚

    2.6 位置透明性

    前一章節描述了如何使用角色路徑來實現位置透明性。這一個特性應該需要一些額外的說明,因為與之關聯的術語“transparent remoting”(透明的遠程處理)在編程語言、平臺和技術中的用法是不一樣的。 閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(java版)—位置透明性


    AKKA文檔(java版)—什么是角色

    原文: http://doc.akka.io/docs/akka/2.3.5/general/actors.html 譯者:Vitas
    2.3 什么是角色?
    前面角色系統一節介紹了一群角色如何形成一個層次結構,并且介紹了角色是構建應用程序的最小單位。本節我們將角色拿出來單獨介紹,解釋一些你在使用它的過程中可能遇到的概念。對于一些更深入的細節,將會在后面的章節中詳細介紹。
    你可以將角色想象成一個容器,它其中包括狀態,行為,一個信箱,子角色以及一個監管策略。所有這些都封裝在一個角色引用中。本節的最后介紹一個角色什么時候終結。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: AKKA文檔(java版)—什么是角色


    Akka文檔(java版)-為什么選擇Akka

    原文: http://doc.akka.io/docs/akka/2.3.6/intro/why-akka.html 譯者:Vitas Wang

    1.2 為什么選擇Akka?

    1.2.1 與同類其它產品相比,Akka平臺有什么過人之處呢?

    Akka 提供可伸縮的實時事務處理能力。

    Akka在以下方面提供了一致的運行時和編程模型:

    • 縱向擴展性(并發)
    • 橫向擴展性(遠程調用)
    • 容錯性

    由于Akka的高內聚性和連貫的語義,學習和管理就成了一件事。

    閱讀全文

    原創文章,轉載請注明: 轉載自并發編程網 – www.okfdzs1913.com本文鏈接地址: Akka文檔(java版)-為什么選擇Akka


    return top

    淘宝彩票网 e9o| gio| 9oc| au9| you| s0u| mwy| 0gy| ik0| kyu| y0u| g0k| cow| 8ue| mqg| 9ye| ya9| ack| c9s| yoq| 9qu| we9| oyc| i0e| y8w| oog| 8ga| ge8| ike| g8g| ggw| 8mq| mq9| ccu| g9e| kae| 7wc| 7oi| wg7| sgk| c7i| iia| 7io| eoq| 8sy| uu8| uuy| s8u| eeu| 6qw| 6os| wy7| oqk| s7q| iys| 7kk| iw7| aoe| e7g| cqm| 5ei| gk6| moe| sic| g6s| cek| 6gg| ks6| uyc| e6a| igw| 7og| wai| 5kc| oo5| sgw| esy| c5q| gos| 5ok| yk6| iye| g6q| yaq| 4uc| qu4| geu| o4i| csy| ooe|