Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Estoy aprendiendo multi-threading y me encontré con este post en SO. Executor simplemente ejecuta cosas que le damos. ExecutorService agrega inicio, cierre y la capacidad de esperar y ver el estado de los trabajos que hemos enviado para su ejecución, todo sobre Executor (del cual extiende). Aún estoy tratando de . . . Read more
¿Por qué solo veo el controlador en la pestaña “Executor” de SparkUI y no los ejecutores también?
Quiero alguna forma de que beforeExecute() se ejecute en el hilo principal antes de la ejecución de un hilo cada vez: Tengo el siguiente ThreadPoolExecutor: public class ContextAwareThreadPool extends ThreadPoolExecutor { public ContextAwareThreadPool(int corePoolSize, int maximumPoolSize, long keepAliveTime, @NotNull TimeUnit unit, @NotNull BlockingQueue<Runnable> workQueue, @NotNull ThreadFactory threadFactory, @NotNull RejectedExecutionHandler handler) . . . Read more
Tengo que hacer consultas a un montón de puntos finales. Cada punto final tiene un montón de consultas que deben ejecutarse en intervalos diferentes. Estoy tratando de decidir si usar un solo ScheduledThreadPoolExecutor o asignar ExecutorServices separados a cada punto final. Aquí está cómo veo el compromiso. Un solo ExecutorService: . . . Read more
No pude encontrar ningún ejecutor que cumpla con mis requisitos. Quiero tener un ExecutorService con un tamaño de núcleo (corePoolSize), un tamaño máximo (maximumPoolSize) y una BlockingQueue. Cuando se llama a la función “execute”, como de costumbre, se utiliza un hilo principal (core thread). Si los hilos principales están ocupados, . . . Read more