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

Sintaxe:

Descrição:

Método construtor da classe.

Sintaxe:

New(cSemaphore, nTimeOut) - > Return

Descrição:

Método construtor da classe

Parâmetros:

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

SetThreads()

.

SetThreads(

nThreads

)

->Return

Descrição:
Inicializa o numero 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()

Sintaxe:

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.

SetNoErrorStop()

Retorno:

Não retorna valores explícitos.

Sintaxe:

SetNoErrorStop(

lNoStop

)

- >Return INoStop

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. deve parar " Ou ".T. não deve parar
Return:

AddThread()

." Para continuar.

Retorno:

Retorna indica se o sistema para ou continua.

Sintaxe:

AddThread()

->Return

Descrição:
Adiciona threads para fazer a execução.

RemoveThread()

Sintaxe:

RemoveThreadAddThread(lAll) - >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()

Sintaxe:

Start(cFunction)->Return

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.

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

Sintaxe:

HasThreadFree()->Return(lRetorno)

Descrição:

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

Go()

Sintaxe:

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

Descrição:

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

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

GetError()

Sintaxe:

GetError()->Return(::cError)

Descrição:

Recupera o erro ocorrido em uma das threads de processamento

GetMonitorStatus()

Sintaxe:

GetMonitorStatus()->Return(PadR(::oSemaphore:DirtyRead(::cMonitorID),THREAD_LENGHT_STATUS))

Descrição:

Recupera o status do Monitor

FreeThreads()

Sintaxe:

FreeThreads()->Return(nRet)

Descrição:

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

StopProcessOnError()

Sintaxe:

SetNoErrorStop(lNoStop)->Return lStop

Descrição:

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

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 21

Nova versão 22

Chave

New()

SetThreads()

SetThreads(

)

Descrição:
Inicializa o numero 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.

SetNoErrorStop()

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. deve parar " Ou ".T. não deve parar
Return:

AddThread()

AddThread()

Descrição:
Adiciona threads para fazer a execução.

RemoveThread()

RemoveThread()

Start()

Stop()

HasThreadFree()

Go()

GetError()

GetMonitorStatus()

FreeThreads()

StopProcessOnError()

Páginas filhas

Histórico da Página

Versões comparadas

Versão antiga 21

Nova versão 22

Chave

New()

SetThreads()

SetThreads(

)

Descrição:Inicializa o numero número de threads para execução da fila.Sintaxe:SetThreads(nThreads)->ReturnParâmetros:NomeTipoDescriçãonThreadsNumberIndica o numero de threads.

SetEnvironment()

Descrição:Inicializa as variáveis para montagem do ambiente.Sintaxe:SetEnvironment( cEnvironment ) - > Return NilParâmetros:NomeTipoDescriçãocEmpcharacterIndica qual a empresa será inicializadas.cFilcharacterIndica qual a filial será inicializadas.

SetNoErrorStop()

SetNoErrorStop(

)

Descrição:Especifica se o sistema deve parar em caso de erro.Sintaxe:SetNoErrorStop(lNoStop) - >Return INoStopParâmetros:NomeTipoDescriçãolNoStopBooleanIndica se o IPC deve parar em caso de erro ".F. deve parar " Ou ".T. não deve pararReturn:

AddThread()

AddThread()

Descrição:Adiciona threads para fazer a execução.

RemoveThread()

RemoveThread()

Start()

Stop()

HasThreadFree()

Go()

GetError()

GetMonitorStatus()

FreeThreads()

StopProcessOnError()

Descrição:
Inicializa o numero 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.

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.

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. deve parar " Ou ".T. não deve parar
Return:

Descrição:
Adiciona threads para fazer a execução.