- Spring4D
- DUnitX
- Bus de mensajes
10.4.1 debido a que se han resuelto problemas de las librerías parallel utilizadas en el proyecto
- El proyecto está en sus comienzos
- Testeando las partes básicas
- Partial High Level Petri Net
- Evolución de tokens coloreados (arrastran valores) y de tokens de sistema (no arrastran valores)
- Multiples disparos de transiciones concurrentes
- Transiciones condicionadas, hay condiciones a cumplir y acciones a ejecutar en caso de que la transición se dispare
- Arcos inhibidores y arcos de reset
- Superplazas: plazas que contienen a otras plazas y provocan una herencia de comportamientos
- Capacidad finita de la red de petri
- terminar unittesting del core: integración eventos
- ampliar core: logging, debugging, persistencia de configuracion
- capas posteriores al core
Es un bus de mensajes (eventos) basado en el patrón publicador/subscriptor
- Basado en interfaces. Todos los mensajes implementan la interface IEvento. Lo normal es que los nuevos mensajes hereden de TEvento
- No se realiza clonación de los mensajes al estar basado en interfaces, ni requiere de una destrucción explícita de los mismos.
- Thread Safe
- Qué es el canal:
- equivalente a un threadpool especializado en la distribución de mensajes a los listeners
- puede tener 1 ó 'n' threads
- se identifican por un nombre
- Los subscriptores:
- se subscriben a un canal, ya sea a uno de los existentes o a uno nuevo customizado
- se subscriben a un tipo de mensaje (con genéricos), ya sea al tipo base o también al base y heredados (configuración)
- pueden filtrar los mensajes para quedarse solo con aquellos de su interés
- pueden configurar la ejecución de la recepción del mensaje: a. en el main thread b. en el thread del bus de mensajes
- se configura un método que se llamará cuando un mensaje del tipo
- Algoritmo:
- Cuando se subscribe un listener a un canal (solo puede subscribirse a un canal), se subscribe implicitamente a todos los threads del mismo
- Cuando se hace un post de un mensaje: a. se pasa el mensaje a todos los canales creados b. en cada canal se elige uno de sus threads como transmisor de dicho mensaje, normalmente al que menos mensajes haya transmitido c. el thread seleccionado recorre todos los listeners y a aquellos que estén subscritos a ese tipo de mensaje se les pasa el mensaje d. el listener puede tener un filtro, por lo que al recibir el mensaje si pasa dicho filtro finalmente se ejecuta el método
- Uso:
- Registrar un canal nuevo:
EventoBus.RegisterChannel('Channel 1', 2); // con 2 threads de trabajo
- Publicar un mensaje:
// Definir evento, en este caso transporta un integer TTestEventoInteger = class(TEvento) public Valor: Integer; constructor Create(const AValue: Integer); overload; end; //en codigo procedure TForm2.Button1Click(Sender: TObject); var LMsg: IEvento; begin LMsg := TTestEventoInteger.Create(5); LMsg.Post; end;
- Definir el subscriptor al tipo de mensaje
//definicion del listener, en la clase donde queremos subscribirnos al mensaje TForm2 = class(TForm) private ... FListenerInteger : IMessageListener; //interface que define un subscriptor ... //en el create de la clase FListenerInteger := TEventoListener<TTestMessageInteger>.Create(DoOnEventoRecibido, DoOnEventoRequiereFiltrado, DPNCore.CHANNEL_SINGLE_THREADED); FListenerInteger.IsCodeToExecuteInUIMainThread := True; //se va a ejecutar en el main thread //en la clase tendremos estos métodos procedure TForm2.DoOnEventoRecibido(AMsg: IMessage); begin Memo1.Lines.Add(LogTime + 'Integer: ' + TTestEventoInteger(AMsg).Valor.ToString) end; function TForm2.DoOnEventoRequiereFiltrado(AMsg: IMessage): boolean; begin Result := (TTestEventoInteger(AMsg).Valor > 0) end;
- Registrar un canal nuevo: