Informações

title	Consumo de Recursos e Licenças

A classe gerência a abertura de threads de forma dinâmica, ajustando-se conforme a demanda de utilização. Isso significa que o consumo de memória e processamento no AppServer será proporcional à quantidade de threads ativas no momento. Sendo assim o consumo de licenças também pode ser impactado.

Informações

title	Disponibilidade

Classe disponível para utilização na lib 20241007 ou superior.

Descrição:

A classe FWIPCWait coordena o processamento entre threads, criando instâncias automaticamente que se iniciam de acordo com a disponibilidade dos servidores.

New()

Descrição:

Método construtor da classe.

Sintaxe:

New(cSemaphore, nTimeOut) - > Return

Parâmetros:

Nome	Tipo	Descrição
cSemaphore	character	identificar a fila de processamento.
nTimeOut	Number	Indica o tempo de time-out em milissegundos.

SetThreads()

Descrição:

Inicializa o número de threads para execução da fila.

Sintaxe:

SetThreads(nThreads)->Return

Parâmetros:

Nome	Tipo	Descrição
nThreads	Number	Indica o numero de threads.

SetEnvironment()

Descrição:

Inicializa as variáveis para montagem do ambiente.

Sintaxe:

SetEnvironment( cEnvironment ) -> Return Nil

Parâmetros:

Nome	Tipo	Descrição
cEmp	character	Indica qual a empresa será inicializadas.
cFil	character	Indica qual a filial será inicializadas.

Retorno:

Não retorna valores explícitos.

SetNoErrorStop()

Descrição:

Especifica se o sistema deve parar em caso de erro.

Sintaxe:

SetNoErrorStop(lNoStop) - >Return INoStop

Parâmetros:

Nome	Tipo	Descrição
lNoStop	Boolean	Indica se o IPC deve parar em caso de erro ".F. " Ou ".T." Para continuar.

Retorno:

Retorna indica se o sistema para ou continua.

AddThread()

Descrição:

Adiciona threads para fazer a execução.

Sintaxe:

AddThread() - >Return

RemoveThread()

Descrição:

Remove threads de execução.

Sintaxe:

RemoveThread(lAll) - >Return

Parâmetros:

Nome	Tipo	Descrição
lAll	Boolean	Força remover todas as threads de execução.

Start()

Descrição:

Inicializa a execução da fila.

Sintaxe:

Start(cFunction)→Return

Parâmetros:

Nome	Tipo	Descrição
cFunction	Character	Função inicia as threads de execução.

Retorno:

Não possui retorno explícito.

Stop()

Descrição:

Para a execução das threads de IPC e a de monitoramento.

Sintaxe:

FWIpcWait():Stop() → lRetorno

Retorno:

lRetorno → Logica, Indica sucesso na parada as threads da FWIpcWait.

HasThreadFree()

Descrição:

Indica se há threads de processamento livres para execução.

Sintaxe:

HasThreadFree()->Return(lRetorno)

Retorno:

Retorna .T. se houver threads livres, caso contrário retorna .F.

Go()

Descrição:

Envia uma requisição para uma thread agent, onde será processado uma lista de até 10 parâmetro de acordo com a função informada no método Start.

Sintaxe:

Go( uParm1, uParm2, uParm3, uParm4, uParm5, uParm6, uParm7, uParm8, uParm9, uParm10 )->Return(lRetorno)

Parâmetros:

Nome	Tipo	Descrição
uParm1	Indefinido
uParm2	Indefinido
uParm3	Indefinido
uParm4	Indefinido
uParm5	Indefinido
uParm6	Indefinido
uParm7	Indefinido
uParm8	Indefinido
uParm9	Indefinido
lRetorno	Boolean	Indica que a requisição não foi feita

Retorno:

Retorna .T. se a requisição foi feita com sucesso, caso não foi retorna .F.

GetError()

Descrição:

Recupera o erro ocorrido em uma das threads de processamento

Sintaxe:

GetError()->Return(::cError)

Retorno:

Descreve o tipo de erro ocorrido ou vazio caso não houver.

GetMonitorStatus()

Descrição:

Recupera o status do Monitor

Sintaxe:

GetMonitorStatus()→Return(PadR(::oSemaphore:DirtyRead(::cMonitorID),THREAD_LENGHT_STATUS))

Retorno:

Status atual em formato de sting.

FreeThreads()

Descrição:

Devolve a quantidade de threads de processamento livres para execução

Sintaxe:

FreeThreads()->Return(nRet)

Retorno:

Retorna a quantidade de threads livres

StopProcessOnError()

Descrição:

Especifica se o IPC deve ou não parar em caso de erro.

Sintaxe:

SetNoErrorStop(lNoStop)->Return lStop

Parâmetros:

Nome	Tipo	Descrição
lNoStop	Boolean	Define o comportamento em casos de erros

Retorno:

Define o comportamento para continuar retorna .T. e para finalizar retorna .F.

Bloco de código

language	js
theme	Midnight
title	Exemplo

#include "protheus.ch"

//---------------------------------------------------------------------
/*/{Protheus.doc} IPCTeste
Função para exemplo de uso da classe FWIPCWait

@author  FRAMEWORK
@since   11/09/2024
@version 1.0
/*/
//---------------------------------------------------------------------
User Function IPCTeste()
Local oIPC as object
Local nX as numeric
 
RpcSetEnv("99","01")
 
oIPC := FWIPCWait():New("TESTE",10000)
oIPC:SetThreads(1)
oIPC:SetEnvironment(cEmpAnt,cFilAnt)
oIPC:Start("U_IPCTEST2")

For nX := 1 To 1000
    oIPC:Go(nX)
Next nX

oIPC:Stop()

FreeObj(oIPC)
oIPC := Nil

Return

//---------------------------------------------------------------------
/*/{Protheus.doc} IPCTEST2
Função que será executada nas threads de exemplo da FWIpcWait

@author  FRAMEWORK
@since   11/09/2024
@version 1.0
/*/
//---------------------------------------------------------------------
User Function IPCTEST2(nX as numeric)
 
ConOut("Entrei...", nX, Time())
Sleep(2000)
ConOut("Saindo...", nX, Time())
 
Return

Templatedocumentos

HTML

<style>
div.theme-default .ia-splitter #main {
    margin-left: 0px;
}
.ia-fixed-sidebar, .ia-splitter-left {
    display: none;
}
#main {
    padding-left: 10px;
    padding-right: 10px;
    overflow-x: hidden;
}

.aui-header-primary .aui-nav,  .aui-page-panel {
    margin-left: 0px !important;
}
.aui-header-primary .aui-nav {
    margin-left: 0px !important;
}
</style>

Métodos:

Índice

maxLevel	15
printable	false

Páginas filhas

Versões comparadas

Versão antiga 39

Nova versão 40

Chave

New()

SetThreads()

SetEnvironment()

SetNoErrorStop()

AddThread()

RemoveThread()

Start()

Stop()

HasThreadFree()

Go()

GetError()

GetMonitorStatus()

FreeThreads()

StopProcessOnError()

Páginas filhas

Histórico da Página

Versões comparadas

Versão antiga 39

Nova versão 40

Chave

New()

SetThreads()

SetEnvironment()

SetNoErrorStop()

AddThread()

RemoveThread()

Start()

Stop()

HasThreadFree()

Go()

GetError()

GetMonitorStatus()

FreeThreads()

StopProcessOnError()