Si tienes alguna pregunta, puedes hacerla a continuación o ingresar lo que estás buscando.
Tengo una clase Java que utiliza ScheduledThreadPoolExecutor para ejecutar un trabajo. He intentado escribir una prueba de unidad con mockto, pero no está llamando al método run del objeto Runnable. Ejemplo: class MyExecutor { ScheduledThreadPoolExecutor stp = new ScheduledThreadPoolExecutor(); public void start() {// cómo escribir una prueba junit stp.scheduleAtFixedRate(executeRunnable(), 2,2, . . . Read more
Estoy utilizando Python ‘ThreadPoolExecutor’ para ejecutar mis tareas en paralelo. import concurrent.futures, time poolx = concurrent.futures.ThreadPoolExecutor(max_workers=2) poolx.submit(time.sleep, 3) poolx.submit(time.sleep, 3) poolx.submit(time.sleep, 3) poolx.submit(time.sleep, 0) # muy rápido Quería saber: ¿Cuántas tareas están en estado en cola o pendientes? ¿Cuántas tareas están en estado de ejecució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 una aplicación FastAPI que tiene una API que necesita ejecutar algunas tareas en paralelo. He implementado threadpoolexecutor y está funcionando bien. El único problema es que cada vez que llega una solicitud a esa API y la ejecución llega al threadpool executor, crea nuevos hilos en lugar de usar . . . Read more