Tenho a seguinte questão:
1 - Tenho uma rotina que percorre um banco de dados, que tem informações de arquivos que precisam sem escritos, poderá ter até 100 cadastros.
2 - A aplicação precisa percorrer registro a registro, e coletar as informações, e escrever os arquivos.
3 - O arquivos a serem escritos podem ser grande tamanho.
4 - Precisam ser escritos sequencialmente, ou seja a cada arquivo escrito, dai então a aplicação irá para o próximo.
Desenvolvi o código abaixo usando Thread.
Problemas:
1 - Da forma que está todos os JOBs, são executados ao mesmo tempo, coisa que conforme percebi, não poderá acontecer, pois se o banco de dados for muito grande, o consumo de memória por JOB, fica imenso.
Eu preciso que mesmo que esteja usando o conceito de paralelismo da Thread, esta rotina funcione serializada, ou seja, registro a registro, somente quando uma Thread terminar, a outra poderá começar.
Tentei utilziando WaitFor, mas como ele está no processo principal travou a aplicação, coisa que não pode acontecer.
Tentei várias possibilidades mas não consegui, alguém poderia dar uma dica de como fazer isso? Executar a Thread sequencialmente, porem com o paralelismo?
while not dm.quArquivos do
begin
nControleThreads := nControleThreads + 1;
thEscreveArquivo:= tEscreveArquivo.Create(True);
thEscreveArquivo.sDriverId := dm.quBancoTIPO_BANCO.AsString;
thEscreveArquivo.sDataBase := dm.quBancoDATABASE.AsString;
thEscreveArquivo.sOwner := dm.quBancoOWNER.AsString;
thEscreveArquivo.sServer := dm.quBancoSERVIDOR.AsString;
thEscreveArquivo.sipserver := dm.quBancoIP.AsString;
thEscreveArquivo.sPort := dm.quBancoPORTA.AsString;
thEscreveArquivo.sCharacterSet := 'utf8';
thEscreveArquivo.sUserName := dm.quBancoUSUARIO.AsString;
thEscreveArquivo.sPassWord := dm.quBancoSENHA.AsString;
thEscreveArquivo.sTodosDatabase :=
dm.quBancoTODOS_DATABASE.AsString;
thEscreveArquivo.sNomeArquivo := sNomeArquivoOrigem;
thEscreveArquivo.sNomeArquivoZip := sNomeArquivoZipDestino;
thEscreveArquivo.sSenhaCritpoGrafia :=
dm.quConfigsenha_criptografia.AsString;
thEscreveArquivo.sAlias := dm.quBancoALIAS.AsString;
thEscreveArquivo.sCaminho := sCaminho;
thEscreveArquivo.IidBanco := dm.quBancoID.AsInteger;
thEscreveArquivo.FreeOnTerminate := True;
thEscreveArquivo.OnTerminate := ControleThreads;
thEscreveArquivo.Start;
Sleep(2000);
dm.quArquivos.Next;
end;