Estoy luchando con la mejor manera de implementar mi canal de procesamiento. Mis productores alimentan el trabajo a un BlockingQueue. Del lado del consumidor, sondeé la cola, envolví lo que obtengo en
Considere un BlockingQueue y algunos hilos esperando en poll(long, TimeUnit) (posiblemente también en take()). Ahora la cola está vacía y se desea notificar a los hilos de espera que pueden dejar de e
Supongamos que tengo una tarea que está extrayendo elementos de un java.util.concurrent.BlockingQueue y procesándolos. public void scheduleTask(int delay, TimeUnit timeUnit)
{
scheduledExecutorS