Я использую OmniThreadLibrary для реализации фонового конвейера для отправки электронных писем (см. этот SO вопрос). Я заметил, что после закрытия приложения оно продолжает работать в фоновом режиме (видно в диспетчере задач Windows). Это означает, что в моем коде что-то не так с тем, как я реализовал конвейер OTL. Можете ли вы помочь мне определить неисправность?
Код следует:
unit uEmailQueue;
interface
uses Classes, OtlCommon, OtlCollections, OtlParallel, Windows;
type
TEmailServer = record
SMTPHost: String;
SMTPPort: Integer;
SMTPUseSSL: Boolean;
SMTPUserName: String;
SMTPPassword: String;
SMTPSenderName: String;
end;
TEmailMessage = record
RecipientEmailAddr: String;
EmailSubject: String;
EmailMessage: String;
end;
TEmailQueue = class(TObject)
private
FEmailServer: TEmailServer;
FPipeline: IOmniPipeline;
procedure SendEmailStage(const input, output: IOmniBlockingCollection);
public
constructor Create;
destructor Destroy; override;
procedure SendEmail(AEmailMessage: TEmailMessage);
end;
implementation
{ TEmailQueue }
procedure TEmailQueue.SendEmailStage(const input, output: IOmniBlockingCollection);
var
mailmessage: TOmniValue;
begin
for mailmessage in input do
begin
Beep(3700, 1500); // just some dummy code for now
end;
end;
constructor TEmailQueue.Create;
begin
FPipeline := Parallel.pipeline.Stage(SendEmailStage).Run;
end;
destructor TEmailQueue.Destroy;
begin
inherited;
end;
procedure TEmailQueue.SendEmail(AEmailMessage: TEmailMessage);
begin
FPipeline.input.Add(TOmniValue.FromRecord(AEmailMessage));
// FPipeline.input.CompleteAdding;
// FPipeline.WaitFor(INFINITE);
end;
end.
Я инициализирую и вызываю вышеуказанный класс следующим образом:
В событии OnCreate основной формы приложения:
FEmailQueue := TEmailQueue.Create;
Кнопка на главной форме имеет это в событии OnClick:
var
em: TEmailMessage;
begin
FEmailQueue.SendEmail(em);
позже я освобождаю класс в событии OnDestroy основной формы:
FEmailQueue.Free;
