Throw a custom exception for test timeouts

tests/js/src/main/scala/cats/effect/DetectPlatform.scala

@@ -36,5 +36,6 @@ trait DetectPlatform {
   }
 
   def isJS: Boolean = true
+  def isJVM: Boolean = false
   def isNative: Boolean = false
 }

tests/jvm/src/test/scala/cats/effect/DetectPlatform.scala

@@ -19,5 +19,6 @@ package cats.effect
 trait DetectPlatform {
   def isWSL: Boolean = System.getProperty("os.version").contains("-WSL")
   def isJS: Boolean = false
+  def isJVM: Boolean = true
   def isNative: Boolean = false
 }

tests/native/src/test/scala/cats/effect/DetectPlatform.scala

@@ -19,5 +19,6 @@ package cats.effect
 trait DetectPlatform {
   def isWSL: Boolean = System.getProperty("os.version").contains("-WSL")
   def isJS: Boolean = false
+  def isJVM: Boolean = false
   def isNative: Boolean = true
 }

tests/shared/src/test/scala/cats/effect/Runners.scala

@@ -27,7 +27,7 @@ import org.specs2.matcher.Matcher
 import org.specs2.mutable.SpecificationLike
 import org.specs2.specification.core.Execution
 
-import scala.concurrent.{Future, Promise, TimeoutException}
+import scala.concurrent.{Future, Promise}
 import scala.concurrent.duration._
 import scala.reflect.ClassTag
 
@@ -105,7 +105,8 @@ trait Runners extends SpecificationLike with TestInstances with RunnersPlatform
     val r = runtime()
     implicit val ec = r.compute
 
-    val cancel = r.scheduler.sleep(duration, { () => p.tryFailure(new TimeoutException); () })
+    val cancel =
+      r.scheduler.sleep(duration, { () => p.tryFailure(new TestTimeoutException); () })
 
     f.onComplete { result =>
       p.tryComplete(result)
@@ -115,3 +116,5 @@ trait Runners extends SpecificationLike with TestInstances with RunnersPlatform
     p.future
   }
 }
+
+class TestTimeoutException extends Exception

tests/shared/src/test/scala/cats/effect/kernel/DeferredSpec.scala

@@ -22,7 +22,7 @@ import cats.syntax.all._
 
 import scala.concurrent.duration._
 
-class DeferredSpec extends BaseSpec { outer =>
+class DeferredSpec extends BaseSpec with DetectPlatform { outer =>
 
   "Deferred for Async" should {
     tests(IO(Deferred.unsafe), IO(Deferred.unsafe))
@@ -180,7 +180,7 @@ class DeferredSpec extends BaseSpec { outer =>
                 d.get.as(1).parReplicateA(n).map(_.sum must be_==(n))
               }
             }
-            .replicateA_(100)
+            .replicateA_(if (isJVM) 100 else 1)
         }
         .as(true)
     }

tests/shared/src/test/scala/cats/effect/std/QueueSpec.scala

@@ -277,7 +277,8 @@ class BoundedQueueSpec extends BaseSpec with QueueTests[Queue] with DetectPlatfo
       constructor(8) flatMap { q =>
         val offerer = List.fill(8)(List.fill(8)(0)).parTraverse_(_.traverse(q.offer(_)))
 
-        (offerer &> 0.until(8 * 8).toList.traverse_(_ => q.take)).replicateA_(1000) *>
+        val iter = if (isJVM) 1000 else 1
+        (offerer &> 0.until(8 * 8).toList.traverse_(_ => q.take)).replicateA_(iter) *>
           q.size.flatMap(s => IO(s mustEqual 0))
       }
     }
@@ -300,7 +301,7 @@ class BoundedQueueSpec extends BaseSpec with QueueTests[Queue] with DetectPlatfo
           }
         }
 
-        (offerer &> taker(0)).replicateA_(1000) *>
+        (offerer &> taker(0)).replicateA_(if (isJVM) 1000 else 1) *>
           q.size.flatMap(s => IO(s mustEqual 0))
       }
     }