mormot.core.threads--TSynParallelProcess

来源:https://www.cnblogs.com/hieroly/p/18289982
-Advertisement-
Play Games

1 註冊中心 1.1 為什麼要用註冊中心 微服務之間會相互調用,假如有兩個服務orderService和userService,orderService會調用userService獲取當前訂單相關的用戶信息,且userService部署了多個實例: 大家思考幾個問題: order-service在發 ...


mormot.core.threads--TSynParallelProcess

{ ************ 線程池中的並行執行 }

type
  /// TSynParallelProcess 的並行化過程回調
  // - 如果 0<=IndexStart<=IndexStop,則應執行某些過程
  TOnSynParallelProcess = procedure(IndexStart, IndexStop: integer) of object;

  /// 為 TSynParallelProcess 執行過程的線程
  TSynParallelProcessThread = class(TSynBackgroundThreadMethodAbstract)
  protected
    fMethod: TOnSynParallelProcess; // 回調方法
    fIndexStart, fIndexStop: integer; // 要處理的索引範圍
    procedure Start(const Method: TOnSynParallelProcess; // 開始執行過程
      IndexStart, IndexStop: integer);
    /// 執行 fMethod(fIndexStart,fIndexStop)
    procedure Process; override;
  public
  end;

  /// 允許線上程池中並行執行基於索引的過程
  // - 將創建自己的線程池,然後將工作分配給每個線程執行
  TSynParallelProcess = class(TSynPersistentLock)
  protected
    fThreadName: RawUtf8; // 線程名稱
    fPool: array of TSynParallelProcessThread; // 線程池
    fThreadPoolCount: integer; // 線程池中的線程數
    fParallelRunCount: integer; // 並行運行次數
  public
    /// 初始化線程池
    // - 您可以定義一些回調來嵌套線程執行,例如,分配給 TRestServer.BeginCurrentThread/EndCurrentThread
    // - 最多可設置 MaxThreadPoolCount=32 個線程(您可以允許更大的值,但此線程池的目的是使其進程飽和每個 CPU 核心)
    // - 如果 ThreadPoolCount 為 0,則不會創建線程,並且過程將在當前線程中執行
    constructor Create(ThreadPoolCount: integer; const ThreadName: RawUtf8;
      const OnBeforeExecute: TOnNotifyThread = nil; // 執行前通知回調
      const OnAfterExecute: TOnNotifyThread = nil;  // 執行後通知回調
      MaxThreadPoolCount: integer = 32); reintroduce; virtual;
    /// 終結線程池
    destructor Destroy; override;
    /// 並行運行一個方法,並等待執行完成
    // - 將 Method[0..MethodCount-1] 的執行分散到線程中
    // - 如果在過程中發生任何異常,則此方法將引發 ESynParallel 異常
    // - 如果設置了 OnMainThreadIdle,則當前線程(例如,預期為主 UI 線程)將不會處理任何內容,但在等待後臺線程時調用此事件
    procedure ParallelRunAndWait(const Method: TOnSynParallelProcess;
      MethodCount: integer; const OnMainThreadIdle: TNotifyEvent = nil);
  published
    /// 已激活的線程數
    property ParallelRunCount: integer
      read fParallelRunCount;
    /// 此實例線程池中當前有多少線程
    property ThreadPoolCount: integer
      read fThreadPoolCount;
    /// 一些文本標識符,用於區分每個擁有的線程
    property ThreadName: RawUtf8
      read fThreadName;
  end;

後期再整理!

由於 TSynParallelProcess在mORMot 2框架中是一個假定的類(因為標準的mORMot 2庫並不直接包含這個類名,但它可能是一個自定義擴展或類似功能的類的代表),我將基於您提供的類定義來編寫一個假設的常式代碼,這個代碼將模擬在Free Pascal中使用這樣一個類。

請註意,以下代碼將不會直接編譯,因為 TSynParallelProcessTSynParallelProcessThread的具體實現細節(如構造函數、析構函數和方法的內部邏輯)並未給出。但是,我將提供一個結構化的示例,展示如何使用這樣的類(如果它存在的話)。

program TSynParallelProcessDemo;

{$MODE DELPHI}

uses
  SysUtils, Classes; // 引入必要的單元

// 假設TSynParallelProcess和TSynParallelProcessThread已經在某個單元中定義
// 這裡我們使用一個占位符單元名YourMormotUnit
// 註意:在實際應用中,您需要替換'YourMormotUnit'為包含這些類的實際單元名
uses YourMormotUnit;

procedure MyParallelTask(IndexStart, IndexStop: integer);
begin
  // 這裡是您的並行任務邏輯
  WriteLn('Executing task with indices from ', IndexStart, ' to ', IndexStop);
  // 模擬耗時操作
  Sleep(100); // 假設每個任務需要一些時間來完成
end;

