TBackgroundTasks fpc sample

samples/fpc/QuickThreads/BackgroundTasks/RunBackgroundTasks.lpi

@@ -0,0 +1,60 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<CONFIG>
+  <ProjectOptions>
+    <Version Value="11"/>
+    <PathDelim Value="\"/>
+    <General>
+      <Flags>
+        <MainUnitHasCreateFormStatements Value="False"/>
+        <MainUnitHasTitleStatement Value="False"/>
+        <MainUnitHasScaledStatement Value="False"/>
+      </Flags>
+      <SessionStorage Value="InProjectDir"/>
+      <MainUnit Value="0"/>
+      <Title Value="RunBackgroundTasks"/>
+      <UseAppBundle Value="False"/>
+      <ResourceType Value="res"/>
+    </General>
+    <BuildModes Count="1">
+      <Item1 Name="Default" Default="True"/>
+    </BuildModes>
+    <PublishOptions>
+      <Version Value="2"/>
+    </PublishOptions>
+    <RunParams>
+      <FormatVersion Value="2"/>
+      <Modes Count="0"/>
+    </RunParams>
+    <Units Count="1">
+      <Unit0>
+        <Filename Value="RunBackgroundTasks.lpr"/>
+        <IsPartOfProject Value="True"/>
+      </Unit0>
+    </Units>
+  </ProjectOptions>
+  <CompilerOptions>
+    <Version Value="11"/>
+    <PathDelim Value="\"/>
+    <Target>
+      <Filename Value="RunBackgroundTasks"/>
+    </Target>
+    <SearchPaths>
+      <IncludeFiles Value="$(ProjOutDir)"/>
+      <OtherUnitFiles Value="..\..\..\.."/>
+      <UnitOutputDirectory Value="lib\$(TargetCPU)-$(TargetOS)"/>
+    </SearchPaths>
+  </CompilerOptions>
+  <Debugging>
+    <Exceptions Count="3">
+      <Item1>
+        <Name Value="EAbort"/>
+      </Item1>
+      <Item2>
+        <Name Value="ECodetoolError"/>
+      </Item2>
+      <Item3>
+        <Name Value="EFOpenError"/>
+      </Item3>
+    </Exceptions>
+  </Debugging>
+</CONFIG>

samples/fpc/QuickThreads/BackgroundTasks/RunBackgroundTasks.lpr

@@ -0,0 +1,85 @@
+program RunBackgroundTasks;
+
+{$IFDEF MSWINDOWS}
+{$APPTYPE CONSOLE}
+{$ENDIF}
+
+{$MODE DELPHI}
+
+uses
+  {$IFDEF UNIX}
+  cthreads,
+  {$ENDIF}
+  SysUtils,
+  DateUtils,
+  Quick.Commons,
+  Quick.Console,
+  Quick.Threads;
+
+type
+  TMyTask = class
+  private
+    fId : Integer;
+    fName : string;
+  public
+    property Id : Integer read fId write fId;
+    property Name : string read fName write fName;
+    procedure DoJob(task : ITask);
+    procedure Failed(task : ITask; aException : Exception);
+    procedure Finished(task : ITask);
+  end;
+
+var
+  backgroundtasks : TBackgroundTasks;
+  mytask : TMyTask;
+  i : Integer;
+
+{ TMyTask }
+
+procedure TMyTask.DoJob(task : ITask);
+var
+  a, b, i : Integer;
+begin
+  cout('[%s] task "%s" doing a %s job...',[DateTimeToStr(Now()),fName,task.Param[0].AsString],etInfo);
+  Sleep(Random(1000));
+  a := Random(100);
+  b := Random(5) + 1;
+
+  i := a div b;
+  cout('task "%s" result %d / %d = %d',[fName,a,b,i],etSuccess);
+end;
+
+procedure TMyTask.Failed(task : ITask; aException : Exception);
+begin
+  cout('task "%s" failed (%s)',[fName,aException.Message],etError);
+end;
+
+procedure TMyTask.Finished(task : ITask);
+begin
+  cout('task "%s" finished',[fName],etDebug);
+end;
+
+begin
+  Console.LogVerbose := LOG_DEBUG;
+  try
+    backgroundtasks := TBackgroundTasks.Create(10);
+    for i := 1 to 100 do
+    begin
+      mytask := TMyTask.Create;
+      mytask.Id := i;
+      mytask.Name := 'Task' + i.ToString;
+      backgroundtasks.AddTask(['blue'],True,mytask.DoJob
+                             ).OnException(mytask.Failed
+                             ).OnTerminated(mytask.Finished
+                             ).Run;
+    end;
+    backgroundtasks.Start;
+    cout('Running tasks in background!',etInfo);
+    ConsoleWaitForEnterKey;
+    backgroundtasks.Free;
+  except
+    on E: Exception do
+      Writeln(E.ClassName, ': ', E.Message);
+  end;
+end.
+