Concurrency 3,422 crates

boarddown-syncCRDT/OT sync engine for BoardDown297MITConcurrency celers-workerTask execution runtime for CeleRS with concurrency control and health checks296Apache-2.0AsynchronousConcurrency nv-viewPTZ/view-state, camera motion modeling, epoch policy, and context validity for the NextVision runtime.293MIT OR Apache-2.0Computer visionConcurrency adze-concurrency-env-coreEnvironment-backed concurrency cap policy and parsing utilities.290MIT OR Apache-2.0Concurrency adze-concurrency-init-classifier-coreClassifier utilities for Rayon global thread-pool initialization errors.290MIT OR Apache-2.0Concurrency worldinterface-coordinatorActionQueue handler for WorldInterface FlowRun orchestration289Apache-2.0Concurrency taktora-medkit-modelWire DTOs for the SOVD-aligned taktora-medkit runtime-diagnostics surface (entity tree, DTC/fault model, freeze-frames,…288Apache-2.0 OR MITConcurrencyEmbedded development taktora-ethercat-esi-buildbuild.rs glue turning EtherCAT ESI XML files into a generated Rust device-driver module in OUT_DIR.287Apache-2.0 OR MITConcurrencyEmbedded development rs_ctrl_osA small runtime library for node discovery, ZeroMQ pub/sub messaging, dynamic TOML config reloading, and simple time…287MITConcurrencyConfiguration frameallocIntent-aware, thread-smart memory allocation for Rust game engines285MIT OR Apache-2.0ConcurrencyGame development daedalus-runtimeRuntime executor for Daedalus plans with backpressure and plugins.285MIT OR Apache-2.0Concurrency taktora-medkit-providerThe data-source seam for taktora-medkit: the `Provider` trait the diagnostic gateway reads through, plus an in-memory mock…285Apache-2.0 OR MITConcurrencyEmbedded development nexus-async-rtExperimental single-threaded async executor (reference implementation; tokio is the supported path for production use)284MIT OR Apache-2.0ConcurrencyData structures celers-canvasWorkflow primitives for CeleRS (Chain, Chord, Group, Map)284Apache-2.0AsynchronousConcurrency rakka-distributed-dataConvergent replicated data types (CRDTs) over a rakka cluster — counters, sets, maps, registers, replicator.284Apache-2.0ConcurrencyData structures rustrade-supervisorService lifecycle supervisor with backoff and circuit breakers for rustrade283MITAsynchronousConcurrency taktora-motion-coreAllocation-free, no_std real-time motion trajectory core (profiles, virtual master, electronic gearing) for the taktora runtime.283Apache-2.0 OR MITConcurrencyEmbedded development tokio-futures-orderEnforce execution order of multiple tasks.282MITConcurrencyDevelopment tools bb-runtimeSans-IO engine for the bytesandbrains framework — Node, Engine, Framework, Backends, roles, snapshot, runtime-side syscalls.281AGPL-3.0-or-laterConcurrencyNetwork programming rt-write-lockconcurrent, realtime write data structure280MIT OR Apache-2.0Concurrency taktora-cia402Fieldbus-independent CiA 402 profile: power state machine and Cia402Drive trait.279Apache-2.0 OR MITConcurrencyEmbedded development precise_rate_limiterA high-performance, precise rate limiter using tokio channels and atomic operations278Apache-2.0AsynchronousConcurrency go-macrosProcedural macros for the gorust crate - providing Go-style concurrency macros for Rust277MITConcurrencyDevelopment tools cloudillo-crdtCRDT collaborative editing over WebSocket for Cloudillo, using the Yjs protocol277LGPL-3.0-onlyConcurrencyWeb programming ash-flareFault-tolerant supervision trees for Rust with distributed capabilities inspired by Erlang/OTP276Apache-2.0AsynchronousConcurrency beetry-macrosInternal beetry crate. For the public API, check the beetry crate.273MITAsynchronousConcurrency starlang-supervisorSupervisor pattern for Starlang273MIT OR Apache-2.0AsynchronousConcurrency taktora-motion-protoPOD NC<->commander ABI (AxisCommand / AxisStatus) for taktora motion.272Apache-2.0 OR MITConcurrencyEmbedded development altair-concurrentType-safe parallel execution of named async tasks with cancellation and per-task tracing271MITAsynchronousConcurrency actionqueue-actorRemote actor registration, heartbeat monitoring, and capability routing for the ActionQueue task queue engine.269Apache-2.0Concurrency tokio-multilockDeadlock-safe concurrent lock acquisition269LGPL-3.0-or-laterAsynchronousConcurrency deltaflowThe embeddable workflow engine. Type-safe, Elixir-inspired pipelines.268MITAsynchronousConcurrency slotbusLock-free shared memory IPC with slotted request/response. Sub-microsecond wake latency, zero-copy payloads, 32 concurrent…268MITConcurrencyNetwork programming ringkernel-audio-fftGPU-accelerated audio FFT processing with direct/ambience separation using RingKernel actors267Apache-2.0ConcurrencyHardware support beetryBehavior tree framework with a runtime, plugin system, and Beehive editor.265MITAsynchronousConcurrency compact-waitgroupA compact asynchronous WaitGroup synchronization primitive.265MIT OR Apache-2.0AsynchronousConcurrency datum-cluster-shardingDatum cluster sharding core: envelopes, coordinator, regions, and entities264Apache-2.0AsynchronousConcurrency ringkernel-ecosystemEcosystem integrations for RingKernel - actors, web frameworks, data processing, ML263Apache-2.0AsynchronousConcurrency proxide-parallel-rtMinimal parallel runtime: thread-count registry for wasm32 builds263MITConcurrency superqueueA tiny, lock-light, type-routed message bus providing event streams and latest-value topics (snapshots) for fast state and event…262MITConcurrencyData structures tg-syncSynchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar.262GPL-3.0ConcurrencyEmbedded development ider高性能时间戳ID生成器 / High-performance timestamp ID generator261MulanPSL-2.0AlgorithmsConcurrency throttle-netGeneral-purpose outbound throttling and resilience for Rust: multi-algorithm rate limiting, multi-dimensional and cost-aware…258Apache-2.0 OR MITAsynchronousConcurrency qubit-dclReusable double-checked lock executor for Rust lock abstractions258Apache-2.0Concurrency copybook-sequence-ringDeterministic sequence reordering primitive for parallel copybook pipelines256AGPL-3.0-or-laterConcurrencyData structures edirstatA fast, cross-platform disk usage analyzer and deduplicator—with work-stealing multithreading, zero-copy snapshots, and an…255MITConcurrencyFilesystem motosan-workflow-skillSkill system and ACP integration for motosan-workflow254MITAsynchronousConcurrency polluxQueue worker pool254MITAsynchronousConcurrency adze-concurrency-init-bootstrap-policy-corePure policy for normalizing concurrency bootstrap caps.252MIT OR Apache-2.0Concurrency adze-concurrency-init-rayon-coreIdempotent Rayon global thread-pool initialization primitives.250MIT OR Apache-2.0Concurrency oxicuda-graphOxiCUDA Graph — CUDA Graph execution engine with operator fusion, buffer lifetime analysis, stream partitioning, and optimized…247Apache-2.0AlgorithmsConcurrency firq-coreCore multi-tenant scheduler with DRR fairness, deadlines, and backpressure246MIT OR Apache-2.0AlgorithmsAsynchronous lockout-channelLock-free unbounded MPMC channel using hazard pointers244MITConcurrencyData structures bb-dslAuthoring DSL for the bytesandbrains framework — Module trait, Graph, Output, contracts, placeholders, concrete-component…243AGPL-3.0-or-laterConcurrencyNetwork programming adze-concurrency-plan-corePure policy helpers for normalized concurrency and bounded parallel partitioning.243MIT OR Apache-2.0Concurrency locksThread-safe type wrappers241MITConcurrencyData structures axhash-dashmapConcurrent DashMap and DashSet powered by dashmap (multi-shard RwLock) and fueled by axhash (AES-NI accelerated hashing).238MITAlgorithmsConcurrency jinternerEfficient and concurrent interning of JSON data237MIT OR Apache-2.0CachingConcurrency worklane-coreShared job model and Broker contract for worklane brokers and extensions.237MIT OR Apache-2.0AsynchronousConcurrency taktora-ethercat-esi-rtRuntime trait contract for generated EtherCAT device drivers (object-safe EsiDevice + runtime EsiError).237Apache-2.0 OR MITConcurrencyEmbedded development ai2070-netHigh-performance, schema-agnostic, backend-agnostic event bus236Apache-2.0AsynchronousConcurrency kovan-stmSoftware Transactional Memory (STM) implementation using Kovan for memory reclamation236Apache-2.0ConcurrencyData structures lazyflowA lazy, effectful streaming library for Rust -- FS2-inspired LazyFlow<B> with pull-based sources, async transforms, backpressure,…235MITAsynchronousConcurrency bachelorPure single-threaded utilities optimized for thread-per-core executors235MIT OR Apache-2.0ConcurrencyData structures taktora-motionCyclic NC task: runs taktora-motion-core against CSP drives over a CyclicFieldbus.235Apache-2.0 OR MITConcurrencyEmbedded development philiprehberger-task-queueIn-process thread-based task queue with priority and concurrency control234MITConcurrencyData structures worldinterface-hostEmbedded Host trait for WorldInterface (Agent integration surface)233Apache-2.0Concurrency bpmn-engineBPMN 2.0 execution engine for Rust with JSON and XML format support232Apache-2.0AlgorithmsConcurrency cell-sdkZero-copy RPC framework with compile-time schemas (rkyv) and 48 Gbps throughput232MIT OR Apache-2.0ConcurrencyNetwork programming lockout-hazardLock-free hazard pointers for safe memory reclamation232MITConcurrencyData structures postvanA minimalistic implementation of pub/sub messaging230MITConcurrency fraktor-utils-std-rsStandard-library helpers complementing fraktor-utils-core227MIT OR Apache-2.0Concurrency scheduled_channelA mpmc channel that allows specifying a timestamp for when a message is received226Apache-2.0ConcurrencyData structures structecsA structural data access framework. Type-safe extraction from nested structures with Arc-based smart pointers.225MITConcurrencyData structures beetry-pluginInternal beetry crate. For the public API, check the beetry crate.225MITAsynchronousConcurrency smc_scan_scxmlSCXML frontend for the Scan model checker.224Apache-2.0CompilersConcurrency motosan-workflow-runtimeExecution engine for motosan-workflow223MITAsynchronousConcurrency warpstateGPU-accelerated multi-pattern matching — run thousands of literals on GPU via wgpu compute shaders223MITAlgorithmsConcurrency soft-cycleAsync controller for coordinating soft restarts and graceful shutdowns with shared listeners222MITAsynchronousConcurrency smc_scan_janiJANI frontend for the Scan model checker.222Apache-2.0CompilersConcurrency rakka-macrosProcedural macros for rakka — `#[derive(Actor)]`, `props!`, `#[derive(Receive)]`.221Apache-2.0ConcurrencyRust patterns taktora-connector-uiServer-side MVVM UI connector for the taktora-connector framework: ViewModel/CommandParams authoring traits, POD image lowering,…221Apache-2.0 OR MITConcurrencyEmbedded development relayrl_env_traitTraits for training and testing environments in the RelayRL framework.221Apache-2.0AlgorithmsConcurrency qubit-rayon-batchRayon-backed batch executor implementation for Qubit Rust libraries220Apache-2.0ConcurrencyDevelopment tools sfidDistributed Snowflake ID generator with Redis-based auto machine ID allocation / 基于 Redis 自动分配机器号的分布式雪花 ID 生成器218MulanPSL-2.0AlgorithmsConcurrency ebpfsieveByte-frequency prefilter for read-heavy scanning pipelines with optional eBPF offload218MITConcurrencyNetwork programming hel-rsHigh-performance lock-free sharded sync+async MPMC/SPSC channels with keyed routing217MITAsynchronousConcurrency dstateDistributed state replication across actor-based clusters215MITConcurrencyNetwork programming archyAn async application framework with services, systems, and dependency injection214MIT OR Apache-2.0AsynchronousConcurrency atomr-persistence-sqlSQL journal and snapshot store for atomr — sqlx-backed; SQLite default; Postgres / MySQL / MSSQL features.214Apache-2.0ConcurrencyDatabase interfaces ctxguardA library for managing contexts.213MITAsynchronousConcurrency rakka-persistence-queryTagged event-stream queries over rakka journals.213Apache-2.0ConcurrencyDatabase interfaces copybook-codec-memoryReusable memory utilities for copybook codec streaming and parallelism.213AGPL-3.0-or-laterConcurrencyData structures rakka-accel-cudaGPU acceleration via the actor model. Wraps NVIDIA CUDA libraries (cuBLAS, cuDNN, cuFFT, cuRAND, cuSOLVER, cuSPARSE, cuTENSOR,…209Apache-2.0AsynchronousConcurrency numallocA blazing-fast, NUMA-aware memory allocator written in pure Rust209MITConcurrencyMemory management d-engine-serverProduction-ready Raft consensus engine server and runtime209MIT OR Apache-2.0AsynchronousConcurrency nv-perceptionStage model, detection/track types, perception artifacts, and derived signals for the NextVision runtime.208MIT OR Apache-2.0Computer visionConcurrency smc_scan_promelaPromela frontend for the Scan model checker.208Apache-2.0CompilersConcurrency trash_parallelismAzzybana Raccoon's comprehensive parallelism library.207Apache-2.0AsynchronousConcurrency adze-concurrency-init-bootstrap-coreBootstraps concurrency caps initialization from environment-derived values.206MIT OR Apache-2.0Concurrency parexBlazing-fast parallel search engine — generic, embeddable, zero opinions205MITConcurrencyFilesystem occams-rpc-api-macrosThe macro crate for razor-rpc. razor-rpc is a modular, pluggable RPC for high throughput scenario, supports various…204MITConcurrencyNetwork programming adze-concurrency-bounded-map-coreBounded parallel map implementation details.203MIT OR Apache-2.0Concurrency taktora-medkit-gatewayTransport-neutral read-diagnostic core for taktora-medkit: resolves entity-tree queries, fault lists, and the worst-wins health…203Apache-2.0 OR MITConcurrencyEmbedded development motosan-agent-workflowA general-purpose DAG-based agent workflow engine202MITAsynchronousConcurrency x0x-symphony-orchestratorDispatch orchestrator tying the tracker, runner, and workspace together for x0x-symphony.201AGPL-3.0-or-laterConcurrencyDevelopment tools ruvix-queueio_uring-style ring buffer IPC for RuVix Cognition Kernel (ADR-087)199MIT OR Apache-2.0ConcurrencyEmbedded development reflow_pack_loaderRuntime loader for .rflpack actor bundles — dlopens pack cdylibs and publishes their templates to the runtime registry.199MIT OR Apache-2.0ConcurrencyDevelopment tools tinytownA simple, fast multi-agent orchestration system using Redis for message passing199MITCommand line utilitiesConcurrency async-local-channelLightweight channels for single-threaded async runtimes.198MITAsynchronousConcurrency tg-rcore-tutorial-multi-processor-sync-wzySynchronization primitives for rCore tutorial OS, including mutex, semaphore, and condvar, with SMP support.198GPL-3.0ConcurrencyEmbedded development reflow_networkNetwork executor for Reflow — routes messages between actors, manages subgraphs, and emits runtime events.197MIT OR Apache-2.0ConcurrencyDevelopment tools rakka-inference-coreFoundation crate for rakka-inference — typed errors, deployment value object, ModelRunner trait, batch primitives.196Apache-2.0AsynchronousConcurrency tianshuAsync Rust workflow engine — define workflows as trait implementations and run them on a pluggable scheduler196Apache-2.0AsynchronousConcurrency taktora-connector-ui-contractLanguage-neutral MVVM contract (manifest, POD field schema, command ack, contract hash) for the taktora UI connector (FEAT_0092);…195Apache-2.0 OR MITConcurrencyEmbedded development bb-opsCanonical concrete components for the bytesandbrains framework — syscalls, wire transport, backends, protocols, role…194AGPL-3.0-or-laterConcurrencyNetwork programming philiprehberger-event-busThread-safe event bus with typed listeners for Rust194MITConcurrencyData structures pithanosFast, lock-free probabilistic data structures for modern Rust.194MITAlgorithmsConcurrency actionqueue-platformMulti-tenant isolation, RBAC, and append-only ledgers for the ActionQueue task queue engine.194Apache-2.0Concurrency insert-takeA Concurrent bag supporting atomically inserting and taking all elements193MIT OR Apache-2.0ConcurrencyData structures cloudillo-crdt-adapter-redbredb-backed CRDT document persistence adapter for Cloudillo, storing binary Yjs updates192LGPL-3.0-onlyConcurrencyDatabase implementations solti-coreSolti SDK supervisor orchestration.192Apache-2.0AsynchronousConcurrency atomr-diDependency-injection container for atomr.189Apache-2.0ConcurrencyRust patterns lockoutA collection of lock-free utilities for Rust189MITConcurrencyData structures wal-dbWrite-ahead log primitive for Rust storage engines. Durable, recoverable, lock-free append path. The WAL substrate under lsm-db,…189Apache-2.0 OR MITConcurrencyDatabase implementations tokio-fsmCompile-time generated Tokio async finite state machines with explicit Rust behavior189MITAsynchronousConcurrency iqdb-buildParallel index construction, incremental updates, and merging - part of the iQDB family.188Apache-2.0 OR MITAlgorithmsConcurrency forge-orchestrationRust-native orchestration platform for distributed workloads with MoE routing, autoscaling, and Nomad integration187Apache-2.0AsynchronousConcurrency dcontext-dactorAutomatic dcontext propagation through dactor actor messages186MITConcurrencyNetwork programming atomr-accel-tensorrtTensorRT engine builder + runtime as supervised atomr actors. Wraps libnvinfer / libnvonnxparser at runtime (proprietary library,…185Apache-2.0AsynchronousConcurrency disruptor-mpUltra-low-latency and high-throughput multiprocess ring-buffer substrate over SHM and mmap (LMAX Disruptor design, extended…185MIT OR Apache-2.0AlgorithmsConcurrency livenLIVEN is a fast, lightweight database built to capture, store, and stream data in real time.185SSPL-1.0ConcurrencyData structures lane_switchboardsTelecom-inspired OTP actor runtime for Rust: mailbox routing, supervision trees, let-it-crash fault isolation, and distributed…184MITAsynchronousConcurrency mechanicsmechanics automation framework (http server)184Apache-2.0 OR MPL-2.0API bindingsArtificial intelligence atomic_token_bucketLock-free Token Bucket algorithm implemented using atomics183MITAlgorithmsConcurrency ubqLock-free unbounded MPMC queue with no_std + alloc support.183MITConcurrencyData structures oxide_coreRust engine primitives for Oxide (store, snapshot streams, error model, optional persistence).182MIT OR Apache-2.0API bindingsAsynchronous taktora-connector-ui-deriveAuthoring derive macros (`ViewModel`, `CommandParams`, `ImageEnum`) for the taktora UI connector: POD image lowering, schema…181Apache-2.0 OR MITConcurrencyEmbedded development rustywallet-batchHigh-performance batch key and address generation for cryptocurrency wallets179MITConcurrencyCryptography crabka-throttleShared token-bucket throttling primitives for Crabka179Apache-2.0Concurrency raft-ioRaft consensus and replicated-log engine for Rust. Leader election, log replication, membership changes, and snapshotting over a…178Apache-2.0 OR MITAlgorithmsConcurrency dactor-test-harnessMulti-process integration test harness for dactor actor framework175MITConcurrencyDevelopment tools::Testing work-managerA library for managing asynchronous work tasks.175MITAsynchronousConcurrency pacta-contractThe isolated core contract for Pacta: durable lifecycle vocabulary and a sans-I/O kernel.174MIT OR Apache-2.0AsynchronousConcurrency parcodeA high-performance, lazy load and parallelized caching library for complex Rust data structures.174MITConcurrencyData structures fraktor-actor-core-rsfraktor no_std actor runtime core174MIT OR Apache-2.0ConcurrencyEmbedded development smc_scanStatistical model checker for large concurrent systems.174Apache-2.0CompilersConcurrency post-cortex-coreCore domain library for post-cortex: lock-free conversation memory, semantic search, knowledge graph, and storage backends.…174MITConcurrencyData structures rbp-autotrainAutomated MCCFR training pipeline orchestration with distributed workers173MITAlgorithmsCommand line utilities floopA more convenient and less error prone replacement for loop `{ select! { .. }}`173MIT OR Apache-2.0AsynchronousConcurrency parawalkBlazing-fast parallel directory walker with zero filtering baggage173MITConcurrencyFilesystem clockworkerA single-threaded async executor with EEVDF-based fair scheduling and pluggable task schedulers173Apache-2.0AsynchronousConcurrency beetry-serializationInternal beetry crate. For the public API, check the beetry crate.173MITAsynchronousConcurrency kwokkacompletion-based async runtime with optional orchestration172MIT OR Apache-2.0AsynchronousConcurrency theater-handler-loopLoop handler for Theater WebAssembly runtime - cooperative looping with yield points172Apache-2.0ConcurrencyDevelopment tools memkit-coCPU-GPU memory coordination for the memkit ecosystem171MPL-2.0ConcurrencyGraphics veda-rsHigh-performance parallel runtime for Rust with work-stealing and adaptive scheduling170MIT OR Apache-2.0AlgorithmsAsynchronous maniac-runtimeHigh-performance async runtime with M:N threading and stackful coroutines168MIT OR Apache-2.0AsynchronousConcurrency rayon-caHigh-performance cellular automaton's implementation in Rust LIB with CLI app and WebP animation export.168MITCommand line utilitiesConcurrency kojin-redisRedis broker backend for the kojin task queue168MIT OR Apache-2.0AsynchronousConcurrency marius-collectorLock-free bit-vector collector for the Marius reactive engine. Pure Core, no async runtime.167MIT OR Apache-2.0ConcurrencyData structures rakka-cluster-toolsDistributed pub/sub, cluster singleton, and cluster client patterns for rakka.167Apache-2.0ConcurrencyNetwork programming getitdoneExperimenting with a simple Mongo-backed caller/worker bridge that keeps tracing context alive.167MITAsynchronousConcurrency firq-asyncTokio async adapter for firq-core166MIT OR Apache-2.0AsynchronousConcurrency philiprehberger-safe-shutdownGraceful shutdown coordination with timeout support for Rust166MITAsynchronousConcurrency taktora-medkit-gateway-axumaxum HTTP surface for taktora-medkit: serves the read-diagnostic core over the ros2_medkit-compatible REST contract on a tokio…166Apache-2.0 OR MITConcurrencyEmbedded development atomr-infer-python-bridgePython-resident GPU runtime wiring for atomr-infer. PythonGpuBridge + python-pinned dispatcher used by the vLLM and other…165Apache-2.0AsynchronousConcurrency kojin-macrosProc-macro support for the kojin task queue (#[kojin::task])165MIT OR Apache-2.0AsynchronousConcurrency taktora-medkit-binding-executortaktora binding for taktora-medkit: sources liveness and timing from taktora-executor Observer/ExecutionMonitor hooks and feeds…165Apache-2.0 OR MITConcurrencyEmbedded development adze-concurrency-map-coreBounded parallel map utilities with deterministic partition planning.164MIT OR Apache-2.0Concurrency deep_causality_parShared parallelism primitives (MaybeParallel marker, scoped fork-join) for the deep_causality crates.163MITConcurrencyScience adze-concurrency-init-coreRayon global thread-pool initialization policy for process-wide concurrency caps.163MIT OR Apache-2.0Concurrency starlang-macrosErgonomic macros for Starlang163MIT OR Apache-2.0AsynchronousConcurrency taktora-medkit-binding-connectortaktora binding for taktora-medkit: maps connector-framework ConnectorHealth transitions into SOVD Components and DTCs…163Apache-2.0 OR MITConcurrencyEmbedded development starlang-applicationApplication lifecycle management for Starlang162MIT OR Apache-2.0AsynchronousConcurrency taktora-idl-coreShared bounded message-type IR for interface descriptions (structs, enums, sequences, services). The message-plane twin of…162Apache-2.0 OR MITConcurrencyEmbedded development busybeaverThis Beaver executes your Futures independently of your worker threads, supporting scheduling strategies such as time intervals,…161MIT OR Apache-2.0AsynchronousConcurrency relayrl_algorithmsIndependent / Multi-Agent Proximal Policy Optimization (PPO) Algorithms for the RelayRL framework160Apache-2.0AlgorithmsArtificial intelligence qubit-execution-servicesAggregated execution services facade for blocking, CPU-bound, Tokio blocking, and async IO tasks158Apache-2.0AsynchronousConcurrency theater-handler-rpcRPC handler for Theater WebAssembly runtime - inter-actor communication158Apache-2.0ConcurrencyDevelopment tools kwokka-runtimescheduler, worker, task, memory, timer, and sync primitives157MIT OR Apache-2.0AsynchronousConcurrency qubit-concurrentConcurrent utilities library providing thread pools, task scheduling, synchronization primitives and other concurrent programming…157Apache-2.0AsynchronousConcurrency ritlersA task-length aware rate limiter that waits for tasks to finish before counting them against the rate limit157MIT OR Apache-2.0AsynchronousConcurrency rsmg-coreCore atomic pointer management and concurrent data structures for the RSMG framework.156MIT OR Apache-2.0ConcurrencyData structures taktora-medkit-manifestThe mandatory Area/Component grouping manifest for taktora-medkit: a type-safe builder core plus a TOML loader over one shape,…156Apache-2.0 OR MITConcurrencyEmbedded development proofman-mpiMessage Passing Interface bindings for Rust155MIT OR Apache-2.0Concurrency theater-handler-timerTimer handler for Theater WebAssembly runtime - periodic tick callbacks155Apache-2.0ConcurrencyDevelopment tools qubit-event-busA lightweight, thread-safe in-process event bus for Rust154Apache-2.0AsynchronousConcurrency atomr-accel-patternsUniversal GPU actor blueprints for atomr-accel-cuda: DynamicBatchingServer, InferenceCascade, ModelReplicaPool,…154Apache-2.0AsynchronousConcurrency bb-compilerCompiler pipeline for the bytesandbrains framework — Compiler driver, CompilerPass trait, canonical pass list, BuildError.154AGPL-3.0-or-laterConcurrencyNetwork programming atomr-infer-runtime-litellmLiteLLM proxy provider for atomr-infer — implements ModelRunner against the LiteLLM unified API gateway, fronting…154Apache-2.0AsynchronousConcurrency myelonUltra-low-latency and high-throughput typed transport for multiprocess SHM and mmap. Layers framing, codecs, typed zero-copy, and…154MIT OR Apache-2.0AlgorithmsArtificial intelligence crossbarZero-copy pub/sub over shared memory. URI-addressed. O(1) transfer at any payload size.154Apache-2.0ConcurrencyNetwork programming tasker-workerWorker foundation system for multi-language step execution153MITAsynchronousConcurrency acton-aiAn agentic AI framework where each agent is an actor152MITAsynchronousConcurrency taktora-idl-codegenPolicy-owning codegen layer for the message-plane IR: naming policy, the MessageBackend trait, and the resolve+generate entry…151Apache-2.0 OR MITConcurrencyEmbedded development pipe-ioTyped source-transform-sink pipelines with backpressure, batching, windowing, and per-stage error isolation. A lightweight…150Apache-2.0AsynchronousConcurrency yot_run_macrosThe wrapper macro for a work-stealing, multi-threaded async executor with non-blocking scheduling.150MIT OR Apache-2.0AsynchronousConcurrency regent-cell-typesPublic trait surface and wire-protocol types for the Regent cell-architecture substrate (pre-1.0; semver-stable when Fuse plus…149Apache-2.0ConcurrencyData structures locus-allocNUMA-aware KV-block pooling with owner-drained chunk mailboxes for CPU LLM inference serving149Apache-2.0ConcurrencyHardware support