Skip to main content
Bumped by Community user

Bom dia pessoal, TenhoTenho a seguinte questão  : 1 )

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 - )

2 - A aplicação precisa percorrer registro a registro, e coletar as informações, e escrever os arquivos. 3 - )

3 - O arquivos a serem escritos podem ser grande tamanho. 4 - )

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 - )

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.

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;

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;

Bom dia pessoal, 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.

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;

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.

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;
Fonte Link
Mano
  • 67
  • 1
  • 4

Executar Thread serializada

Bom dia pessoal, 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;