Bikeshed

typelevel · Jan 8, 2024 · 862b60c · 862b60c
1 parent bf03fb3
commit 862b60c
Show file tree

Hide file tree

Showing 4 changed files with 6 additions and 6 deletions.
diff --git a/core/js-native/src/main/scala/cats/effect/unsafe/WorkStealingThreadPool.scala b/core/js-native/src/main/scala/cats/effect/unsafe/WorkStealingThreadPool.scala
@@ -36,7 +36,7 @@ private[effect] sealed abstract class WorkStealingThreadPool private ()
       task: Runnable,
       fallback: Scheduler): Runnable
   private[effect] def canExecuteBlockingCode(): Boolean
-  private[effect] def prepareBlocking(): Unit
+  private[effect] def prepareForBlocking(): Unit
   private[unsafe] def liveTraces(): (
       Map[Runnable, Trace],
       Map[WorkerThread, (Thread.State, Option[(Runnable, Trace)], Map[Runnable, Trace])],

diff --git a/core/jvm/src/main/scala/cats/effect/unsafe/WorkStealingThreadPool.scala b/core/jvm/src/main/scala/cats/effect/unsafe/WorkStealingThreadPool.scala
@@ -502,10 +502,10 @@ private[effect] final class WorkStealingThreadPool(
    * Prepares the current thread for running blocking code. This should be called only if
    * [[canExecuteBlockingCode]] returns `true`.
    */
-  private[effect] def prepareBlocking(): Unit = {
+  private[effect] def prepareForBlocking(): Unit = {
     val thread = Thread.currentThread()
     val worker = thread.asInstanceOf[WorkerThread]
-    worker.prepareBlocking()
+    worker.prepareForBlocking()
   }
 
   /**

diff --git a/core/jvm/src/main/scala/cats/effect/unsafe/WorkerThread.scala b/core/jvm/src/main/scala/cats/effect/unsafe/WorkerThread.scala
@@ -797,7 +797,7 @@ private final class WorkerThread(
    *   There is no reason to enclose any code in a `try/catch` block because the only way this
    *   code path can be exercised is through `IO.delay`, which already handles exceptions.
    */
-  def prepareBlocking(): Unit = {
+  def prepareForBlocking(): Unit = {
     val rnd = random
 
     pool.notifyParked(rnd)
@@ -858,7 +858,7 @@ private final class WorkerThread(
    * A mechanism for executing support code before executing a blocking action.
    */
   override def blockOn[T](thunk: => T)(implicit permission: CanAwait): T = {
-    prepareBlocking()
+    prepareForBlocking()
     thunk
   }
 

diff --git a/core/shared/src/main/scala/cats/effect/IOFiber.scala b/core/shared/src/main/scala/cats/effect/IOFiber.scala
@@ -991,7 +991,7 @@ private final class IOFiber[A](
             if (ec.isInstanceOf[WorkStealingThreadPool]) {
               val wstp = ec.asInstanceOf[WorkStealingThreadPool]
               if (wstp.canExecuteBlockingCode()) {
-                wstp.prepareBlocking()
+                wstp.prepareForBlocking()
 
                 var error: Throwable = null
                 val r =