cats-effect
cats-effect copied to clipboard
typelevel
The pure asynchronous runtime for Scala
Notes so far: - [ ] ~~There is something weird going on with exception stacktraces; I haven't been able to minimize so far. UPDATE: seems to work fine in CI,...
On top of #4065 Provides a parallel of `MapRef` for `AtomicCell`, the `AtomicMap`. It also includes some nice improvements for `AtomicCell`, we may move these to its own PR if...
Also corrects the site docs for `Hotswap` so it conforms to the `Hotswap` API Addresses #4268
Added a `Kqueue` trait with an `awaitEvent` method to enable direct kevent handling in the kqueue-based polling system. This provides access to kqueue-specific functionality beyond standard file descriptor polling.
With this change, every time we park a thread we check to see if the underlying polling system `needsPoll`, which is a hint that is intended to be implemented by...
https://github.com/typelevel/cats-effect/blob/c33d8876ceecfc143aa2f4f8bce8d5d9ecdfe381/core/native/src/main/scala/cats/effect/IOApp.scala#L451-L458
After switching the WSTP implementation to use `LinkedTransferQueue` (#4295), cached threads are now polled based on their insertion order — oldest threads are polled first. This change has introduced an...
This is a proposal to introduce retry functionality in Cats Effect. The intent here is to focus the discussion on the interface, before moving on to implementation in a dedicated...
I absolutely love this: ``` [WARNING] A Cats Effect worker thread was detected to be in a blocked state (WAITING) at java.base/jdk.internal.misc.Unsafe.park(Native Method) at java.base/java.util.concurrent.locks.LockSupport.park(LockSupport.java:221) at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:715) at java.base/java.util.concurrent.locks.AbstractQueuedSynchronizer.acquire(AbstractQueuedSynchronizer.java:938) at...