Resultados de la búsqueda a petición "executorservice"
Grupo de subprocesos dinámicos
Tengo un proceso de larga ejecución que escucha eventos y realiza un procesamiento intenso. Actualmente usoExecutors.newFixedThreadPool(x) para limitar la cantidad de trabajos que se ejecutan simultáneamente, pero dependiendo de la hora del día ...
ExecutorService, cómo esperar a que finalicen todas las tareas
¿Cuál es la forma más sencilla de esperar todas las tareas deExecutorService ¿para terminar? Mi tarea es principalmente computacional, por lo que solo quiero ejecutar una gran cantidad de trabajos, uno en cada núcleo. En este momento ...
Cómo elegir un ejecutor para CompletableFuture :: supplyAsync
CompletableFuture::supplyAsync(() -> IO bound queries) ¿Cómo elijo un ejecutor para CompletableFuture :: supplyAsync para evitar contaminar elForkJoinPool.commonPool(). Hay muchas opciones enExecutors (newCachedThreadPool, ...
¿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 ...
Cómo verificar si todas las tareas que se ejecutan en ExecutorService se han completado
Tengo ConcurrentLinkedDeque, que estoy usando para elementos push / pop sincrónicos, y tengo algunas tareas asíncronas que toman un elemento de la pila y si este elemento tiene vecinos, lo empuja a la pila. Código de ejemplo: private ...
¿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, ...
Java: cómo obtener subprocesos terminados para recoger tareas de subprocesos en ejecución
Estoy trabajando en una aplicación multiproceso con tareas que tienen tiempos de ejecución variables. Cuando finaliza un subproceso, ¿hay alguna forma de que se haga cargo de algunas tareas de un subproceso que aún se está ejecutando? Aquí hay ...
¿Cómo esperar un hilo que genera su propio hilo?
Estoy tratando de probar un método que funciona en un hilo separado, simplificado es así: public void methodToTest() { Thread thread = new Thread() { @Override public void run() { Clazz.i = 2; } }; thread.start(); }En mi prueba unitaria, ...
Cómo atrapar excepciones en FutureTask
Después de encontrar esoFutureTask corriendo en unExecutors.newCachedThreadPool() en Java 1.6 (y desde Eclipse) traga excepciones en elRunnable.run() método, he tratado de encontrar una manera de atraparlos sin agregar throw / catch a todos ...
ExecutorService que ejecuta tareas en el hilo de llamada?
¿Hay algunajava.util.ExecutorService implementaciones que simplemente ejecutan todas las tareas ejecutadas en el hilo de llamada? Si esto no está incluido en Java por defecto, ¿hay una biblioteca que contenga una implementación como esta?