Avoid race condition in GC_Example test

build/build/src/engine/context.rs

@@ -661,12 +661,10 @@ pub async fn runner_sanity_test(
             .args(["--run", repo_root.test.join("Base_Tests").as_str()])
             .set_env_opt(ENSO_JAVA, enso_java)?
             .set_env(ENSO_DATA_DIRECTORY, engine_package)?
-            .run_stdout()
-            .await?;
-        ensure!(
-            test_base.contains("0 tests failed."),
-            "All tests shall succeed. Output:\n{test_base}",
-        );
+            .run_ok()
+            .await;
+        test_base
+    } else {
+        Ok(())
     }
-    Ok(())
 }

engine/runtime/src/main/java/org/enso/interpreter/runtime/ResourceManager.java

@@ -177,29 +177,34 @@ private final class ProcessItems extends ThreadLocalAction implements Runnable {
      */
     @Override
     protected void perform(ThreadLocalAction.Access access) {
+      var isMyThreadChoosen = false;
       for (; ; ) {
         Item[] toProcess;
         synchronized (pendingItems) {
-          request.cancel(false);
+          if (!isMyThreadChoosen) {
+            if (request == null || request.isCancelled()) {
+              // some thread is already handing the request
+              return;
+            } else {
+              // I am choosen and I will loop and process pendingItems
+              // until they are available
+              isMyThreadChoosen = true;
+              // signal others this request has choosen thread
+              request.cancel(false);
+            }
+          }
           if (pendingItems.isEmpty()) {
-            // nothing to process,
-            // signal request is finished
+            // nothing to process anymore,
+            // signal request is finished and new one shall be scheduled
             request = null;
             return;
           }
           toProcess = pendingItems.toArray(Item[]::new);
-          // mark as being processed
-          pendingItems.set(0, null);
+          pendingItems.clear();
         }
-        try {
-          for (var it : toProcess) {
-            it.finalizeNow(context);
-            removeFromItems(it);
-          }
-        } finally {
-          synchronized (pendingItems) {
-            pendingItems.subList(0, toProcess.length).clear();
-          }
+        for (var it : toProcess) {
+          it.finalizeNow(context);
+          removeFromItems(it);
         }
       }
     }

test/Base_Tests/src/Runtime/GC_Example.enso

@@ -15,11 +15,11 @@ type My_Resource
 
 close_resource resource = resource.close
 
-repeat_cleanup_until_done counter =
+repeat_cleanup_until_done counter println =
     go i =
         if counter.get == 0 then Nothing else
             if i % 100 == 0 then
-                IO.println "Still "+counter.get.to_text+" resources to clean up..."
+                println "Still "+counter.get.to_text+" resources to clean up..."
             Runtime.gc
             @Tail_Call go i+1
     go 1
@@ -32,7 +32,7 @@ perform_test n:Integer println =
         My_Resource.allocate counter
 
     println "Cleaning up..."
-    repeat_cleanup_until_done counter
+    repeat_cleanup_until_done counter println
     println "All cleaned up! Remaining: "+counter.get.to_text
     counter.get
 

test/Base_Tests/src/Runtime/Managed_Resource_Spec.enso

@@ -58,8 +58,8 @@ add_specs suite_builder = suite_builder.group "Managed_Resource" group_builder->
         r_3 = Panic.recover Any <| Managed_Resource.bracket 42 (_-> Nothing) (_-> Panic.throw "action")
         r_3.catch . should_equal "action"
 
-    group_builder.specify "allocate lots of resources at once" pending=(if Environment.get "CI" . is_nothing . not then "GC Example is marked as pending as it was causing problems on the CI.") <|
-        remaining = GC_Example.perform_test 100000 (_->Nothing)
+    group_builder.specify "allocate lots of resources at once" <|
+        remaining = GC_Example.perform_test 100000 IO.println
         remaining . should_equal 0
 
 main filter=Nothing =