ezthreads - thread pool support

mr-highball

Full Member
Posts: 233

ezthreads - thread pool support

« on: April 15, 2020, 06:05:41 am »

added thread pool support to ezthreads, hope this helps someone out there,

some features:

works with await (entire pool or specific group id)
thread pool is itself an IEZThread, so all events are supported
safe capturing of success / error cases for individual threads
global arguments passed to pool carry to workers

basic usage:

Code: Pascal [Select][+]

(*
  test that shows two simple tasks completing in parallel
  by an ezthread pool
*)
procedure TestTwoTasks;
var
  LPool : IEZThreadPool;
  LJobOneFinished,
  LJobTwoFinished: Boolean;
 
  //simple parallel job
  procedure JobOne(const AThread : IEZThread);
  begin
    //do some work
    Sleep(100);
    LJobOneFinished := True;
  end;
 
  //simple parallel job
  procedure JobTwo(const AThread : IEZThread);
  begin
    //do some work
    Sleep(100);
    LJobTwoFinished := True;
  end;
 
begin
  //flags for checking if both jobs finished
  LJobOneFinished := False;
  LJobTwoFinished := False;
 
  //init a pool with two workers
  LPool := NewEZThreadPool(2);
 
  //work two jobs
  LPool
    .Queue(JobOne, nil, nil)
    .Queue(JobTwo, nil, nil)
    .Start; //start the pool
 
  //wait until both jobs finish
  Await(LPool);
 
  //write status
  WriteLn(Format('TestTwoTasks::[success]:%s', [BoolToStr(LJobOneFinished and LJobTwoFinished, True)]));
end;
 