program MultiParsing;

{$APPTYPE CONSOLE}

uses
  FastMM4,
  SysUtils,
  zmq_h in '..\libZMQ\zmq_h.pas',
  zmq_classes in '..\libZMQ\zmq_classes.pas',
  Math;

const
  cMaxThreads = 5;
  cPagesCount = 20;
  cMasterEndPint = 'inproc://Parsers';


procedure Parser(aArgs: Pointer; aContext: TzmqContext; aInnerPipe: TzmqSocket);
var
  fMsg: TzmqMessage;
  fMasterSocket: TzmqSocket;
  fStr: string;
  fInnerNumber: Integer;
begin
  fInnerNumber := pInteger(aArgs)^; // Номер парасера
  fMasterSocket := aContext.Socket(stRouter);
  fMasterSocket.Connect(cMasterEndPint);
  fMsg := TzmqMessage.Create;
  try
    fMsg.Add().AsString := 'Ready!';
    aInnerPipe.Send(fMsg);
    while fMasterSocket.Recv(fMsg) >= 0 do begin; // Получение задания на парсинг;
      fStr := fMsg[1].AsString; // Текст задания
      if fStr = 'Parse' then begin
        sleep(Random(1000));// кагбэ.. выполняем задание, "парсим"
        // Для сокета ROUTER в fMsg[0] хранится "обратный адрес"
        fMsg[1].AsString := 'OK'; //  Сообщаем о результате
        fMsg[2].AsInteger := fInnerNumber; //  Идентификатор парсера
        fMasterSocket.Send(fMsg)
      end;
    end;
  finally
    FreeAndNil(fMsg);
  end;
end;

procedure doIt();
var
  fCtx: TzmqContext;
  i: Integer;
  fOuterPipe: TzmqSocket;
  fParserSocket: TzmqSocket;
  fMsg: TzmqMessage;
begin
  fCtx := TzmqContext.Create();
  fParserSocket := fCtx.Socket(stDealer);
  fParserSocket.Bind(cMasterEndPint);
  fMsg := nil;
  try
    // Создание пула парсеров:
    for i := 0 to Pred(Min(cMaxThreads, cPagesCount)) do begin
      fOuterPipe := fCtx.Fork_Attached_Thread(@i, @Parser); // Создаем нить - парсер
      fOuterPipe.Recv(fMsg); // Дожидаемся запуска
      Writeln('Parser ', i, ':', fMsg[0].AsString);
    end;
    FreeAndNil(fMsg);
    // // Отправка заданий через очередь  сообщений
    for i := 0 to Pred(cPagesCount) do begin
      fMsg := TzmqMessage.Create;
      fMsg.Add.AsString := 'Parse'; // "Задание"
      fMsg.Add.AsInteger := i; // Параметр "Задания", в данном случае - № страницы
      fParserSocket.Send(fMsg);
    end;
    for i := 0 to Pred(cPagesCount) do begin // Отправка задания
      fMsg := TzmqMessage.Create;
      fMsg.Add.AsString := 'Parse'; // "Задание"
      fMsg.Add.AsInteger := i; //Параметр - № страницы
      fParserSocket.Send(fMsg);
    end;
    // Ждем завершения работы по парсингу страниц
    for i := Pred(cPagesCount) downto 0 do begin 
     fParserSocket.Recv(fMsg);
      Writeln('Parser ', fMsg[1].AsInteger, ' - ', fMsg[0].AsString );
    end;

  finally
    FreeAndNil(fMsg);
    FreeAndNil(fCtx);
  end;

end;

begin
  doIt();
  Readln;
end.