private void filterStaleObjects()

in edas-demo/observability-demo/prometheus-demo/src/main/java/com/alibabacloud/edas/exporter/PrometheusExporter.java [111:128]

• 15 lines of code
• 3 McCabe index (conditional complexity)

    private void filterStaleObjects() {
        Collection<ThreadPoolMonitorObject> filtered = monitoringThreadPools
                .stream()
                .filter(object -> ! object.isStale())
                .collect(Collectors.toList())
        ;

        if (filtered.size() == monitoringThreadPools.size()) {
            return;
        }

        try {
            writeSafeBlock(() -> monitoringThreadPools = filtered);
        } catch (Exception e) {
            logger.warn("Reset monitoring objects after filtered error.", e);
        }

    }