diff --git a/quartz/src/main/java/com/vitorpamplona/quartz/utils/CacheOperations.kt b/quartz/src/main/java/com/vitorpamplona/quartz/utils/CacheOperations.kt
new file mode 100644
index 000000000..b1c9a9ccc
--- /dev/null
+++ b/quartz/src/main/java/com/vitorpamplona/quartz/utils/CacheOperations.kt
@@ -0,0 +1,173 @@
+/**
+ * Copyright (c) 2025 Vitor Pamplona
+ *
+ * Permission is hereby granted, free of charge, to any person obtaining a copy of
+ * this software and associated documentation files (the "Software"), to deal in
+ * the Software without restriction, including without limitation the rights to use,
+ * copy, modify, merge, publish, distribute, sublicense, and/or sell copies of the
+ * Software, and to permit persons to whom the Software is furnished to do so,
+ * subject to the following conditions:
+ *
+ * The above copyright notice and this permission notice shall be included in all
+ * copies or substantial portions of the Software.
+ *
+ * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR
+ * IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS
+ * FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR
+ * COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN
+ * AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
+ * WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
+ */
+package com.vitorpamplona.quartz.utils
+
+import java.util.function.BiConsumer
+
+interface CacheOperations<K, V> {
+    fun forEach(consumer: BiConsumer<K, V>)
+
+    fun size(): Int
+
+    fun filter(consumer: CacheCollectors.BiFilter<K, V>): List<V> {
+        val runner = CacheCollectors.BiFilterCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun filterIntoSet(consumer: CacheCollectors.BiFilter<K, V>): Set<V> {
+        val runner = CacheCollectors.BiFilterUniqueCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> map(consumer: CacheCollectors.BiNotNullMapper<K, V, R>): List<R> {
+        val runner = CacheCollectors.BiNotNullMapCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> mapNotNull(consumer: CacheCollectors.BiMapper<K, V, R?>): List<R> {
+        val runner = CacheCollectors.BiMapCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> mapNotNullIntoSet(consumer: CacheCollectors.BiMapper<K, V, R?>): Set<R> {
+        val runner = CacheCollectors.BiMapUniqueCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> mapFlatten(consumer: CacheCollectors.BiMapper<K, V, Collection<R>?>): List<R> {
+        val runner = CacheCollectors.BiMapFlattenCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> mapFlattenIntoSet(consumer: CacheCollectors.BiMapper<K, V, Collection<R>?>): Set<R> {
+        val runner = CacheCollectors.BiMapFlattenUniqueCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun maxOrNullOf(
+        filter: CacheCollectors.BiFilter<K, V>,
+        comparator: Comparator<V>,
+    ): V? {
+        val runner = CacheCollectors.BiMaxOfCollector(filter, comparator)
+        forEach(runner)
+        return runner.maxV
+    }
+
+    fun sumOf(consumer: CacheCollectors.BiSumOf<K, V>): Int {
+        val runner = CacheCollectors.BiSumOfCollector(consumer)
+        forEach(runner)
+        return runner.sum
+    }
+
+    fun sumOfLong(consumer: CacheCollectors.BiSumOfLong<K, V>): Long {
+        val runner = CacheCollectors.BiSumOfLongCollector(consumer)
+        forEach(runner)
+        return runner.sum
+    }
+
+    fun <R> groupBy(consumer: CacheCollectors.BiNotNullMapper<K, V, R>): Map<R, List<V>> {
+        val runner = CacheCollectors.BiGroupByCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> countByGroup(consumer: CacheCollectors.BiNotNullMapper<K, V, R>): Map<R, Int> {
+        val runner = CacheCollectors.BiCountByGroupCollector(consumer)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <R> sumByGroup(
+        groupMap: CacheCollectors.BiNotNullMapper<K, V, R>,
+        sumOf: CacheCollectors.BiNotNullMapper<K, V, Long>,
+    ): Map<R, Long> {
+        val runner = CacheCollectors.BiSumByGroupCollector(groupMap, sumOf)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun count(consumer: CacheCollectors.BiFilter<K, V>): Int {
+        val runner = CacheCollectors.BiCountIfCollector(consumer)
+        forEach(runner)
+        return runner.count
+    }
+
+    fun <T, U> associate(transform: (K, V) -> Pair<T, U>): Map<T, U> {
+        val runner = CacheCollectors.BiAssociateCollector(size(), transform)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <T, U> associateNotNull(transform: (K, V) -> Pair<T, U>?): Map<T, U> {
+        val runner = CacheCollectors.BiAssociateNotNullCollector(size(), transform)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <U> associateWith(transform: (K, V) -> U?): Map<K, U?> {
+        val runner = CacheCollectors.BiAssociateWithCollector(size(), transform)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun <U> associateNotNullWith(transform: (K, V) -> U): Map<K, U> {
+        val runner = CacheCollectors.BiAssociateNotNullWithCollector(size(), transform)
+        forEach(runner)
+        return runner.results
+    }
+
+    fun joinToString(
+        separator: CharSequence = ", ",
+        prefix: CharSequence = "",
+        postfix: CharSequence = "",
+        limit: Int = -1,
+        truncated: CharSequence = "...",
+        transform: ((K, V) -> CharSequence)? = null,
+    ): String {
+        val buffer = StringBuilder()
+        buffer.append(prefix)
+        var count = 0
+        forEach { key, value ->
+            val str = if (transform != null) transform(key, value) else ""
+            if (str.isNotEmpty()) {
+                if (++count > 1) buffer.append(separator)
+                if (limit < 0 || count <= limit) {
+                    when {
+                        transform != null -> buffer.append(str)
+                        else -> buffer.append("$key $value")
+                    }
+                } else {
+                    return@forEach
+                }
+            }
+        }
+        if (limit >= 0 && count > limit) buffer.append(truncated)
+        buffer.append(postfix)
+        return buffer.toString()
+    }
+}