Delphi 200X、XE中如何用并行实现循环的计算
2023-09-27 14:29:12 时间
interface uses Classes, SysUtils; type TParallelProc = reference to procedure(i: Integer; ThreadID: Integer); TParallel = class(TThread) private FProc: TParallelProc; FThreadID: Integer; //current thread ID protected procedure Execute; override; function GetNextValue: Integer; public constructor Create; destructor Destroy; override; property Proc: TParallelProc read FProc write FProc; class var CurrPos: Integer; //current loop index MaxPos: Integer; //max loops index cs: TCriticalSection; ThCount: Integer; //thread counter - how much threads have finished execution end; {** ParallelFor Loop - all iterations will be performed in chosen threads @param nMin - Loop min value (first iteration) @param nMax - Loop max value (last iteration) @param nThreads - how much threads to use @param aProc - anonymous procedure which will be performed in loop thread } procedure ParallelFor(nMin, nMax, nThreads: Integer; aProc: TParallelProc); overload; {** ParallelFor Loop - all iterations will be performed in max cpu cores @param nMin - Loop min value (first iteration) @param nMax - Loop max value (last iteration) @param aProc - anonymous procedure which will be performed in loop thread } procedure ParallelFor(nMin, nMax: Integer; aProc: TParallelProc); overload; implementation uses {$IFDEF MSWINDOWS} Windows, {$ENDIF} SyncObjs; procedure ParallelFor(nMin, nMax, nThreads: Integer; aProc: TParallelProc); var threads: array of TParallel; I: Integer; begin if nMin > nMax then Exit; // initialize TParallel class data TParallel.CurrPos := nMin; TParallel.MaxPos := nMax; TParallel.cs := TCriticalSection.Create; TParallel.ThCount := 0; // create the threads SetLength (threads, nThreads); for I := 0 to nThreads - 1 do begin threads[I] := TParallel.Create; // suspended threads[I].FThreadID := I; threads[I].Proc := aProc; threads[I].Start; end; for I := 0 to nThreads - 1 do begin threads[I].WaitFor; end; for I := 0 to nThreads - 1 do begin threads[I].Free; end; TParallel.cs.Free; end; procedure ParallelFor(nMin, nMax: Integer; aProc: TParallelProc); begin ParallelFor(nMin, nMax, CPUCount, aProc); end; { TParallel } constructor TParallel.Create; begin inherited Create(True); // suspended InterlockedIncrement(ThCount); FreeOnTerminate := False; FThreadID := 0; end; destructor TParallel.Destroy; begin InterlockedDecrement(ThCount); inherited; end; procedure TParallel.Execute; var nCurrent: Integer; begin nCurrent := GetNextValue; while nCurrent <= MaxPos do begin Proc(nCurrent, FThreadID); nCurrent := GetNextValue; end; end; function TParallel.GetNextValue: Integer; begin cs.Acquire; try Result := CurrPos; Inc(CurrPos); finally cs.Release; end; end;
相关文章
- TensorFlow2-实战(一):回归问题(手写梯度下降,不用任何模型)、步骤:【初始化参数】-->【循环(①计算Loss;②计算梯度;③利用梯度下降来更新参数)】
- python break continue跳过和跳出循环
- Javascript中的循环变量声明,到底应该放在哪儿?
- 0077-Go-for 循环
- doT中嵌套for循环的使用
- while循环和until语句
- js--非循环方式填充数组
- 2019牛客多校第五场 generator 1——广义斐波那契循环节&&矩阵快速幂
- c – 强制C99在CMake(使用’for’循环初始声明)
- Android摄像头开发完美demo---(循环聚焦,缩放大小,旋转picture,查询支持的picturesize, ImageButton按键效果)
- MATLAB的循环结构