Блог

У меня есть класс, в котором есть внутренняя очередь и объект подключения к серверу. Когда элемент помещается в очередь, создается соединение, и элемент обрабатывается, соединение уничтожается, а затем цикл ожидает следующего элемента в очереди.

Я хочу, чтобы после создания соединения сохранялось созданное в течение X секунд / минут, в случае нажатия какого-либо нового элемента мне не нужно заново создавать и повторно аутентифицировать соединение. Вот пример:

 program Project1;

{$APPTYPE CONSOLE}

{$R *.res}

uses
  System.SysUtils, System.Classes, System.Generics.Collections, System.Threading;

type
  TConn = class
  public
    procedure Authenticate;
  end;

  TMyClass = class
  private
    FQueue: TThreadedQueue<TProc<TConn>>;
    FTask: ITask;
    procedure Start;
  public
    constructor Create;
    destructor Destroy; override;
    procedure Push(Proc: TProc<TConn>);
  end;

{ TConn }

procedure TConn.Authenticate;
begin

end;

{ TMyClass }

constructor TMyClass.Create;
begin
  FQueue := TThreadedQueue<TProc<TConn>>.Create;
  Start;
end;

destructor TMyClass.Destroy;
begin
  FQueue.DoShutDown;
  FQueue.Free;
  inherited;
end;

procedure TMyClass.Push(Proc: TProc<TConn>);
begin
  FQueue.PushItem(Proc);
end;

procedure TMyClass.Start;
var
  Proc: TProc<TConn>;
  Conn: TConn;
begin
  FTask := TTask.Run(procedure
  begin
    while not FQueue.Shutdown or (FQueue.QueueSize > 0) do
    begin
      //Blocked by internal TMonitor, released when DoShutdown is called or PushItem
      FQueue.PopItem(Proc);

      if FQueue.ShutDown then
        Exit;

      Conn := TConn.Create;
      Conn.Authenticate;
      Proc(Conn);
      Conn.Free;
    end;
  end);
end;

var
  MyClass: TMyClass;
begin
  try
    MyClass := TMyClass.Create;
    MyClass.Push(procedure(AParam: TConn)
    begin
      //use conn
    end);
  except
    on E: Exception do
      Writeln(E.ClassName, ': ', E.Message);
  end;
end.
 

При вызове Conn.Free я хочу подождать и оставить его созданным на некоторое время. Если истечет время ожидания X секунд / минут, соединение будет уничтожено и воссоздано в следующем элементе.

Является ли таймер лучшим подходом здесь? Я не люблю использовать таймеры, но в данном случае, я думаю, это имеет смысл.

Я мог бы использовать тайм-аут TThreadedQueue, но тайм-аут устанавливается при создании объекта и используется при ожидании PopItem . Я хотел дождаться только создания соединения, если соединения нет, нет смысла использовать этот тайм-аут. Если бы тайм-аут TThreadedQueue был доступен в prop, я мог бы установить его при создании conn, а затем, после уничтожения, вернуться к бесконечности. Но это не так.

Есть предложения?