Недопонимаю про потоки. Как их можно "скрещивать"?

[Ship_1]

Здравствуйте.
Вот, например, я сделал программку для получения инфы про два принтера через веб-интерфейс. В одной процедуре я получаю очередь печати. Параметром в процедуру передаю IP принтера. Одна процедура у меня работает для двух принтеров.
Чтоб это всё не зависало, пока идёт получение информации, решил получение очереди перенести в поток.
Правильно ли я понимаю, что в потоках, в отличие от основного кода, информацию о двух принтерах я могу получать "параллельно"? Но тогда я уже не смогу обойтись одной процедурой - для каждого принтера придётся создавать свою, дублировать её в каждом потоке? Или как-то можно процедуру всё-таки оставить одну и вызывать её из двух потоков со своими параметрами?
Или я могу создать два экземпляра одного потока и запускать со своими параметрами, и это будет нормально?
И ещё недопонимаю про синхронизацию. Она нужна, если необходима строгая параллельность работы потока (потоков) и программы либо нескольких потоков? В моём случае она не нужна?
И ещё, в процедуре/функции можно сделать необязательный параметр со значением по умолчанию, например

... printer_nom:string = '90' ...

А как это сделать для потока?

[Alex11223]

Сообщение от Ship_1

Или как-то можно процедуру всё-таки оставить одну и вызывать её из двух потоков со своими параметрами?

Да. Только желательно чтобы она не взаимодействовала с чем-либо из других потоков (например, не писала что-то на форме), а просто выполняла запрос и возвращала результат. Ну или тогда придется синхронизировать это (TCriticalSection, ...).

Сообщение от Ship_1

А как это сделать для потока?

так же? смотря что вы имеете в виду под потоком. Если экземпляр класса наследника TThread, то просто в конструктор это можно добавить, ну и поле в классе.

  TPrinterStatusLoaderThread = class(TThread)
  private
    FPrinterNumber: string;
  protected
    procedure Execute; override;
  public
    constructor Create(PrinterNumber: string = '90', CreateSuspended: Boolean = true);
  end;

...

constructor TPrinterStatusLoaderThread.Create(PrinterNumber: string = '90', CreateSuspended: Boolean = true);
begin
  inherited Create(CreateSuspended);

  FPrinterNumber := PrinterNumber;
end;

Результат работы потока тоже можно получать из public поля/свойства (заносить туда при получении инфы, читать в основном потоке после завершения), или событие/callback вызывать.

[Pavia]

Локальные переменные и параметры у каждого потока свои. Код дублировать не надо.

Или я могу создать два экземпляра одного потока и запускать со своими параметрами, и это будет нормально?

Именно так всё и работает.

И ещё недопонимаю про синхронизацию. Она нужна, если необходима строгая параллельность работы потока (потоков) и программы либо нескольких потоков? В моём случае она не нужна?

Если строгая, то не нужна. Но это недостижимый идеал. Веб-мора у вас общая для двух потоков. Поэтому от синхронизации вы никуда не денятись.

[Alex11223]

Сообщение от Pavia

Веб-мора у вас общая для двух потоков. Поэтому от синхронизации вы никуда не денятись.

И? Это ж ее проблемы, а не клиента.

[Ship_1]

Смотрю про потоки здесь. Как понял - синронизация забирает себе выполнение кода "засинхронизированной" процедуры до тех пор, пока она не выполнится? Или это только из-за "WaitFor", который необязателен?
В примере с синхронизацией уничтожение потоков происходит "вручную" и в теле execute потока. При этом переменные потока, судя по всему, глобальные. Мне глобальные не нужны. Можно ли их уничтожать в теле процедуры, из которой они записаны (типа bt1Click)?
У меня в потоке будет выполняться три процедуры:
1. Получение текста с веб-страницы (допустим, Proc1)
2. Обработка результата (Proc2)
3. Вывод результата на форму (Proc3).
Правильно ли я понимаю, что мне нужно

synchronize(Proc1);
Proc2;
synchronize(Proc3);

(процедура 2 ни с чем, кроме себя, не связана, поэтому её можно не синхронизировать)

[Ship_1]

Сообщение от Alex11223

И? Это ж ее проблемы, а не клиента.

