Форум программистов [Powered by Invision Power Board]

Код


type
  TiaSphere = class(TThread)
 protected
    fCS_AccessToProps: TCriticalSection;
    fTimeCount: Cardinal;
    fSphereEvent: TSimpleEvent;
    fRequestInterval: Cardinal;

    procedure Execute; override;
 public
    Constructor Create(CreateSuspended: Boolean); virtual;
    Destructor Destroy; override;
    procedure Start;
    procedure Stop;
end;

Код


procedure TiaSphere.Execute;
begin
  SetName;

  while (not Terminated) do
  Begin
    try
      fSphereEvent.WaitFor(INFINITE);

      If Terminated then Continue;

      if (GetTickCount() - fTimeCount) > ( fRequestInterval ) then
        begin
          try
            Monitoring;
          finally
            fTimeCount := GetTickCount;
          end;
        end;

      //пауза что бы поток не кушал такты процессора слишком сильно
      Sleep(50);
    except
      on E: Exception do
        begin
          WriteToLog('Error in thread: ' + e.Message);
        end;
    end;
  end;
end;

constructor TiaSphere.Create(CreateSuspended: Boolean);
begin
  inherited;

  fRequestInterval := MSC_REQUEST_INTERVAL;

  fCS_AccessToProps := TCriticalSection.Create;

  fSphereEvent := TSimpleEvent.Create;
  fSphereEvent.ResetEvent;

  fSphereAPI := TiaSphereAPI.Create;
  fSphereAPI.Log := fLoger;

  setDebugLogging( False );
end;

destructor TiaSphere.Destroy;
begin
  Terminate;
  fSphereEvent.SetEvent;
  WaitFor;

  FreeAndNil(fSphereAPI);

  FreeAndNil(fSphereEvent);
  FreeAndNil(fCS_AccessToProps);

  inherited;
end;

procedure TiaSphere.Start;
begin
  try
    fSphereAPI.Active := True;

    fTimeCount :=  GetTickCount;

    fSphereEvent.SetEvent;

    WriteToLog('Monitoring started');

    setIsStarted( True );
  except
    on e: Exception do
      begin
        fSphereAPI.Active := false;
        WriteToLog('Error while monitoring started: ' + e.Message);
      end;
  end;
end;

procedure TiaSphere.Stop;
begin
  try
    fSphereEvent.ResetEvent;

    fSphereAPI.Active := False;

    WriteToLog('Monitoring stopped');

    setIsStarted( False );
  except
    on e: Exception do
      begin
        WriteToLog('Errro while monitoring started: ' + e.Message);
      end;
  end;
end;