¿JBoss Drools realmente ejecuta todas las reglas en paralelo?

Question

He leído mucha documentación de JBoss Drools, pero no puedo encontrar una respuesta definitiva si todas las reglas son ejecutadas al mismo tiempo (sin duda son disparadas concurrentemente). Más específicamente, para una sola entrada y un conjunto de reglas de digamos 1000, las condiciones "cuándo" y las condiciones "entonces" en cada regla se ejecutan secuencialmente una por una o en paralelo al mismo tiempo.

Por un lado, el algoritmo rete implica paralelismo, ciertamente cuando los nodos seleccionados se contraen. Sin embargo, una vez optimizados los nodos, ¿la evaluación es secuencial? Y la memoria beta y los nodos de unión parecen que deberían ejecutarse al mismo tiempo, pero ¿verdad?

Además, la documentación de Drools habla de "modo secuencial", diciendo que esto está desactivado por defecto. Entonces, ¿qué está activado, modo paralelo? Y hay una opción maxThreads que implica enhebrar.

Por otro lado, me dijeron que el código no utiliza el subprocesamiento, por lo que se evalúa al mismo tiempo pero se ejecuta, en su mayor parte de forma secuencial.

¿Alguien ha visto alguna documentación que muestre el caso de alguna manera?

Gracias!

Answer 1

No hay indicación de paralelismo en el algoritmo de rete estándar. Un conjunto de conflictos se produce a partir de reglas coincidentes, luego la agenda aplica una estrategia para activar esas reglas a su vez.

A lo largo de los años se han realizado varios esfuerzos para paralelizar las partes de la rete, ya sea durante las etapas de emparejamiento o disparo.

Un gran problema al disparar todas las reglas en paralelo es la ejecución determinista.

Actualmente estamos explorando varias estrategias para la coincidencia concurrente y paralela, en Drools. También exploraremos el lanzamiento simultáneo de reglas, pero debemos encontrar formas más sólidas para que los usuarios indiquen qué se puede disparar en paralelo y qué no; para que el usuario obtenga una ejecución determinista donde lo necesite.

Answer 2

Parece que ha resuelto el problema, pero aún puedo brindarle más información si lo necesita. Hay una biblioteca simultánea utilizada en el código fuente de Drools, se muestra el enlace web de github, https://github.com/kiegroup/drools/blob/master/drools-core/src/main/java/org/drools/core/concurrent/ExecutorProviderImpl.java.

Algunos puntos,

1. Claro, la fábrica de hilos se utiliza en el ejecutor operación. Y puede encontrar la biblioteca de hilos si lee el código fuente que se muestra en este enlace web.

2. También preguntas sobre maxThread, el threadpool usado en Drools tiene un tamaño de grupo como se muestra en el código fuente. newExecutor = new ThreadPoolExecutor(Pool.SIZE, Pool.SIZE, 60L, TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(), threadFactory);