Optimize lazy stage actor dispatch#3035

Draft

He-Pin wants to merge 7 commits into

apache:mainfrom

He-Pin:optimize-stage-actor-ref-lazy-dispatch

Commits on Jun 3, 2026

fix: optimize lazy stage actor dispatch via MPSC drain coalescing
He-Pin
committed
fix: keep lazy stage actor refs under supervisor
He-Pin
committed
fix: guard LazyDispatch producer path against post-completion enqueue
He-Pin
committed
fix: drop queue and skip drain re-schedule when stage completes mid-batch
He-Pin
committed
fix: replace AtomicInteger with VarHandle and remove drainCallback in LazyDispatch
He-Pin
committed
fix: type-witness VarHandle.get for Scala 3 cross-compile
He-Pin
committed

Commits on Jun 7, 2026

fix: encapsulate VarHandle access and clean up LazyDispatch style
He-Pin
committed