var
  ParallelProcessor: TSynParallelProcess;
  TaskCount: Integer;

begin
  try
    // 初始化任務計數(這裡假設我們有100個任務要並行處理)
    // 註意:在實際應用中,您可能需要根據具體情況來確定這個值
    TaskCount := 100;

    // 創建TSynParallelProcess實例
    // 註意:這裡我們假設ThreadPoolCount是一個合理的值,例如CPU核心數的兩倍
    // 並且MaxThreadPoolCount足夠大以容納所需的線程數
    // ThreadName是可選的,用於標識線程池中的線程
    ParallelProcessor := TSynParallelProcess.Create(
      System.SysUtils.GetProcessorCount * 2, // 假設線程池大小為CPU核心數的兩倍
      'MyParallelTasks', // 線程名稱首碼(可選)
      nil, // OnBeforeExecute回調(這裡不使用)
      nil  // OnAfterExecute回調(這裡不使用)
    );
    try
      // 並行運行任務並等待完成
      // 註意:這裡的ParallelRunAndWait是假設的方法,它可能不直接存在於TSynParallelProcess中
      // 您需要根據實際的方法簽名和邏輯來調整以下調用
      // 由於我們沒有ParallelRunAndWait的具體實現,這裡只是一個示意性的調用
      // 在實際中,您可能需要調用一個不同的方法,或者ParallelRunAndWait本身就需要您來實現
      // 假設ParallelRunAndWait接受一個任務過程和任務總數作為參數
      ParallelProcessor.ParallelRunAndWait(
        @MyParallelTask, // 指向您的並行任務過程的指針
        TaskCount        // 要並行處理的任務總數
      );
    finally
      // 銷毀TSynParallelProcess實例
      ParallelProcessor.Free;
    end;
  except
    on E: Exception do
      WriteLn('An error occurred: ', E.Message);
  end;
  // 保持控制台視窗打開,直到用戶按任意鍵
  WriteLn('Press Enter to exit...');
  ReadLn;
end.

重要說明

  1. 類和方法的存在性:上述代碼假設 TSynParallelProcess類及其 ParallelRunAndWait方法存在。在mORMot 2的標準庫中,這樣的類和方法可能不存在,或者它們的名稱和參數可能有所不同。
  2. 實現細節:由於我們沒有 TSynParallelProcessTSynParallelProcessThread的具體實現,因此上述代碼中的 ParallelRunAndWait調用是示意性的。在實際應用中,您需要根據實際可用的方法來實現並行任務的執行。
  3. 線程池大小:在創建 TSynParallelProcess實例時,我使用了 System.SysUtils.GetProcessorCount * 2作為線程池的大小。這隻是一個常見的啟髮式方法,用於確定合理的線程數。然而,最佳線程數取決於您的具體應用程式和工作負載。
  4. 錯誤處理:代碼中包含了基本的錯誤處理邏輯,用於捕獲並列印異常消息。在實際應用中,您可能需要根據需要擴展這種錯誤處理。
  5. 單元引用:請將 uses YourMormotUnit;中的 YourMormotUnit替換為包含 TSynParallelProcessTSynParallelProcessThread定義的實際單元名。如果這些類是您自定義的,那麼您需要確保它們已經被正確編譯並包含在您的項目中。

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

-Advertisement-
Play Games
更多相關文章
  • ‍ 寫在開頭 點贊 + 收藏 學會 7 種方案解決移動端1px邊框的問題 造成邊框變粗的原因 css中的1px並不等於移動設備的1px,這是由不同手機由不同像素密度,在window對象中有一個devicePixelRatio屬性,他可以反應css中像素與設備的像素比 device ...
  • ## 動態表單系統:利用 Spring Boot 和 MyBatis 實現後端服務 在現代企業應用中,表單是數據收集和處理的核心部分。然而,傳統的表單系統難以適應快速變化的需求。為瞭解決這個問題,我們可以使用動態表單系統,它可以根據業務需求靈活地調整表單結構。本文將介紹如何使用 Spring Boo ...
  • 本文探討了Node.js事件迴圈中的timers階段,分析了定時器的管理和執行過程。通過源碼解析,揭示了定時器超時檢查、回調執行以及定時器類型(setTimeout與setInterval)的內部實現機制。文章旨在幫助讀者理解Node.js中定時器的工作原理及其在事件驅動編程中的重要性。 ...
  • 摘要:本文詳細介紹了Nuxt3框架中的五個webpack鉤子函數:webpack:configResolved用於在webpack配置解析後讀取和修改配置;webpack:compile在編譯開始前調用,可修改編譯選項;webpack:compiled在編譯完成後調用,可處理編譯結果;webpack... ...
  • ‍ 寫在開頭 點贊 + 收藏 學會 前言: 最近接到了一個需求很有意思,類似於我們經常在逛購物平臺中,選擇一個物品分享給好友,然後好友複製這段文本打開相對應的平臺以後,就可以彈出鏈接上的物品。實現過程也比較有意思,特來分享一下實現思路。 一. 效果預覽 當我在別的界面複製了內 ...
  • 本節課,我們主要講解了在Python類的繼承中子類如何進行初始化、調用父類的屬性和方法,同時講解了模擬串口感測器和主機類的具體實現,並使用xcom串口助手與兩個類進行串口通信使用。 ...
  • # Maven簡介 Maven的本質是一個項目管理工具,將項目開發和管理過程抽象成一個項目對象模型(POM)) 這玩意兒是使用Java開發的,所以採用的就是Java的思想:面向對象 POM (Project Object Model):項目對象模型 Maven的作用: 項目構建:提供標準的、跨平臺的 ...
  • 生成全局唯一 ID 全局唯一 ID 需要滿足以下要求: 唯一性:在分散式環境中,要全局唯一 高可用:在高併發情況下保證可用性 高性能:在高併發情況下生成 ID 的速度必須要快,不能花費太長時間 遞增性:要確保整體遞增的,以便於資料庫創建索引 安全性:ID 的規律性不能太明顯,以免信息泄露 從上面的要 ...
