You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
{{ message }}
Repository navigation
concurrent.futures→asyncio state transfer is a bottleneck #134173
The current _copy_future_state implementation requires multiple method calls and lock acquisitions to retrieve the source future's state:
done() - acquires lock to check state
cancelled() - acquires lock again
exception() - acquires lock to get exception
result() - acquires lock to get result
Each method call involves thread synchronization overhead, making this operation a bottleneck for high-frequency executor dispatches.
Our use case involves dispatching a large number of small executor jobs from asyncio to a thread pool. These jobs typically involve open or stat on files that are already cached by the OS, so the actual I/O returns almost instantly. However, we still have to offload them to avoid blocking the event loop, since there's no reliable way to determine in advance whether a read will hit the cache.
As a result, the majority of the overhead isn't from the I/O itself, but from the cost of scheduling. Most of the time is spent copying future state, which involves locking. This PR reduces that overhead, which has a meaningful impact at scale.
Activity
gh-134173: optimize state transfer between `concurrent.futures.Future…
kumaraditya303 commentedon May 18, 2025
Thanks
pythongh-134173: optimize state transfer between `concurrent.futures.…
pythongh-134173: optimize state transfer between `concurrent.futures.…