public class ProductCacheServiceImpl implements ProductCacheService {

    private ConcurrentSkipListSet<Long> queueIds = new ConcurrentSkipListSet<>();

    public void evictByProductIds(Iterable<Long> productIds) {
        productIds.forEach(queueIds::add);
    }

    @Scheduled(fixedDelay = 1000 * 20)
    public void processCacheEviction() {
        if (queueIds.isEmpty()) {
            return;
        }

        ArrayList<Long> productIds = new ArrayList<>();
        
        synchronized(queueIds) {
            while (!queueIds.isEmpty()){
                productIds.add(queueIds.pollFirst());
            }
        }

        cacheManager.findKeysByAttributeValues(FACETS_BY_IDS, FACETS_IDS_ATTRIBUTE, productIds).forEach(productFind::evict);
    }
}