Changeset 3 for trunk/Platform

Timestamp:

Nov 22, 2014, 11:50:49 PM (10 years ago)

Author:

chronos

Message:

• Added: Application is executed as Task by Scheduler. OS threads is used for scheduler for efficient execution.

File:

• trunk/Platform/Base/UPlatformBase.pas (modified) (1 diff)

trunk/Platform/Base/UPlatformBase.pas

@@ -6 +6 @@
 
 uses
-  Classes, SysUtils, UFileSystem;
+  Classes, SysUtils, UFileSystem, UKernel;
 
 type
+  { TCustomThread }
+
+  TCustomThread = class(TThread)
+    Task: TTask;
+    procedure Execute; override;
+  end;
+
+  { TBaseTask }
+
+  TBaseTask = class(TTask)
+    Thread: TCustomThread;
+    constructor Create; override;
+    destructor Destroy; override;
+  end;
+
+
   TBaseFileSystem = class(TFileSystem)
 
   end;
 
+  { TBaseScheduler }
+
+  TBaseScheduler = class(TScheduler)
+    function AddTask(Name: string; EntryPoint: TEvent): TTask; override;
+    constructor Create; override;
+    procedure Start; override;
+  end;
+
 implementation
+
+{ TBaseTask }
+
+constructor TBaseTask.Create;
+begin
+  inherited;
+  Thread := TCustomThread.Create(True);
+  Thread.Task := Self;
+end;
+
+destructor TBaseTask.Destroy;
+begin
+  Thread.Free;
+  inherited Destroy;
+end;
+
+{ TCustomThread }
+
+procedure TCustomThread.Execute;
+begin
+  Task.EntryPoint;
+end;
+
+{ TBaseScheduler }
+
+function TBaseScheduler.AddTask(Name: string; EntryPoint: TEvent): TTask;
+var
+  Task: TBaseTask;
+begin
+  Task := TBaseTask(inherited AddTask(Name, EntryPoint));
+  if Running then Task.Thread.Start;
+end;
+
+constructor TBaseScheduler.Create;
+begin
+  inherited Create;
+  TaskClass := TBaseTask;
+end;
+
+procedure TBaseScheduler.Start;
+var
+  I: Integer;
+begin
+  inherited Start;
+  for I := 0 to Tasks.Count - 1 do
+    TBaseTask(Tasks[I]).Thread.Start;
+end;
 
 end.