Spring Integration Executor Channel utilizando código de anotaciones de muestra

Mi diagrama del sistema está adjunto. Sistema de diagram [https://i.stack.imgur.com/tEZYn.png] CÓMO FUNCIONA EL FLUJO: El flujo de integración de primavera lee la entrada de un archivo json en C: \ y realiza 2 acciones: Almacenar en DB ...

Cómo detener la ejecución del siguiente subproceso en un ScheduledThreadPoolExecutor

Tengo un ScheduledThreadPoolExecutor que tiene un hilo y se ejecuta por cada 30 segundos. Ahora, si el subproceso actual en ejecución arroja alguna excepción, entonces debo asegurarme de que el siguiente subproceso no se ejecute y que ...

¿Cómo es una recurrencia de terminación de ejecutor en Java?

Este es un programa que lee el sitio de información para el formato anterior, utiliza recursividad y ejecutor. Funciona bien, mi problema es probar si el programa se completó y la notificación de éxito. public class NewClass { static String ...

Múltiples hilos que escriben en el mismo CSV en Python

Soy nuevo en multi-threading en Python y actualmente estoy escribiendo un script que se agrega a un archivo csv. Si tuviera que enviar varios hilos a unconcurrent.futures.ThreadPoolExecutor que agrega líneas a un archivo csv. ¿Qué podría hacer ...

Diferencia entre Executors.newFixedThreadPool (1) y Executors.newSingleThreadExecutor ()

¿Cuál es el tamaño óptimo de grupo de subprocesos para un programa simple que ejecuta tareas basadas en CPU en Java?

Estoy usando un grupo de subprocesos para ejecutar tareas, que en su mayoría están basadas en CPU con un poco de E / S, de tamaño uno mayor que el número de ...

Ejecutar una tarea en paralelo a otra tarea

Tengo los siguientes

Java precisión programada del ejecutor

Hay una peculiaridad que encontré al usar ejecutores programados de Java y me preguntaba si lo que experimenté es normal. Necesito programar tareas que se ejecuten a una velocidad predefinida de 5 segundos. Se espera que estas tareas demoren ...

ExecutorService rendimiento lento de subprocesos múltiples

Estoy intentando ejecutar un cálculo simple (llama aMath.random() 10000000 veces). Sorprendentemente, ejecutarlo en un método simple funciona mucho más rápido que usar ExecutorService. He leído otro hilo enl sorprendente punto de equilibrio ...

Pause ScheduledExecutorService

Estoy usando unaScheduledExecutorService para ejecutar una tarea que llama a un servicio a una tasa fija. El servicio puede devolver algunos datos a la tarea. La tarea almacena datos en una cola. Algunos otros hilos recogen lentamente elementos ...