Make DrainableWorker keyed by thread

[ashvinnihalani]

Summary

• make DrainableWorker process items serially per thread key while allowing different keys to run concurrently
• update the provider command, runtime ingestion, and checkpoint reactors to enqueue work by threadId
• remove drainKey from DrainableWorker, document that we do not support per-key draining yet, and add regression coverage for blocked-thread isolation

Testing

• bun fmt
• bun lint
• bun typecheck
• bun run test -- src/DrainableWorker.test.ts
• bun run test -- src/orchestration/Layers/ProviderCommandReactor.test.ts

Note

Key DrainableWorker by thread to allow concurrent cross-thread processing

• Rewrites DrainableWorker from a single-queue design to a per-key design using TxRef-managed state, where each key gets its own serial queue but different keys run concurrently.
• Updates enqueue to accept (key, item) and the process function to receive (key, item); drain now waits for all keys' work to complete.
• Updates CheckpointReactor, ProviderCommandReactor, and ProviderRuntimeIngestion to enqueue with threadId as the key.
• Behavioral Change: enqueue now requires a key argument at all call sites; work for different threads proceeds concurrently while preserving per-thread ordering.

^{Macroscope summarized 343bd81.}

[coderabbitai]

Important

Review skipped

Auto reviews are disabled on this repository. Please check the settings in the CodeRabbit UI or the .coderabbit.yaml file in this repository. To trigger a single review, invoke the @coderabbitai review command.

⚙️ Run configuration

Configuration used: Repository UI

Review profile: CHILL

Plan: Pro

Run ID: d702dca7-9ee0-4b9a-8d3a-719865e4e8d0

You can disable this status message by setting the reviews.review_status to false in the CodeRabbit configuration file.

Use the checkbox below for a quick retry:

• 🔍 Trigger review

✨ Finishing Touches

🧪 Generate unit tests (beta)

• Create PR with unit tests

---

Thanks for using CodeRabbit! It's free for OSS, and your support helps us grow. If you like it, consider giving us a shout-out.

❤️ Share

• X
• Mastodon
• Reddit
• LinkedIn

_{Comment @coderabbitai help to get the list of available commands and usage tips.}