一周排行
    -Advertisement-
    Play Games
  • 通過WPF的按鈕、文本輸入框實現了一個簡單的SpinBox數字輸入用戶組件並可以通過數據綁定數值和步長。本文中介紹了通過Xaml代碼實現自定義組件的佈局,依賴屬性的定義和使用等知識點。 ...
  • 以前,我看到一個朋友在對一個系統做初始化的時候,通過一組魔幻般的按鍵,調出來一個隱藏的系統設置界面,這個界面在常規的菜單或者工具欄是看不到的,因為它是一個後臺設置的關鍵界面,不公開,同時避免常規用戶的誤操作,它是作為一個超級管理員的入口功能,這個是很不錯的思路。其實Winform做這樣的處理也是很容... ...
  • 一:背景 1. 講故事 前些天有位朋友找到我,說他的程式每次關閉時就會自動崩潰,一直找不到原因讓我幫忙看一下怎麼回事,這位朋友應該是第二次找我了,分析了下 dump 還是挺經典的,拿出來給大家分享一下吧。 二:WinDbg 分析 1. 為什麼會崩潰 找崩潰原因比較簡單,用 !analyze -v 命 ...
  • 在一些報表模塊中,需要我們根據用戶操作的名稱,來動態根據人員姓名,更新報表的簽名圖片,也就是電子手寫簽名效果,本篇隨筆介紹一下使用FastReport報表動態更新人員簽名圖片。 ...
  • 最新內容優先發佈於個人博客:小虎技術分享站,隨後逐步搬運到博客園。 創作不易,如果覺得有用請在Github上為博主點亮一顆小星星吧! 博主開始學習編程於11年前,年少時還只會使用cin 和cout ,給單片機點點燈。那時候,類似async/await 和future/promise 模型的認知還不是 ...
  • 之前在阿裡雲ECS 99元/年的活動實例上搭建了一個測試用的MINIO服務,以前都是直接當基礎設施來使用的,這次準備自己學一下S3相容API相關的對象存儲開發,因此有了這個小工具。目前僅包含上傳功能,後續計劃開發一個類似圖床的對象存儲應用。 ...
  • 目錄簡介快速入門安裝 NuGet 包實體類User資料庫類DbFactory增刪改查InsertSelectUpdateDelete總結 簡介 NPoco 是 PetaPoco 的一個分支,具有一些額外的功能,截至現在 github 星數 839。NPoco 中文資料沒多少,我是被博客園群友推薦的, ...
  • 前言 前面使用 Admin.Core 的代碼生成器生成了通用代碼生成器的基礎模塊 分組,模板,項目,項目模型,項目欄位的基礎功能,本篇繼續完善,實現最核心的模板生成功能,並提供生成預覽及代碼文件壓縮下載 準備 首先清楚幾個模塊的關係,如何使用,簡單畫一個流程圖 前面完成了基礎的模板組,模板管理,項目 ...
  • 假設需要實現一個圖標和文本結合的按鈕 ,普通做法是 直接重寫該按鈕的模板; 如果想作為通用的呢? 兩種做法: 附加屬性 自定義控制項 推薦使用附加屬性的形式 第一種:附加屬性 創建Button的附加屬性 ButtonExtensions 1 public static class ButtonExte ...
  • 在C#中,委托是一種引用類型的數據類型,允許我們封裝方法的引用。通過使用委托,我們可以將方法作為參數傳遞給其他方法,或者將多個方法組合在一起,從而實現更靈活的編程模式。委托類似於函數指針,但提供了類型安全和垃圾回收等現代語言特性。 基本概念 定義委托 定義委托需要指定它所代表的方法的原型,包括返回類 ...