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 capturar correctamente las Exenciones de Runtime de los Ejecutores?

Di que tengo el siguiente código:

Ejecutor y Daemon en Java

Tengo un objeto MyThread que ejemplifico cuando mi aplicación se carga a través del servidor, lo marqué como un hilo Daemon y luego llamo

Llamar a Looper más de una vez provoca "el envío de un mensaje a un controlador en un hilo muerto"

Estoy usando un Ejecutor [grupo de subprocesos fijo] con mi propio ThreadFactory que agrega un Looper: Handler HANDLER = new Handler(); Executor THREADS = Executors.newFixedThreadPool(THREAD_POOL_SIZE, new ThreadFactory() { @Override public ...

Implementación elegante de indicadores de longitud de cola para ExecutorServices

¿Por qué? ¿Por qué no?java.util.concurrent proporcionar indicadores de longitud de cola para suExecutorServices? Recientemente me encontré haciendo algo como esto: ExecutorService queue = Executors.newSingleThreadExecutor(); ...

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

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 ...

¿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 ...

¿ThreadPoolExecutor se bloquea cuando la cola está llena?

Estoy tratando de ejecutar muchas tareas usando un ThreadPoolExecutor. A continuación se muestra un ejemplo hipotético: def workQueue = new ArrayBlockingQueue<Runnable>(3, false) def threadPoolExecutor = new ThreadPoolExecutor(3, 3, 1L, ...

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 ...