cats-effect
cats-effect copied to clipboard
typelevel
The pure asynchronous runtime for Scala
I'm starting to think that GHA has just gotten slower lately… ``` [error] ==> X cats.effect.kernel.AsyncSuite.fromFutureCancelable should backpressure on cancelation 20.003s java.util.concurrent.TimeoutException: test timed out after 20 seconds ```
`blockOn` may be invoked by directly using the WSTP as an `ExecutionContext` with `scala.concurrent.blocking`, no `IO` involved. So that's not sufficient justification for not using `try`/`catch`. Not sure if we...
2e053480c0ec4c45af78186cbd1f2b5b5cab22a3 windows-latest, 2.13.16, temurin@17, ciJVM ``` [error] ==> X cats.effect.std.SupervisorSuite.async - restart / cancel race 20.058s cats.effect.TestTimeoutException: null [error] at cats.effect.Runners.$anonfun$timeout$1(Runners.scala:147) [error] at cats.effect.unsafe.WorkStealingThreadPool$$anon$1.apply(WorkStealingThreadPool.scala:680) [error] at cats.effect.unsafe.WorkStealingThreadPool$$anon$1.apply(WorkStealingThreadPool.scala:677) [error] at cats.effect.unsafe.WorkerThread.run(WorkerThread.scala:842)...
macos-14, 2.13.16, temurin@21, ciJVM d3dd96a353ba712665f69b07bd5a3d51bd7849f2 ``` [error] ==> X cats.effect.std.DeferredJVMParallelism4Tests.Deferred — issue #380: with cooperative light async boundaries 30.234s java.util.concurrent.TimeoutException: test timed out after 30 seconds ``` https://github.com/typelevel/cats-effect/actions/runs/13651959326/job/38162372267#step:22:1750
Currently, the external queue holds tasks in two styles: - batches, which are enqueued when a local queue spills over - singletons, which are enqueued when tasks are scheduled externally...
```scala trait Manager[F[_], K, V] { def +=(pair: (K, Resource[F, V])): F[Unit] def -=(key: K): F[Unit] def apply(key: K): F[Option[V]] def join(key: K): F[V] } object Manager { def apply[F[_]:...
All credit goes to @xuwei-k here. I even cribbed his code more or less directly. I haven't yet run the full set of benchmarks so hold off on merging. Fixes...
The [site doc example of a rotating logger](https://typelevel.org/cats-effect/docs/std/hotswap) assumes an API that doesn't match the one provided by `Hotswap`. The assumed API would be much easier to work with in...
I think `java.lang.ClassValue` is faster than current implementation. - benchmark code https://github.com/xuwei-k/cats-effect/commit/f7c2dabfd974bcfb57cff683a360ef7c163a4487 - https://github.com/scala/scala/pull/9632 ``` Jmh / run -i 10 -wi 10 -f 1 -t 1 cats.effect.benchmarks.TagBenchmark ``` ``` [info]...
The [documentation](https://github.com/typelevel/cats-effect/blob/v3.5.7/kernel/shared/src/main/scala/cats/effect/kernel/GenConcurrent.scala#L127:L129) of `parTraverseN` explicitly mentions fairness: > Note that the semantics of this operation aim to maximise fairness: when a spot to execute becomes available, every task has a...
