Work in progress

webapp/sources/utils/src/main/scala/com/normation/ZioCommons.scala

@@ -26,6 +26,9 @@
 package com.normation
 
 
+import java.util.concurrent.ForkJoinPool
+import java.util.concurrent.RejectedExecutionException
+
 import net.liftweb.common.{Logger => _, _}
 import cats.data._
 import cats.implicits._
@@ -36,6 +39,12 @@ import com.normation.errors.RudderError
 import com.normation.errors.SystemError
 import _root_.zio._
 import _root_.zio.syntax._
+import _root_.zio.clock._
+import _root_.zio.random._
+import _root_.zio.blocking._
+import _root_.zio.console._
+import _root_.zio.system.{System => ZSystem}
+import _root_.zio.internal._
 import com.normation.zio.ZioRuntime
 import org.slf4j.Logger
 
@@ -303,7 +312,29 @@ object zio {
      * IO into an async thread pool to avoid deadlock in case of
      * a hierarchy of calls.
      */
-    val internal = new DefaultRuntime(){}
+    val internal = new DefaultRuntime() {
+      object ForkJoinBlockin extends Blocking {
+        val blocking: Blocking.Service[Any] = new Blocking.Service[Any] {
+          val blockingExecutor: UIO[Executor] = {
+            val pool = new ForkJoinPool(4)
+            object executor extends Executor {
+              override def yieldOpCount: Int = 10000
+              override def metrics: Option[ExecutionMetrics] = None
+              override def submit(runnable: Runnable): Boolean =
+                try {
+                  pool.execute(runnable)
+                  true
+                } catch {
+                  case _: RejectedExecutionException => false
+                }
+              override def here: Boolean = false
+            }
+            executor.succeed
+          }
+        }
+      }
+      override val Environment: Environment = new Clock.Live with Console.Live with ZSystem.Live with Random.Live with Blocking.Live
+    }
 
     /*
      * use the blocking thread pool provided by that runtime.