Versões comparadas
Chave
- Esta linha foi adicionada.
- Esta linha foi removida.
- A formatação mudou.
Informações | ||
---|---|---|
| ||
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:
|
SetThreads()
Descrição: Inicializa o número de threads para execução da fila. Sintaxe: SetThreads(nThreads)->Return Parâmetros:
|
SetEnvironment()
Descrição: Inicializa as variáveis para montagem do ambiente. Sintaxe: SetEnvironment( cEnvironment ) -> Return Nil Parâmetros:
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:
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:
|
Start()
Descrição: Inicializa a execução da fila. Sintaxe: Start(cFunction)→Return Parâmetros:
|
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:
|
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 Retorno: |
Bloco de código | ||||||
---|---|---|---|---|---|---|
| ||||||
#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 | ||||
---|---|---|---|---|
|