日韩性视频-久久久蜜桃-www中文字幕-在线中文字幕av-亚洲欧美一区二区三区四区-撸久久-香蕉视频一区-久久无码精品丰满人妻-国产高潮av-激情福利社-日韩av网址大全-国产精品久久999-日本五十路在线-性欧美在线-久久99精品波多结衣一区-男女午夜免费视频-黑人极品ⅴideos精品欧美棵-人人妻人人澡人人爽精品欧美一区-日韩一区在线看-欧美a级在线免费观看

歡迎訪問 生活随笔!

生活随笔

當前位置: 首頁 > 编程资源 > 编程问答 >内容正文

编程问答

并行模型Actor

發(fā)布時間:2023/12/4 编程问答 28 豆豆
生活随笔 收集整理的這篇文章主要介紹了 并行模型Actor 小編覺得挺不錯的,現(xiàn)在分享給大家,幫大家做個參考.

并行開發(fā)時經(jīng)常需要關(guān)注加鎖和原子操作等一系列線程問題,而Actor模型內(nèi)部狀態(tài)由它自己維護,內(nèi)部數(shù)據(jù)只能自己修改,因此Actor不需要過多關(guān)注線程問題。

Actor模型

Actor由狀態(tài)(State)、郵箱(Mailbox)和行為(Behavior)組成。

NewLife.Model.Actor 設計為一個輕量級Actor模型,麻雀雖小五臟俱全!

/// <summary>無鎖并行編程模型</summary> /// <remarks> /// 獨立線程輪詢消息隊列,簡單設計避免影響默認線程池。 /// 適用于任務顆粒較大的場合,例如IO操作。 /// </remarks> public interface IActor {/// <summary>添加消息,驅(qū)動內(nèi)部處理</summary>/// <param name="message">消息</param>/// <param name="sender">發(fā)送者</param>/// <returns>返回待處理消息數(shù)</returns>Int32 Tell(Object message, IActor sender = null); }

IActor 接口設計為只有一個Tell方法,用于傳遞要發(fā)通知給目標Actor。這里的message可以列極為狀態(tài)(State)。目標Actor內(nèi)部有個隊列收集信息,該隊列可以認為是郵箱(Mailbox)。Actor內(nèi)部有獨立線程去讀取 郵箱數(shù)據(jù)進行處理,即是行為(Behavior)!

從某種程度上來講,Actor就是一個隊列加上獨立線程。如果該隊列設計為分布式隊列,那么這個Actor就成了真正的分布式并行模型。(如果Actor配上RedisQueue又會怎么樣呢?)

Actor可以一個接著一個,串聯(lián)起來,形成分布式并發(fā)處理集群。盡管是分布式系統(tǒng),然而所有代碼完全不需要考慮多線程問題。

總之,Actor模型的理念非常簡單:萬物皆Actor!

應用例程

我們來看一段測試代碼,默認讀取數(shù)據(jù)庫然后生成Excel文件,兩步都是比較耗時的操作。

[Fact] public async void Test1() {var sw = Stopwatch.StartNew();var actor = new BuildExcelActor();for (var i = 0; i < 6; i++){// 模擬查詢數(shù)據(jù),耗時500msXTrace.WriteLine("讀取數(shù)據(jù)……");await Task.Delay(500);// 通知另一個處理器actor.Tell($"數(shù)據(jù)行_{i + 1}");}// 等待最終完成actor.Stop();sw.Stop();Assert.True(sw.ElapsedMilliseconds > 6 * 500);Assert.True(sw.ElapsedMilliseconds < 6 * 500 + 500); } private class BuildExcelActor : Actor {protected override async Task ReceiveAsync(ActorContext context){XTrace.WriteLine("生成Excel數(shù)據(jù):{0}", context.Message);await Task.Delay(500);} }

新建一個實現(xiàn)類繼承Actor,重寫ReceiveAsync,實現(xiàn)Actor行為(業(yè)務邏輯)。此時獨占線程,所以無需考慮多線程問題。

跑起來看看日志輸出

從上圖可以看出,主邏輯和Actor是并行執(zhí)行。主邏輯把數(shù)據(jù)送給Actor后,繼續(xù)去讀取下一頁,無需等待Actor生成完成。

總結(jié)

XCode的實體延遲隊列,就是一個貨真價實的Actor模型。主邏輯只管處理業(yè)務,數(shù)據(jù)保存操作由另一個Actor完成。

此處為語雀文檔,點擊鏈接查看:https://www.yuque.com/go/doc/7553851

DAL的數(shù)據(jù)導出、恢復和備份,也是Actor模型,主邏輯操作數(shù)據(jù)庫,獨立Actor負責寫入文件,相比同一段邏輯完成該操作大概提升一倍性能。

總結(jié)

以上是生活随笔為你收集整理的并行模型Actor的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯,歡迎將生活随笔推薦給好友。