Add async concurrency gate and re-evaluation coordinator

PiperOrigin-RevId: 974934413

Author: l46kok

runtime/planner/BUILD.bazel

@@ -21,3 +21,27 @@ java_library(
     visibility = ["//:internal"],
     exports = ["//runtime/src/main/java/dev/cel/runtime/planner:planned_program"],
 )
+
+java_library(
+    name = "async_gate",
+    visibility = ["//:internal"],
+    exports = ["//runtime/src/main/java/dev/cel/runtime/planner:async_gate"],
+)
+
+cel_android_library(
+    name = "async_gate_android",
+    visibility = ["//:internal"],
+    exports = ["//runtime/src/main/java/dev/cel/runtime/planner:async_gate_android"],
+)
+
+java_library(
+    name = "async_completion_coordinator",
+    visibility = ["//:internal"],
+    exports = ["//runtime/src/main/java/dev/cel/runtime/planner:async_completion_coordinator"],
+)
+
+cel_android_library(
+    name = "async_completion_coordinator_android",
+    visibility = ["//:internal"],
+    exports = ["//runtime/src/main/java/dev/cel/runtime/planner:async_completion_coordinator_android"],
+)

runtime/src/main/java/dev/cel/runtime/BUILD.bazel

@@ -855,7 +855,6 @@ java_library(
         "//runtime:activation",
         "//runtime:interpretable",
         "//runtime:proto_message_activation_factory",
-        "//runtime:resolved_overload",
         "//runtime/planner:planned_program",
         "//runtime/planner:program_planner",
         "//runtime/standard:type",

runtime/src/main/java/dev/cel/runtime/CelRuntimeImpl.java

@@ -112,22 +112,7 @@ public Program createProgram(CelAbstractSyntaxTree ast) throws CelEvaluationExce
     return toRuntimeProgram(planner().plan(ast));
   }
 
-  private static final CelFunctionResolver EMPTY_FUNCTION_RESOLVER =
-      new CelFunctionResolver() {
-        @Override
-        public Optional<CelResolvedOverload> findOverloadMatchingArgs(
-            String functionName, Collection<String> overloadIds, Object[] args) {
-          return Optional.empty();
-        }
-
-        @Override
-        public Optional<CelResolvedOverload> findOverloadMatchingArgs(
-            String functionName, Object[] args) {
-          return Optional.empty();
-        }
-      };
-
-  public Program toRuntimeProgram(dev.cel.runtime.Program program) {
+  private Program toRuntimeProgram(dev.cel.runtime.Program program) {
     return new Program() {
 
       @Override
@@ -152,7 +137,7 @@ public Object eval(Message message) throws CelEvaluationException {
         return plannedProgram.evalOrThrow(
             plannedProgram.interpretable(),
             ProtoMessageActivationFactory.fromProto(message, plannedProgram.options()),
-            EMPTY_FUNCTION_RESOLVER,
+            CelFunctionResolver.EMPTY,
             /* partialVars= */ null,
             /* listener= */ null);
       }
@@ -215,14 +200,14 @@ public ListenableFuture<Object> evalAsync(PartialVars partialVars) {
       @Override
       public Object trace(CelEvaluationListener listener) throws CelEvaluationException {
         return ((PlannedProgram) program)
-            .trace(GlobalResolver.EMPTY, EMPTY_FUNCTION_RESOLVER, null, listener);
+            .trace(GlobalResolver.EMPTY, CelFunctionResolver.EMPTY, null, listener);
       }
 
       @Override
       public Object trace(Map<String, ?> mapValue, CelEvaluationListener listener)
           throws CelEvaluationException {
         return ((PlannedProgram) program)
-            .trace(Activation.copyOf(mapValue), EMPTY_FUNCTION_RESOLVER, null, listener);
+            .trace(Activation.copyOf(mapValue), CelFunctionResolver.EMPTY, null, listener);
       }
 
       @Override
@@ -232,7 +217,7 @@ public Object trace(Message message, CelEvaluationListener listener)
         return plannedProgram.evalOrThrow(
             plannedProgram.interpretable(),
             ProtoMessageActivationFactory.fromProto(message, plannedProgram.options()),
-            EMPTY_FUNCTION_RESOLVER,
+            CelFunctionResolver.EMPTY,
             /* partialVars= */ null,
             listener);
       }
@@ -243,7 +228,7 @@ public Object trace(CelVariableResolver resolver, CelEvaluationListener listener
         return ((PlannedProgram) program)
             .trace(
                 (name) -> resolver.find(name).orElse(null),
-                EMPTY_FUNCTION_RESOLVER,
+                CelFunctionResolver.EMPTY,
                 null,
                 listener);
       }
@@ -278,13 +263,13 @@ public Object trace(PartialVars partialVars, CelEvaluationListener listener)
         return ((PlannedProgram) program)
             .trace(
                 (name) -> partialVars.resolver().find(name).orElse(null),
-                EMPTY_FUNCTION_RESOLVER,
+                CelFunctionResolver.EMPTY,
                 partialVars,
                 listener);
       }
 
       @Override
-      public Object advanceEvaluation(UnknownContext context) throws CelEvaluationException {
+      public Object advanceEvaluation(UnknownContext context) {
         throw new UnsupportedOperationException("Unsupported operation.");
       }
     };