¿Es posible lanzar una excepción si no se puede manejar la solicitud entrante?
Entonces, tengo un grupo de subprocesos fijos:
private val executor: ThreadPoolExecutor = Executors.newFixedThreadPool(4) as ThreadPoolExecutorY no quiero que las solicitudes vayan a la cola de subprocesos si no se pueden manejar, solo quiero lanzar una excepción.
Estoy tratando de verificar activeCount y lanzar una excepción si es mayor que el tamaño máximo del grupo, pero no funciona como yo quiero.
private fun checkPoolSize() { if (executor.activeCount >= 4) { throw RuntimeException("Request can't be handled. ") } }Una solución para esto es usar una cola de capacidad 0 y java.util.concurrent.ThreadPoolExecutor.AbortPolicy como RejectedExecutionHandler .
Los métodos estáticos en Executors no exponen el conjunto completo de parámetros que desea para esto, por lo que deberá crear una instancia de ThreadPoolExecutor directamente. En tu caso, podrías usar lo siguiente:
new ThreadPoolExecutor(4, /* Core pool size */ 4, /* Max pool size */ 0, TimeUnit.SECONDS, /* Core th. keep-alive */ new MyQueue<Runnable>(0), /* No queueing allowed */ Executors.defaultThreadFactory(), /* default */ new AbortPolicy()) /* throws when all core threads busy */Algunas notas:
Executors.newFixedThreadPool(4) .Executors.defaultThreadFactory() es la fábrica de subprocesos predeterminada, igual que cuando se usa Executors.newFixedThreadPool(4) .MyQueue es una implementación de BlockingQueue que acepta 0 como una capacidad (es decir, que solo puede estar vacía. Esto, por supuesto, no es una cola, pero su implementación permite una integración perfecta con ThreadPoolExecutor proporcionado por JDK).Consideración adicional :
Con un ajuste tan fino de su grupo de subprocesos, tenga en cuenta que el rendimiento será limitado. Aquí, considerando 4 subprocesos y una latencia promedio L en segundos para las tareas enviadas al grupo de subprocesos, el rendimiento promedio permitido por esta configuración es 4/L tareas/segundo.
Puede usar una política de saturación que entra en juego cuando su cola limitada se llena. Puede establecer una política de saturación llamando a setRejectedExecutionHandler() de ThreadPoolExecutor . Las implementaciones listas para usar son AbortPolicy , CallerRunsPolicy , DiscardPolicy y DiscardOldestPolicy . AbortPolicy es el valor predeterminado que lanza RejectedExecutionException cuando la cola delimitada se llena. También puede proporcionar su propia implementación personalizada.