А одновременное обращение к разным адресам через WinInt не вызывает ошибки?

[Alex11223]

Сообщение от Ship_1

к разным адресам через WinInt не вызывает ошибки?

Смотря как, но вообще нет.

Сообщение от Ship_1

Можно ли их уничтожать в теле процедуры, из которой они записаны (типа bt1Click)?

Зачем? Можно ж просто FreeOnTerminate:=true поставить.

Сообщение от Ship_1

Вывод результата на форму (Proc3).

Лучше это делать в самой форме после завершения, как выше написано.

[Ship_1]

Сообщение от Alex11223

Зачем? Можно ж просто FreeOnTerminate:=true поставить.

У меня создалось впечатление, что если у потока есть свойства, которым надо присвоить значение, то нужно сначала создать экземпляр потока, потом присвоить ему значения параметров, а потом уже запустить "вручную". И подумал, почему-то, что и уничтожать, соответственно, в этом случае нужно тоже вручную.

[Ship_1]

A execute у процесса обязательно должна быть процедурой или может быть функцией? Если только процедурой, то как грамотно "вывести" StringList из потока? Пока у меня этот процесс был в функциях и процедурах, я создавал StringList в функции, присваивая переменной значение этой функции, а уничтожал в основном коде после обработки. А как быть с потоком? Работать в нём со StringList можно, сделав StringList его полем. Но после завершения потока ведь и его поля уничтожаются. Или как раз для этого и существует уничтожение вручную: сначала обработать результаты, а потом уничтожить из основного кода?
И можно ли делать автоуничтожение, если пользоваться >вот такой< "конструкцией"? В этом случае сначала срабатывает процедура не потока, но вызванная в потоке, а автоуничтожение срабатывает только после её завершения, не смотря на то, что процедура не из потока?

[Alex11223]

Даже если бы он был функцией, это не помогло бы.
Я ж выше писал как.

Кстати, а почему Proc1 нужна синхронизация?


Вот более полный пример с callback (рядом код валялся, не помню почему использовал колбэк вместо события, и не помню как в Дельфи создавать события).

type
  TCallbackProc = procedure(PrinterNumber: string, Status: string, Error: Exception) of object;

  TPrinterStatusLoaderThread = class(TThread)
  private
    FPrinterNumber: string;
    FCallbackProc: TCallbackProc;
    FStatus: string;
    FError: Exception;
    procedure HandleTerminate;
  protected
    procedure Execute; override;
    procedure DoTerminate; override;
  public
    constructor Create(CallbackProc: TCallbackProc, PrinterNumber: string = '90', CreateSuspended: Boolean = true);
  end;

...

constructor TPrinterStatusLoaderThread.Create(CallbackProc: TCallbackProc, PrinterNumber: string = '90', CreateSuspended: Boolean = true);
begin
  inherited Create(CreateSuspended);

  FCallbackProc := CallbackProc;
  FPrinterNumber := PrinterNumber;
end;

procedure TZagryzkaThread.Execute;
begin
  try
    FStatus := GetPrinterStatus(FPrinterNumber);
  except on ex: Exception do
    begin
      FError := Exception.Create(ex.Message);
    end;
  end;
end;

procedure TPrinterStatusLoaderThread.DoTerminate;
begin
  Synchronize(HandleTerminate);
end;

procedure TPrinterStatusLoaderThread.HandleTerminate;
begin
  FCallbackProc(FPrinterNumber, FStatus, FError);
end;

TMyForm.....
......
private
    procedure PrinterThreadCallback(PrinterNumber: string, Status: string, Error: Exception);

.......


procedure TMyForm.PrinterThreadCallback(PrinterNumber: string, Status: string, Error: Exception);
begin
  if error = nil then
  begin
    ShowStatus(PrinterNumber, Status)
  end
  else
  begin
    ShowErrorMessage(error.Message);
  end;
end;


TMyForm.StartBtnClick.....
.....
  thread1 := TPrinterStatusLoaderThread.Create(PrinterThreadCallback);
  thread1.FreeOnTerminate := true;
  thread1.Resume;
  
  thread2 := TPrinterStatusLoaderThread.Create(PrinterThreadCallback, '42');
  thread2.FreeOnTerminate := true;
  thread2.Resume;