-
parking_lot
比标准同步原语更紧凑和高效的实现
-
spin
基于自旋的同步原语
-
rayon
Rust 的基于工作窃取的并行性
-
dashmap
Rust 的超快速并发 HashMap
-
flume
超快速的多生产者通道
-
thread_local
对象的线程局部存储
-
async-lock
异步同步原语
-
async-channel
异步多生产者多消费者通道
-
crossbeam
并发编程工具
-
threadpool
固定工作线程集合上运行多个作业的线程池
-
oneshot
具有(可能)无锁非阻塞发送和同时支持线程阻塞接收操作以及基于 Future 的异步轮询的 spsc 通道
-
loom
并发代码的排列测试
-
triomphe
std::sync::Arc 的分支,具有一些额外功能,无弱引用(最初为 servo_arc)
-
jobserver
Rust 的 GNU Make jobserver
-
scc
高性能容器和用于并发和异步编程的实用工具
-
ringbuf
无锁 SPSC FIFO 环形缓冲区,可直接访问内部数据
-
state
安全和轻松的全球和线程局部状态管理
-
blake2s_simd
具有动态 SIMD 的纯 Rust BLAKE2s 实现
-
futures-intrusive
基于侵入式数据结构的Futures - 用于std和no-std环境
-
lasso
一个多线程和单线程的字符串池,允许将字符串以最小的内存占用缓存起来,并关联一个唯一键,可以用来随时检索
-
thread-priority
管理线程优先级和调度策略
-
sled
轻量级高性能纯Rust事务嵌入式数据库
-
throttle-server
通过HTTP接口提供分布式系统的信号量
-
leaky-bucket
基于漏桶算法的基于令牌的速率限制器
-
stateright
分布式系统实现的模型检查器
-
corosensei
堆栈协程的快速安全实现
-
mpi
Rust的消息传递接口绑定
-
sync_wrapper
在证明并发不存在时利用编译器的帮助
-
atomic_refcell
线程安全的 RefCell
-
thingbuf
我在缓冲池中。我在 MPSC 通道中。我在组合 MPSC 通道和缓冲池中。
-
mock_instant
模拟 std::time::Instant 的一种方法
-
archery
抽象引用计数指针的原子性
-
rtrb
实时安全的单生产者单消费者环形缓冲区
-
waker-fn
将闭包转换为唤醒函数
-
try-lock
轻量级原子锁
-
lockfree-object-pool
具有自动归还和附加/分离语义的线程安全对象池集合
-
may
Rust 栈式协程库
-
atomic_float
线程之间可以安全共享的浮点类型
-
hwlocality
hwloc硬件局部性库的惯用Rust绑定
-
radium
用于可能原子的类型的可移植接口
-
scheduled-thread-pool
计划线程池
-
async-condvar-fair
异步Rust的条件变量
-
shuttle
测试并发Rust代码
-
ratelimit
可在线程间共享的速率限制器
-
gix-lock
Git风格的锁文件实现
-
mpstthree
为2个或更多参与者实现多方会话类型
-
local-channel
一个非线程安全的、多生产者、单消费者、对future有感知的FIFO队列
-
原子操作
泛型 Atomic<T> 包装类型
-
工作槽
Rust 的 GNU make jobserver
-
图
高性能图算法
-
lasso2
一个多线程和单线程的字符串池,允许将字符串以最小的内存占用缓存起来,并关联一个唯一键,可以用来随时检索
-
grip-grab
比 ripgrep 更快、更轻量级的替代品
-
总线
无锁、有界、单生产者、多消费者、广播通道
-
disruptor
通过环形缓冲区实现低延迟的线程间通信(受 LMAX Disruptor 启发)
-
workerpool
用于在固定数量的状态化工作线程上运行多个作业的线程池
-
wasm_thread
针对 wasm32 目标的 std 线程替代品
-
concurrent-queue
并发多生产者多消费者队列
-
sea-streamer
🌊 Rust 的流处理工具包
-
flurry
Java 的 ConcurrentHashMap 的 Rust 端口
-
kanal
Rust 应得的快速同步和异步通道
-
tachyonix
非常快速的支持异步、多生产者、单消费者有界通道
-
infinitree
具有分层缓存的嵌入式加密数据库
-
mco
类似 go 的 Rust 协程库
-
memo-map
实现用于记忆化的同步映射
-
futures-channel
使用 futures-rs 进行异步通信的通道
-
typedmap
一种哈希表(划线表)。值的类型由键类型上实现的特质定义
-
sdd
可扩展的无锁延迟内存回收器
-
parallel-sh
并行执行命令
-
hydra
使用Rust编程语言编写容错、高度可扩展应用的框架
-
putex
进程互斥锁
-
oneshot-uniffi
专为UniFFI项目修改的oneshot版本。此版本移除了
loom
目标和依赖,有助于UniFFI的下游用户 -
inline-array
高效的不可变内联字节数组
-
deqp-runner
一个VK-GL-CTS/dEQP包装程序,用于跨CPU并行化它,并报告与基线结果
-
maitake-sync
Maitake的no-std异步同步原语
-
rusty_pool
基于crossbeam的多生产者多消费者通道的自增长/缩ThreadPool实现,支持等待任务结果并提供异步支持
-
seize
用于并发数据结构的快速、高效、健壮的内存回收
-
runnel
可插拔的IO流。目前支持:stdio、字符串IO、内存管道
-
atomig
通过
Atomic<T>
提供通用的、便捷的、无锁的std
原子操作。可以用于许多原始类型(包括浮点数)以及自定义类型。 -
messaging_thread_pool
辅助创建与通道通信的泛型对象线程池
-
orx-concurrent-bag
一个高效、便捷且轻量级的仅增长并发数据结构,允许高性能并发收集
-
svix-ksuid
纯Rust且经过完全测试的KSUID实现
-
recloser
使用环形缓冲区实现的并发电路断路器
-
oqueue
非交错的多线程输出队列
-
atomic-take
从容器中原子地取出一个值一次
-
async_once
懒加载静态的异步单例工具
-
callysto
流处理框架
-
salsa
一个通用的按需、增量计算框架(实验性)
-
gst-plugin-threadshare
GStreamer Threadshare 插件
-
arrayfire
一个高性能的软件库,用于并行计算,具有易于使用的API。其基于数组的函数集使得并行编程变得简单。ArrayFire的多个后端(CUDA…
-
threadbound
使任何值同步,但仅在其原始线程上可用
-
atomic-time
AtomicDuration
,AtomicOptionDuration
,AtomicSystemTime
,AtomicOptionSystemTime
,AtomicInstant
和AtomicOptionInstant
用于 Rust -
shred
并行调度需要读取某些资源访问权限和写入其他资源的系统
-
st3
一个非常快、无锁、有界、工作窃取的 LIFO 队列
-
cfavml
CF的加速向量数学库,提供对向量操作的SIMD优化例程
-
aarc
Arc 和 Weak 的原子更新变体,用于无锁并发
-
gabriel2
确实,这是一个基于Tokio的Actor库,用Rust编写
-
mcslock
Mellor-Crummey和Scott的无冲突自旋锁,用于互斥,称为MCS锁
-
spinning_top
基于
lock_api
提供的抽象的自旋锁crate -
crossbeam-queue
并发队列
-
no_deadlocks
运行时死锁调试器
-
boxcar
并发、只增向量
-
picokafka
基于librdkafka的tarantool-module的Kafka库
-
kameo
基于Tokio的容错异步Actor
-
diatomic-waker
用于任务唤醒的异步、无锁同步原语
-
io-reactor
使用反应器模式进行并发I/O资源管理
-
可锁定
提供具有可锁定单独条目的哈希表和缓存数据结构
-
分片互斥锁
无对象内存开销锁。针对Copy/PartialEq类型的伪原子操作。
-
队列管理工具
用于管理长时间运行的shell命令的命令行工具
-
crossfire
异步和线程的通道
-
watchable
与多线程和异步代码兼容的RwLock-like类型
-
rearch-effects
重新构想的应用程序设计和架构方法
-
guardian
为引用计数的互斥锁提供所有者互斥锁保护
-
tonari-actor
一个以高性能和简洁为目标的最小化actor框架
-
idr-ebr
一个高效的并发ID到对象解析器
-
choir
任务编排框架
-
批量不是问题
我有99个问题,但批量不是其中一个
-
async-skipdb
一个嵌入式、内存中、零拷贝、原子性、一致性、MVCC、几乎无锁和可序列化的快照隔离数据库引擎
-
nbio
非阻塞I/O
-
rtsc
实时同步组件
-
happylock
免费死锁预防
-
rtic-monotonics
提供来自rtic-time的Monotonic trait的实现
-
surrealkv
为Rust提供的一个低级、版本化、嵌入式、ACID兼容的键值数据库
-
rustc-rayon
Rust的work-stealing并行主义 - rustc的分支
-
local-sync
用于异步使用的非线程安全的数据结构
-
lever
事务系统和数据网格的支柱
-
append-only-vec
仅追加、并发向量
-
swap-buffer-queue
缓冲式MPSC队列
-
tc-transact
为TinyChain事务提供的特性和锁定工具
-
fault-injection
故障注入、并发延迟注入和错误源标注
-
paradis
使用非交集索引的并行处理
-
mutringbuf
具有就地可变性的无锁SPSC环形缓冲区
-
trauma
简化并美化HTTP下载
-
rclite
小型、快速且内存友好的引用计数,兼容Arc和Rc API
-
atomptr
为类型原子智能指针提供安全、无依赖的抽象
-
rayon-progress-bar
Rust 的基于工作窃取的并行性
-
desync
异步编程的无忧数据类型
-
someday
无锁MVCC原语
-
nexus-acto-rs
Actor模型
-
arccstr
线程安全、引用计数的空终止不可变字符串
-
fast-able
世界武功,唯快不破;天下武功,唯快不破
-
sanitizers
sanitizers接口的接口和FFI绑定
-
async-stm
异步软件事务内存
-
oxidd-manager-pointer
OxiDD的基于指针的管理实现
-
io-pipe
Rust中创建多写入和单读取管道的快速且线程安全的库
-
minstant
一个高性能和高精度的TSC驱动的
std::time::Instant
的替代品,用于测量时间 -
thingvellir
一个并发、无共享抽象,用于管理一组事物
-
通道
Rust 高级队列库
-
线程管理器
一个针对高效线程池和并行作业执行的Rust库,设计简单、灵活、高效
-
utils-atomics
各种原子工具
-
perthread
用于从静态上下文访问PerThread线程局部变量的ThreadMap结构
-
omango
并发集合
-
par-iter-sync
具有顺序输出的并行迭代器
-
concurrent-map
无锁可线性化的B+树
-
myriam
本地和远程演员的Actor模型实现
-
open-coroutine
高效且通用的堆栈式协程库
-
sluice
用于字节缓冲区、FIFO队列和SPSC通道的高效环形缓冲区
-
timeslice
周期性时间片调度器
-
atomic_once_cell
线程安全且无锁的OnceCell和Lazy
-
voxel-tiler-core
将点云转换为体素数据
-
sync_file
可并行读取的文件
-
sharded_queue
ShardedQueue 是目前在高并发和负载下使用最快的并发集合
-
tasklet
异步任务调度库
-
atomic-shim
不支持平台的原子类型
-
melodium
面向数据流的语言和工具,专注于数据应用处理,允许安全地进行高可扩展性和大规模并行化
-
mintex
最小互斥锁
-
portable_atomic_enum
创建围绕 C 风格枚举的可移植原子包装器的属性
-
concurrent_arena
返回 ArenaArc 的 u32 并发插入/删除区域
-
k-lock
用于短关键部分的快速互斥锁
-
shipyard_scenegraph
实体组件系统场景图
-
tsuki-scheduler
适用于每个运行时的轻量级、可组合和可扩展的调度器
-
resman
运行时管理资源借用
-
mpvipc
一个小型库,通过套接字提供控制现有 mpv 实例的绑定
-
reactivate
线程安全的反应式数据结构。用❤️为🦀制作
-
semka
信号量实现
-
indicatif-log-bridge
桥接 log crate 和 indicatif,以防止日志行与进度条混淆
-
rose_bloom
一个具有稳定指针的并发增长的元素大小链表
-
pi_arr
无锁且自动扩展的数组
-
rayon-cond
条件并行或串行迭代的实验性包装器
-
async-local
用于在异步上下文中以及在 await 点之间使用线程局部变量
-
protoflow
Protoflow
-
jod-thread
默认情况下在销毁时自动join的std::thread
-
pagetable
为大致连续键提供无等待4级64位页表
-
signals2
受boost::signals2启发的线程安全的信号/槽库
-
pi_key_alloter
lock free Key(idx:u32, version:u32) alloter
-
senders_receivers
Rust的发送者/接收者实现
-
steady_state
在Linux上构建长期运行低延迟基于actor服务的框架。提供可视化遥测来监视actor之间的数据流。使用earlang风格的supervisor来防御...
-
crossbeam-channel
用于消息传递的多生产者多消费者通道
-
crawly
一个轻量级的Rust异步Web爬虫,优化了并发抓取,同时遵守
robots.txt
规则 -
datacake-crdt
基于混合逻辑时钟实现的免冲突复制数据类型,用于构建最终一致的数据存储
-
keepcalm
多线程程序的共享类型
-
yazi-scheduler
Yazi任务调度器
-
crony
启动另一个线程运行cron作业的cron运行器
-
rucron
作业调度箱
-
kueue
一个健壮的、用户级的、工作窃取的、分布式任务调度器
-
armc
便于访问变量的互斥锁
-
orx-concurrent-vec
一个高效、方便且轻量级的只增读 & 写并发数据结构,允许高性能并发集合
-
blocking-threadpool
固定工作线程集合上运行多个作业的线程池
-
rw-cell
从任何地方将数据写入单元,而不需要复制、锁定和读取
-
qutex
依赖于无锁和其他非阻塞(线程)技术(如Rust futures)的同步机制,以确保对数据的互斥或共享独占访问
-
creche
标准库中std::process::Command和相关类型的替代品。运行单个进程和进程管道,并为每个子进程配置文件描述符和环境。
-
synchronoise
基于标准库的同步原语
-
atomic-wait
跨平台的原子等待和唤醒(即futex)功能
-
taski
异步任务DAG执行
-
reord
以可重复的方式多线程运行您的测试
-
async-cpupool
用于CPU密集型任务的异步线程池
-
file-per-thread-logger
将日志写入每个线程的单独文件中的日志实现
-
slog-atomic
为slog-rs提供的原子运行时可控的排空
-
parallel-processor
用于管理使用消息进行通信的多个计算单元的异步执行的框架
-
benjamin_batchly
低延迟批处理工具。将大量单个并发操作打包成顺序工作批次。
-
p3-maybe-rayon
围绕rayon的功能性包装器
-
tlrepo
线程局部git2::Repository,可在多个线程间共享
-
freezebox
可解引用的懒加载初始化容器
-
employees
一个小型运行时,隐藏使用线程时的所有样板代码
-
tc-scalar
TinyChain的标量值枚举,包括并发可解析的操作定义和引用
-
orx-parallel
适用于定义为由迭代器方法组合的计算的,性能高且可配置的并行计算库
-
pubserve
泛型观察者特质
-
evident
使用ID标识事件的Pub/Sub库
-
pariter
并行迭代器处理
-
rs-store
Rust的Redux存储
-
lock_ext
对 std::sync::Mutex 的扩展
-
balter
负载/压力测试框架
-
sharded-thread
目前为实验性
-
amity
并发算法
-
easy-threadpool
一个相对简单的线程池,可以向其中发送任务
-
may_actor
基于 MAY 的 Actor 库
-
batch-processing
一个用于并行处理一系列项的批处理库
-
atomic-interval
一个原子的计时器实现
-
whisk
快速的锁无异步通道
-
nebkor-maelstrom
创建 Maelstrom 分布式客户端的同步客户端
-
actify
具有最小样板代码的直观 Actor 模型
-
maybe-rayon
既可以作为rayon使用,也可以创建一个单线程的界面
-
idgenerator-thin
使用新的雪花漂移算法,ID更短,生成更快。核心是缩短ID长度,同时也能具有非常高的瞬时并发处理能力(50W/0…
-
atomic_enum
创建一个围绕C风格枚举的原子包装器的属性
-
renoir
Rust中的操作员网络
-
tatl
进程内警报
-
rayon-scan
ParallelIterator的并行前缀扫描函数
-
amfiteatr_classic
一些经典的游戏理论问题进行研究
-
loole
一个安全的异步/同步多生产者、多消费者通道
-
permit
用于取消操作的struct
-
td_rthreadpool
Rust的线程包装器
-
active_standby
高并发读取的原生并发机制
-
dynamodb_lock
基于Dynamodb的分布式锁
-
rusturnate
带有或没有超时的同步或异步互斥锁
-
ballista-executor
Ballista 分布式计算 - 执行器
-
fork-map
在由
fork()
产生的子进程中运行操作 -
tokio-cron
tokio 的 cron 调度器
-
woody
一个真正易于使用的Rust日志记录器
-
incr
快速且自包含的数据结构,用于检查新值是否大于之前的最大值
-
ordered-parallel-iterator
并行执行任务,按出现顺序返回已完成的任务
-
roboplc
PLC和实时微服务的框架
-
cron_runner
运行您计划中的任务的cron运行器
-
parcheck
测试并发场景的排列组合
-
ptr_cell
基于原子指针的线程安全cell
-
arthouse
为Project Lighthouse提供的Art-Net (DMX over UDP/IP)适配器
-
ringbuffer-spsc
快速线程安全单生产者-单消费者环形缓冲区
-
ordered-channel
一个始终按正确顺序接收消息的通道,即使它们是乱序发送的
-
nblock
非阻塞运行时
-
tracing-mutex
通过按顺序分配以确保无死锁的互斥锁,否则
-
mpmc-async
一个具有预留的多生产者、多消费者异步通道
-
thread_io
在后台线程中执行I/O操作
-
sharded-vec-writer
从不同的线程写入Vec的不同部分
-
timedmap
具有过期键值对的哈希表
-
命令执行器
命令执行器线程池
-
mpsc_requests
带有响应的mpsc通道
-
hydra-dashmap
dashmap的hydra框架分支
-
pausable_clock
可暂停和恢复的时间信息来源
-
mq
消息队列
-
left-right-cell
具有无锁并发读访问功能的单元格
-
txn_lock
支持事务版本控制
-
amadeus
Rust中的和谐分布式数据处理与分析。支持parquet postgres aws s3 cloudfront elb json csv logs hadoop hdfs arrow common crawl
-
rearch
重新构想的应用程序设计和架构方法
-
bi
-
spools
Instagram Threads的内容抓取库
-
simd-itertools
常用操作(如包含、最大值、查找等)的SIMD加速替代方案
-
thread_local_collect
支持跨线程收集和聚合线程局部数据
-
rtic-syntax
实时中断驱动的并发(RTIC)元语言
-
latches
一个向下计数器(CountDownLatch),可用于同步线程或协调任务
-
vin
一个易用的actor框架
-
atomic-file-install
用于原子性地安装文件或符号链接
-
per-thread-mutex
专为封装线程不安全C库设计的同步锁
-
pargraph
基于操作符的并行图处理
-
cargo-steady-state
基于结构化dot文件的steady_state项目代码生成器
-
rcu_cell
一个无锁rcu单元实现
-
lfchring
支持虚拟节点和跟踪复制的并发、无锁的一致性哈希环数据结构实现
-
may_waiter
协程通信阻塞器
-
rcu_128
支持原子128位操作的平台的RCU (Read-Copy-Update)实现
-
granite_reckoner
允许在指定数量的线程上对Vec
执行基本统计操作的聚合器。适用于Rust的所有内置数值类型。 -
rstreams
具有演员模型风格的异步流处理工具包
-
zallocator
通过分配更大的内存块来摊销小分配的成本
-
fetchchromium
快速获取Chromium构建版本
-
wiredtiger-rs
libwiredtiger的Rust绑定
-
asyncgit
允许在异步环境中使用git2
-
gettid
获取当前线程整数ID的辅助函数
-
patchver
将现有的Deno二进制文件升级到不同的版本
-
原子析构函数
适用于多线程环境的原子析构函数
-
fast-logger
Rust的快速日志记录器
-
node-replication
一种基于操作日志的方法,将单线程数据结构转换为并发、复制的结构
-
uactor
最快且最模块化的actor系统,不会让你为不需要的东西付费
-
cuda_std
与rustc_codegen_nvvm一起使用的CUDA标准库
-
global_counter
全局、线程安全的计数器
-
deborrow
安全地将可变引用分割成其字段,并帮助进行引用操作
-
work-queue
用于构建调度器的并发工作窃取队列
-
easy-parallel
并行运行闭包
-
pi_atom
全局线程安全的原子字符串池减少了相同字符串的内存占用,也用于HashMap键
-
trc
更快的 Arc
-
squeue
带大小限制的队列
-
antidote
标准库 Mutex 和 RwLock 类型无毒版本
-
rsevents
线程信号和编写新的同步原语(如信号量)的手动和自动重置事件
-
rust_kits
套件
-
xarray
具有写时复制的 XArray 版本
-
ppl
为 Rust 提供的并行编程库
-
leaklist
并发、无锁、单链表
-
rusty-cron-scheduler
遵循 cron 字符串执行函数指针的调度器
-
genzero
获取类型最新值的工具
-
atomic-maybe-uninit
未初始化整数上的原子操作
-
mongo-lock-async
使用 MongoDB 的分布式互斥锁
-
fs-lock
可像正常文件使用的加锁文件
-
blaze-rs
Rust 版本的 OpenCL 体验
-
chess_dl
Chess.com 游戏下载器
-
folklore
无锁并发哈希表
-
sync42
同步工具
-
prun
🍺 Run —
-
threadalone
使任何值 Send + Sync 但仅在原始线程上可用。不要在多线程环境中使用!
-
smolscale2
原始 smolscale 的 hitdns 分支
-
tari_shutdown
方便的关闭信号
-
non_blocking_mutex
非阻塞互斥锁是当前在高并发/负载/竞争下进行昂贵计算或锁内进行低成本计算的最快方式
-
async-ringbuf
异步 SPSC FIFO 环形缓冲区
-
stewart
一个最小化、高性能且非独占的演员系统
-
omango-futex
Rust 的 Futex
-
mogul
帮助管理事物并发版本的无感知工具
-
pacwrap-agent
执行代理,用于进行容器化事务
-
stuck
基于合作堆栈式协程的线程安全任务调度设施
-
dropout
将对象从主线程移除
-
asar-snes
Rust 的 Asar 绑定(https://github.com/RPGHacker/asar)
-
async_nursery
结构化并发原语
-
sea-streamer-examples
🌊 Rust 的流处理工具包
-
flashmap
一个无锁的最终一致并发哈希表
-
bastion
Rust应用程序的容错运行时
-
print_queues
可以从不同线程添加并可以在主线程上打印的打印队列
-
async-atomic
可以订阅并异步通知更新的原子操作
-
multithreading
在Rust中
-
sparking-lot-core
地址上的停车
-
threadpool-executor
线程池执行器
-
pinned-mutex
结构化固定的互斥锁包装器
-
semrs
信号量的纯Rust实现
-
crossbeam-utils
并发编程
-
uid
创建唯一ID
-
粥
ART-OLC 并发自适应基数树
-
workpool
将工作分配给一组线程并等待完成
-
k8s-gateway-api
Rust 对 Kubernetes Gateway API 的绑定
-
executors
一组高性能任务执行器
-
peace-lock
一种零成本的抽象锁,有助于检查无争用算法
-
kontroli
lambda-Pi 演算 modulo 重写类型检查
-
ring-channel
基于环形缓冲区的有界 MPMC 通道抽象
-
oxidd-rules-mtbdd
OxiDD 的多终端决策图 (MTBDDs)
-
synchronized
多线程中代码同步的方便简单宏
-
arena64
提供互斥访问受保护索引的并发竞技场
-
atomicell
基于原子的多线程 RefCell
-
arc-cell
用于包含 Arc/Weak 的简单 Cell-like 对象的辅助工具
-
tc-server
TinyChain 的集群服务器逻辑,包括节点发现和复制
-
undead
在您的 Python 项目中搜索死代码
-
task_pool
基于任务的灵活的多线程组合抽象
-
hala-lockfree
为 Rust 提供的一些无锁结构
-
app-world
管理前端应用程序状态的无框架方法
-
atomic_sibling_counter
一个共享计数器,允许并行线程/任务检查它们有多少个兄弟。计数器是原子的,线程/任务在没有任何方式下同步或耦合。
-
operational-transform
操作转换
-
wasm_sync
适用于 Web 和本地的同步原语
-
dagrs
名为 dagrs 的 DAG 引擎,设计用于执行具有图样依赖关系的多个任务。它提供高性能和异步执行,为 Rust 开发者提供方便的编程接口。
-
parseq
并行顺序迭代器
-
skipdb
一个嵌入式、内存中、零拷贝、原子性、一致性、MVCC、几乎无锁和可序列化的快照隔离数据库引擎
-
lock_api
创建功能齐全的互斥锁和RwLock类型的包装器。与no_std兼容。
-
lock_free_hashtable
无锁(几乎)仅插入的散列表
-
watch
一个同步消息传递通道,仅保留最新值
-
coro
堆栈满,一等非对称协程
-
snowdon
为Rust提供轻量级的线程安全雪花ID实现
-
direct_ring_buffer
适用于单生产者、单消费者场景的高性能、无锁环形缓冲区
-
ora-worker
Ora调度框架的一部分
-
atomic-waitgroup
支持异步和高级特性的waitgroup实现
-
tokio-condvar
Tokio应用程序的条件变量
-
deferred-reference
延迟引用实际上不是引用,它仅是一个与它所指向的位置的生命周期绑定的智能指针
-
session_types
Rust中的会话类型
-
redlock
基于Redis构建的分布式锁定机制
-
ump
线程/任务通信的微消息传递库
-
virtual-buffer
处理由原始虚拟内存支持的缓冲区的跨平台库
-
halt
暂停、停止和恢复迭代器、读取器和写入器的功能
-
circ
用于非阻塞并发的有效引用计数指针
-
pi_weight_task
任务池
-
rider
tokio的有限执行器;限制运行任务的数量 🚦
-
blackhole
...将线程投入其中
-
nolock
无锁数据结构集合
-
may_queue
May 的内部队列库
-
thread-object
对线程局部存储的抽象,允许动态创建 TLS 变量
-
interaction-calculus
一种并行计算模型
-
protoflow-blocks
Protoflow
-
round_mult
一个小型库,用于将数字四舍五入到乘数
-
lockfree
并发数据结构和 ABA 问题的解决方案,作为 hazard pointers 的替代
-
parking
线程挂起和唤醒
-
spry
类似于 Erlang/OTP 风格的弹性、自修复异步进程层次结构
-
simdvec
向量,但具有 SIMD 的操作速度提升!
-
cbloom
布隆过滤器并发实现
-
atomicbox
安全原子指针到封装数据
-
caos
并发只增不删段列表
-
leapfrog
快速无锁并发哈希表
-
atomicring
AtomicRingBuffer是一个固定大小的几乎无锁并发环形缓冲区
-
throttle-client
Throttle的客户端。Throttle是一个提供分布式系统信号量的HTTP信号量服务。
-
left-right
用于单写者数据结构上高并发读取的并发原语
-
axka-rcu
用于保护共享数据的引用计数读-拷贝-更新(RCU)原语
-
stronghold-stm
软件事务内存
-
rpools
Rust的极简工作者池
-
thread-tree
用于在工作者线程上分层拆分任务的树状结构线程池。树状结构意味着在交付任务时工作者之间没有竞争
-
orx-concurrent-ordered-bag
一种高效、便捷且轻量级的仅增长并发数据结构,允许高性能和有序并发集合
-
seqlock
一种提供极快读访问而不饿死写者的读写锁
-
noir-compute
Rust中的操作员网络
-
moro
为异步Rust提供实验性的结构化并发支持(类似于trio的nurseries)
-
papaya
适用于读密集型工作负载的快速且易于使用的并发哈希表
-
ebr
基于纪元的回收,具有低缓存行乒乓效应
-
backdrop_arc
在Backdrop!(稍后,在另一个线程上,或者两者都有!完全可定制!Tokio支持!)中丢弃其大型或复杂内容的一个Arc
-
flowync
多线程/同步
-
libblobd-direct
blobd,直接变体
-
mt-debug-counters
支持高性能调试计数器,适用于重多线程应用程序
-
游泳
游泳:高性能、无废话的连接池
-
highroller
线程安全的高级滚动索引,保证运行时唯一ID的低开销
-
conquer-once
懒加载和一次性初始化的同步原语
-
parking_lot_rt
适用于实时应用的停车场分叉
-
uf_rush
无锁、线程安全的并查集( disjoint-set)数据结构实现
-
arcow
原子引用计数的写时复制共享指针
-
sas
咸甜一线的Rust运行时性能优化库
-
hopper
无界mpsc,内存有界
-
jtp
线程池,类似于java中的ThreadPoolExecutor
-
single_value_channel
并发单值更新和接收通道
-
ratelimit_meter
基于 Rust 的漏桶式速率限制实现
-
visa
(虚拟仪器软件架构) 允许在来自不同供应商的 visa 实现之间进行并发和动态切换的包装器
-
base-threadpool
最小化的线程池实现
-
core-compute
快速、简单且跨平台的 GPGPU 并行计算库
-
sigq
队列,用于向等待消费者发出节点可用信号
-
stm
软件事务内存。允许组合原子操作。
-
idle
线程在没有工作可执行时使用的空闲策略集合
-
rpar
并行运行多个终端命令
-
rusty_junctions
Rust 中的连接模式实现
-
pi_share
rc, arc, lock, atomic
-
with_lock
避免死锁
-
goko
一个无锁、最终一致的并发Covertree
-
flue
一个高效且安全的actor运行时库
-
navactor
一个从管道输入创建和更新actor的cli工具
-
concurrent_lru
一个并发LRU缓存
-
ocl-interop
创建一个启用OpenGL Interop的OpenCL上下文
-
sig_fig_histogram
一种指数分布且对人类友好的直方图类型
-
coroutine
在Rust中
-
thread_lake
一个非常高级的线程池管理器
-
ligmars
对LGMP C库的安全绑定
-
gpu_rand
适用于Rust CUDA项目的GPU友好的随机数生成器
-
chashmap-async
具有键作用域锁定的并发异步哈希表
-
par-dfs
并行、串行和异步dfs和bfs遍历
-
read-write-api
统一单线程代码和基于RwLocks的代码的接口
-
async_logger
异步日志记录器允许将任意切片写入内存缓冲区,然后由其自己的线程中的写入器进行处理
-
hyperbridge
支持异步的快速多生产者多消费者通道
-
semanticsimilarity_rs
设计用于计算嵌入之间的相似度/距离度量
-
statman
统计管理器
-
rayon-wasm
Rust 的基于工作窃取的并行性
-
tokio-bichannel
tokio::sync::mpsc的双向通道
-
sync-extra
提供Mutex和RwLock的便捷函数
-
crossbeam-deque
并发工作窃取双端队列
-
crius
类似Hystrix的断路器
-
atomx
基于原子数据类型的线程安全数据结构
-
datacake-rpc
使用rkyv的零拷贝、类似actor的RPC框架
-
定期
按计划运行任务
-
上下文
使用Boost.Context的Rust合作多任务
-
either-slot
一个原子槽,发送者可以将值放入槽中,也可以从槽中检索所有数据
-
per-thread-object
高效的每个对象的线程局部存储实现
-
tlid
无原子/锁/随机/时间的预定义范围线程本地ID生成器
-
tagged-rendezvous
支持基于标签排除的 rendezvous 哈希
-
essential-lock
包含Essential的锁定方法的最小crate,在异步代码中使用是安全的
-
async-datachannel
datachannel的异步包装器
-
objectpool
无锁对象池,支持no_std
-
env-lock
为测试设置和锁定环境变量
-
unlock
帮助您解决性能问题的仪表化同步原语
-
xtensa-atomic-emulation-trap
非原子Xtensa目标的原子仿真陷阱处理程序
-
two_phase_channel
通过静态禁止冲突访问实现的安全无同步并行通信通道
-
rly
轻松并发运行shell命令。目前仅是一款CLI工具。
-
sentinel-core
您的微服务的流量哨兵
-
hey_listen
提供异步、同步、并行和优先级解决方案的事件分发器集合!
-
cuneiform-fields
Rust的[no_std]字段级缓存优化
-
real-time
与实时线程安全共享数据
-
rtic-monotonic
实时中断驱动的并发单调定时器的核心抽象
-
aramid
合成纤维
-
riker
轻松构建快速、高并发和健壮的应用程序。Rust的Actor框架。
-
acto
Rust的轻量级Actor库
-
adaptive-barrier
具有可调整线程订阅数量的屏障
-
stakker_log
为Stakker提供日志支持
-
arrayfire_fork
ArrayFire是一个易于使用的API的高性能并行计算软件库。它的基于数组的函数集使并行编程变得简单。ArrayFire具有多个后端(CUDA...
-
atomic-arena
代际区域允许从其他线程中预留键
-
namaste
-
readlock
Arc<RwLock<T>>的奇怪替代品
-
zkstate
使用zookeeper在应用程序的多个实例之间共享结构
-
pulse
异步唤醒信号
-
asparit
Rust的异步并行迭代器
-
queued-task
并发队列任务处理
-
rcron
为Rust提供cron作业调度
-
deque
一个(主要)无锁的并发工作窃取deque
-
quartz_sched
Rust 的极简调度库
-
frappe
Rust 的函数响应式编程库
-
readfish-tools
自适应采样数据分析工具
-
potential
为 futures 提供借用 - Potential 允许通过单次通道使用互斥锁和异步借用(租赁)进行内部修改
-
sync_2
提供 Rust 实现 Mutex 和 RwLock 的轻量级 crate
-
crosstalk
一个极其轻量级、基于主题、跨线程、内存通信库
-
currant
在 Rust 中启动并发 shell 进程
-
sortlock
提供有序锁定
-
syncthreads
安全的线程同步
-
disrustor
本项目是将 LMAX Disruptor 移植到 Rust 的项目
-
bztree
Rust 的 BzTree 实现
-
共享过期获取
Rust的并发异步获取与过期
-
原子计数器
Rust的原子(线程安全)计数器
-
job_abstrs
事件驱动作业的抽象
-
shrink_pool
一个线程池,一旦空闲就积极终止其线程
-
sea-streamer-stdio
🌊 SeaStreamer标准I/O后端
-
vigil
用于检测死锁/活锁/饥饿等问题的生存性检查看门狗
-
xrm
跨运行时管理器
-
ductile
一个通道实现,允许本地内存通道和基于远程TCP的通道具有相同的接口
-
xloc
一个用Rust编写的快速、多线程的行计数实用程序
-
yaks
一个用于通过rayon自动多线程hecs的最小化框架
-
crusty
在crusty-core之上开发的快速且可扩展的广域网爬虫
-
testtools
用于测试中消除样板代码的辅助工具
-
mvsync
一个独立的异步和工作线程库,具有可扩展的特性集和命令缓冲区
-
executor-service
一个类似于Java ExecutorService的快速高效的线程池
-
pinboard
一种无锁、线程安全的发布数据的方法,只需将其粘贴在磁板上即可
-
fast-counter
一个分片并发计数器
-
swimming-pool
在固定数量的线程上运行多个任务的线程池
-
coarsetime
针对速度优化的时间和持续时间crate
-
gpgpu
基于wgpu构建的WIP GPGPU框架
-
apalis-core
apalis的核心:为Rust提供简单、可扩展的多线程后台处理
-
redsync
用于Redis的分布式锁的Redlock
-
threadfin
一个线程池,用于在可配置的线程组上运行多个任务
-
parsli
Rust的并行状态行
-
geph-nat
在Geph中广泛使用的并发NAT功能
-
big_data
用于存储大数据的Erlang NIF的Safe Rust代码
-
rearch-tokio
重新构想的应用程序设计和架构方法
-
rust-debugging-locks
Rust中的锁调试
-
tourniquet-tonic
用于远程服务的异步原生轮询管理器。Tonic集成。
-
tokio-etcd-lock
进行中
-
talos_messenger_actions
Talos的消息传递动作
-
hammer-cli
Hammer是一个无需配置的cli工具,用于运行具有monorepo支持的并发任务
-
semaphore-key
使用共享信号量通过键控制并发线程访问
-
evlru
为无锁并发读取设计的最终一致LRU
-
rc_event_queue
类似于VecDeque的快速、无界、FIFO、并发读锁自由的消息队列
-
cht
无锁可调整大小的并发哈希表
-
atom_box
使用危害指针的安全 Rust 风格原子盒实现
-
humthreads
人类友好的线程
-
open-coroutine-iouring
为 open-coroutine 提供的 io_uring 支持
-
godwit-daemon
GodWit 的守护程序运行器
-
mongo_sync
通过命令行即时编码答案(就像 howdoi 一样)
-
async-sema
异步信号量库
-
takecell
一种只能取一次值的 cell 类型
-
dager
创建和执行节点图
-
pipelines
构建执行的多线程管道
-
simt
为 Rust 提供计算支持
-
ora-timer
Ora调度框架的一部分
-
sesh
无死锁的会话类型通信
-
pime
Rust Python 集成简化
-
threadstack
线程局部存储的更易于使用和更灵活的形式
-
slave-pool
线程池
-
async-map-reduce
基于线程的快速map-reduce
-
threadcell
只能由拥有线程访问其值的单元格
-
orx-concurrent-option
ConcurrentOption是一种无锁并发读写选项类型
-
usync
快速、即插即用的同步原语
-
rustodrive
Rust绑定,用于通过CAN协议控制多个ODrive
-
revenq
基于修订的事件队列实现
-
shared-resource-pool-builder
使用共享资源创建线程池
-
skipchannel
skipchannels允许线程之间进行通信,但总是跳到最后发送的值
-
unknownrori-simple-thread-pool
轻量级线程池,用于网络和其他任务
-
tcb
用于以因果关系顺序传递消息的中间件服务
-
supermon
通过通道协调观察者、中间件和消费者的实用工具集
-
scoped-threadpool-std
带密码哈希器的线程池实现和相关测试
-
native-timer
使用操作系统定时器功能的定时器库
-
nysa
在应用程序的独立子系统之间传递消息的总线
-
rayon_iter_concurrent_limit
使用便利的宏限制单个rayon并行迭代方法并发量
-
poolio
线程池
-
sync-unsafe-cell
为旧版Rust版本提供SyncUnsafeCell标准库类型的移植版本
-
read-write-store
用于Rust的并发、无序集合,每个元素都有一个内部生成的ID和一个读写锁
-
spmc
通道
-
rayon-par-bridge
使用传统的顺序Iterator处理Rayon并行处理
-
外交包
一种包装类型,允许您向不同的线程发送
!Send
类型 -
brutils
Rust 的一些实用工具
-
proglog
线程安全的进度日志
-
tokio-async-utils
异步实用工具,例如 TaskHandle 类型,在句柄释放时中止任务
-
evmap
一个无锁的、最终一致的、并发多值映射
-
oncemutex
提供一次性同步访问的互斥锁,然后进行安全的不同步访问
-
cooptex
无死锁的互斥锁
-
pcat
一个无死锁的并行 cat 实现
-
mutex
基于闭包的互斥锁的抽象
-
melodium-common
通用的 Mélodium 元素和特性
-
rusty_chain
对称为
链链接
的功能处理单元进行抽象。链中的每个链接都旨在是独立的、不可变的、幂等的,并且高度可测试。 -
entropy-ecs
一个虚拟世界
-
irox-threading
阻塞和非阻塞线程工具
-
cortexm-threads
在ARM Cortex-M(0, 0+, 3, 4, 4F)微处理器上实现上下文切换
-
seckoo
一个并发Cuckoo哈希表
-
ulock-sys
Rust对Darwin(例如macOS、iOS等)非完全公开的ulock API的绑定,该API提供类似futex的功能。
-
lockpool
提供锁池,可以通过键来锁定/解锁单个锁
-
channel-sender
通道发送者
-
netcon
NetCon Unternehmensberatung GmbH开发和为NetCon Unternehmensberatung GmbH开发的工具和辅助函数集合
-
no-std-async
为#[no_std] rust提供的异步同步原语
-
csplib
并发编程的CSP
-
clustr
多线程字符串聚类
-
steelmill
为分布式系统和仿真测试设计的资源管理器(依赖注入/工厂)
-
rush_core
规则引擎基于 rete 算法
-
priomutex
一个等待线程可以指定优先级的互斥锁
-
rt-history
具有错误检查的实时安全历史日志
-
rs_lockfree
基于实际危险指针算法的锁-free 库
-
jobsys
无锁工作窃取作业系统
-
callback_cell
类似于 Atomic
Option Box FnOnce()>>> -
atomicslice
线程安全的共享切片,读写速度尽可能快
-
go-spawn
提供宏来以最小化的样板代码启动和连接线程
-
rtfm-syntax
大众实时(RTFM)元语言
-
wrrm
写少读多包装器
-
ns3-parallel
ns-3(网络模拟器)的多任务并行并发执行器
-
refcell-lock-api
为 RefCell 实现的单线程锁_api,以允许在单线程和多线程代码之间进行抽象
-
refcapsule
安全地向其他线程发送引用
-
elysees
Triomphe 的分支,现在有更多指针技巧
-
swap_channel
基于 mem::swap 的安全无锁并行通信通道
-
rusty-jokes
一个有趣的 Rust 包,通过诸如“笑点寿命”、“喜剧并发”和“笑点指针”等功能为 Rust 程序员带来欢乐和娱乐
-
swctx
具有一些特殊语义的单次通道
-
vlock
具有无等待读取访问的快速且可扩展的多版本共享状态锁
-
interval-task
以固定时间延迟重复执行
Task
。比setInterval
更强大 -
or_poisoned
以语义方式解包 std 锁卫兵
-
wakerset
无 std、无分配存储 Future 类型中嵌入的 Wakers
-
ach-cell
原子通道
-
promise_out
rust版本的promiseOut
-
hvm-core
大规模并行交互组合评估器
-
dynamic_ocl
动态加载的OpenCL绑定
-
mpi-fork-fnsp
Rust的消息传递接口绑定(FORK)
-
managed-thread
真正的无畏并发!创建在不再需要时自动销毁的线程
-
deploy
deploy
库,用于辅助编写和调试分布式程序,以及跨集群运行它们的工具 -
ctx-thread
基于crossbeam和golang的context包的协作、作用域线程
-
cache-padded
通过填充和对齐到缓存行长度来防止伪共享
-
greenie
稳定的Rust中的绿色线程和协程
-
thfmr-protocol
为 TouHou.FM 广播项目提供的内部控制协议编解码库
-
cogo
类似 go 的 Rust 协程库
-
tokio-par-stream
由 tokio 驱动的并行流
-
wei-scheduler
wei 调度器
-
pcp-mutex
基于 Linux PI futex 的优先级天花板协议(PCP)互斥锁。允许高效且无死锁的执行。
-
thread_timer
无外部依赖的可取消计时器
-
fibril
使用通信纤维实现分布式系统
-
glock
Rust 的细粒度锁定crate
-
concurrent_open_map
Rust 中的并发哈希表实现
-
rewrk
HTTP 基准测试工具
-
conqueue
多生产者、单消费者队列(MPSC)
-
parallel-iterator
轻松并行化任何迭代器!
-
orx-concurrent-iter
线程安全、人性化和轻量级的并发迭代器特性和高效实现
-
lock_pool
健壮、高效、高性能、异步对象池
-
concurrency-demo-benchmarks
一个小型工具,用于评估构建并发应用程序的不同方法
-
shared_resources
线程安全和无锁的共享资源容器
-
crossbeam-skiplist
并发跳表
-
cell-family
通过唯一所有者访问的低成本单元格
-
blobd
为大量随机读取和具有恒定延迟的小对象设计的Blob存储
-
readlock-tokio
Arc<RwLock<T>>的一个奇怪的替代品,使用tokio的RwLock
-
shared-local-state
用于EBR、IO等的共享本地状态注册表
-
abyss-promise
[abyss] 一个具有自适应线程池支持的简单Promise实现
-
meslin
为Rust提供人性化的消息传递
-
sync_splitter
同时安全地在多个线程中分割可变切片
-
持久栈
并发持久栈
-
nbchan
高度优化的非阻塞通信通道
-
lock-free-static
无锁静态变量
-
win-events
实现 WaitForMultipleObjects 和 ManualReset、AutoReset 以及 Pulse 类型的拙劣尝试
-
dycovec
动态分配的并发向量
-
swapper
在线程间交换所有权
-
mpsc
mpsc 通道
-
autoincrement
用于不同目的的包装器
-
range-lock
std::vec::Vec 的范围锁
-
locktick
自动锁计账和剖析
-
peril
Rust 的快速且安全的风险指针
-
async-events
在异步 Rust 代码中等待外部任务完成
-
io_partition
允许仅使用 Read + Seek 对象的一部分
-
atomic_prim_traits
原始原子类型的特性
-
dci
DCI-Closed,一个常用频繁项集挖掘算法,用 Rust 实现
-
toktor
一个小型基于 tokio 的 Actor 框架
-
PRUEBA
任务队列
-
secc
为 Rust 实现了 Skip-Enabled Concurrent Channel (SECC)
-
moka
受 Java Caffeine 启发的快速并发缓存库
-
juliex
一个非常基本的未来执行器
-
gix-features
使用编译时功能标志集成各种功能
-
simple-rw-global
基于 std::sync::RwLock 的 GlobalContainer
-
fenic
测试并发代码
-
atomic-array
定义了多种数组类型,其中元素可以原子更新。旨在提供类似于Java中java.util.concurrent.atomic的原子数组类型。
-
disk_log
高吞吐量,非阻塞 的基于磁盘的日志记录器
-
atomicdouble
通用的128位原子类型
-
fan
简化了使用通道的扇出(以及最终 - 扇入)
-
arcstr
一种更好的引用计数的字符串类型,支持零成本(无需分配)的字符串字面量,以及引用计数的子字符串
-
ballista-scheduler
Ballista 分布式计算 - 调度器
-
despero-hecs-schedule
hecs 的可调度系统和并行执行
-
paradis-demo
paradis 的演示功能,不建议使用
-
timer-rs
用于在给定时间戳安排闭包执行的定时器
-
quick_cache
轻量级且高性能的并发缓存
-
synqueue
内部同步的(MPMC)队列
-
little_raft
最轻量级的分布式一致性库。运行您自己的复制状态机!
-
mwcas
多字CAS原语
-
futures-dagtask
基于DAG的任务队列
-
multichannel
具有动态通道注册和冻结的mpmc优先级多通道
-
distribuidos_sync
使用标准库同步的通用工具
-
magnetic
低延迟的无锁队列
-
shared_cell
同一线程上并发任务之间的内部可变性
-
seda_bus
一个基于阶段事件驱动的架构的消息总线
-
hv-guarded-borrow
用于“受保护”借用泛型使用的特性和实现
-
mini-io-queue
固定长度、分配和锁-free、异步I/O导向的单生产者单消费者队列
-
lofi
低开销的纤程
-
efflux
Rust中的简单MapReduce和Hadoop Streaming接口
-
std-semaphore
从rust 1.7.0提取的计数、阻塞信号量
-
kcas
一个无锁、无分配的多字比较和交换库
-
cloudi
API
-
async-map
一个很少加锁的,共享的Rust映射
-
rapidsync
快速且线程安全的嵌入式数据存储
-
nemo
异步网络会话类型
-
rtrb-basedrop
使用basedrop的共享指针代替Arc的rtrb crate的分支
-
thread-pool-task
一个基于线程池的任务执行库
-
threadpool
一个轻量级的线程池实现
-
threadpool-executor
Protoflow
-
v0.1.0 no-std #executor #threadpool
threadpool-task
-
v0.1.0 no-std #task #executor #threadpool
threadpool-tasks
-
v0.1.0 no-std #executor #threadpool #tasks
threadpool-utils
-
多线程
数据并行任务的API,rayon-lite
-
node-workers
一组长期运行的nodejs工作进程
-
status_executor
在某个上下文(线程)上运行您的任务并获取状态信息
-
shmap
基于Unix共享内存文件(shm)的键值存储,用于跨程序重启持久化状态
-
ccd
一个简单、快速的Windows Chrome_cookie_decryptor
-
parallel_reader
并行读取文件(或任何
Read
流),并按块进行处理 -
lazy_ref
实现了一个非阻塞同步原语,用于延迟初始化不可变引用
-
amfiteatr_proc_macro
为amfiteatr_*包提供的程序宏crate
-
dekker
Dekker的互斥算法
-
rusty_hausdorff
有向Hausdorff距离的并行实现
-
sea-streamer-file
🌊 SeaStreamer 文件后端
-
测试平台
用于并发 Rust 代码的测试和基准测试工具
-
scrummage
操作系统进程优先级争夺战
-
tucan
快速且支持多线程的内部器,对类型要求宽松
-
rgraph
任务图库
-
stronghold-rlu
类似同步机制的 Read-Log-Update 软件事务内存
-
cnr
基于操作日志的数据复制方法
-
dfmutex
无死锁互斥锁
-
threadpooled
线程池实现
-
is_main_thread
一个简单的工具,用于检查当前线程是否为主线程
-
rayon-core
Rayon 的核心 API
-
object-space
用于在 Rust 中编写的非常并发的程序的对象存储库
-
spsc-ringbuf-core
无堆环缓冲区
-
concurrent_prime_sieve
生成带有素数的过滤器集合的工具。Rust实现的Atkin筛法。此实现运行在O( sqrt(max_num) + section_size )(其中section_size = max_num - min_num)...
-
concurrent-round-robin
rust的并发wrr实现
-
skippy-rs
通过跳表实现的一系列无锁、线程安全且快速的数据结构
-
rayon_logs
rayon工作窃取库的跟踪信息
-
paragraphs
一个并行图执行库
-
discord-termview
在Discord中启动多个并发Unix终端
-
foco
基于主题的强类型no_std rust pubsub
-
grandma
一个无锁、最终一致的并发Covertree
-
sleepfast
快速睡眠非常小的时间
-
workerpool-rs
rust的workerpool
-
atomicbox_nostd
atomicbox库的分支,适用于no_std环境
-
schedwalk
测试所有可能的轮询调度下的未来
-
locktree
实验性的编译时死锁检测
-
todc-utils
构建和测试分布式系统
-
queuingtask
queuingtask 是一个用于在 Rust 中按顺序运行不同线程的库
-
talaria
高性能、循环消息传递库
-
bmrng
异步 MPSC 请求-响应通道,适用于 Tokio
-
ipmpsc
进程间多生产者、单消费者通道
-
open-coroutine-queue
使用 st3 和 crossbeam-deque 实现的并发工作窃取队列
-
tyra
类型化 Actor 系统
-
rsevents-extra
基于 rsevents 的同步对象。信号量、倒计时事件等。
-
kademlia-dht
Kademlia DHT
-
hexchat-api
HexChat 插件开发 API
-
bursty
测试多线程代码中加剧竞争的支持
-
task-notify
在有人修改他们感兴趣的数据时通知异步任务
-
maxim
基于 Erlang / Elixir 和 Akka 的最佳实践,实现了一个高度可扩展且易用的 Rust 基础上的 actor 系统。是 Axiom actor 框架的一个分支。
-
task-exec-queue
异步任务执行队列
-
cpq
使用 Safe Rust 实现的并发优先队列
-
channel-receiver
通道接收器
-
maybe_parallel_iterator
使用功能标志切换并行性!
-
spinning
通过自旋实现互斥锁和 SIX 锁
-
threatpool
线程池
-
rayon-tlsctx
rayon 循环的线程局部上下文
-
mpc-bench
多方计算实验库
-
reactor_rs
reactor-rust 是 Reactive-Streams 的实现
-
slb
分片负载均衡文本流式 Unix 工具
-
ora
调度框架
-
rustls-split
一个可以单独从不同线程发送和接收数据的 rustls TCPStream 包装器
-
tc-fs
TinyChain 的交易文件系统接口层
-
shardize
进程宏,用于生成创建现有容器分片形式的代码
-
killable_thread
线程包装器,允许其被合作地轻松停止
-
stoppable_thread
线程包装器,允许其被合作地轻松停止
-
one_at_a_time_please
用于串行化对函数的调用
-
sever
强制将硬链接转换为新文件
-
yaambo
并发跳表
-
conquer-util
并发和无锁编程
-
single_executor
并发原语的特性
-
spliter
实现 Rayon 的并行迭代器的方法
-
tenorite
一个并发抽象库。提供异步工作者的客户端-服务器模型
-
runloop
可取消的非阻塞轮询线程(可选的超时时间)
-
thread-control
控制线程的执行/状态
-
poolter
使用类似于 JavaScript Promise 的函数式语法实现的 Rust 线程池
-
rayon_croissant
<lqd> 对名称进行讨论:映射折叠并收集,一个 🥐
-
darc
动态原子引用计数的指针(概念验证)
-
jadesrandomutil
为 Jade 提供的 Rust 随机实用库
-
lariv
链式原子随机插入向量:一个线程安全、自管理内存的向量,没有保证的顺序插入
-
classic-sync
使用经典 Linux 互斥锁系统的 ReentrantLock、Semaphore 和 CyclicBarrier
-
spawns-executor
为线程上下文任务生成器提供异步执行器
-
atomic-bus
原子 MPMC 总线
-
blinkcast
快速、有界、多生产者、多消费者、有损的广播通道
-
drive-server
使用 mDNS 在本地交换文件
-
norpc
进程内微服务框架
-
mioco
基于可伸缩、异步 IO 协程处理的处理(即 MIO 协程)
-
ev_slotmap
无锁、最终一致的并发槽映射
-
threads_pool
此包提供了一种创建和管理线程池的简单方法,因此您不必
-
rdispatcher
Rust 的调度器,多对多广播和订阅
-
npnc
无锁队列
-
threadpool-simple
用于轻松处理多个任务的线程池
-
inert
允许以同步方式使用非同步值
-
rust-releases-core
rust-releases 的基础特性和定义
-
specs-static
为 Specs 添加自定义 ID 的扩展
-
barriers
屏障自旋锁实现
-
update_channel
用于单个可更新值的通道
-
malobu
原子 MPMC 总线
-
crossbeam-skiplist_piedb
并发跳表
-
cupchan
通过交换杯子实现无等待阻塞的异步线程间覆盖通道
-
gosh-remote
在多个节点上执行分布式并行计算
-
lazy_id
线程安全的延迟初始化 ID
-
sublock
RwLock/RefCell 的变体,支持子锁,当主
RwLock
以读取方式打开时,以读取方式打开,当主RwLock
以写入方式打开时,以写入方式打开 -
fast-async-mutex
提供异步锁定机制(Mutex、RwLock、OrderedMutex 和 OrderedRwLock)的库
-
contrie
并发映射和集合
-
zkmq
基于Zookeeper的消息队列
-
safenv
标准库中的
env
模块的线程安全包装器 -
amadeus-parquet
Rust中的Apache Parquet实现
-
scoped-pool
提供作用域线程的灵活线程池
-
witty-actors
quickwit-actors的分支,quickwit中使用的Actor框架
-
hadron-client
Hadron Rust客户端库
-
microlock
等待:小型锁和其他定时功能!
-
thread-local-panic-hook
每个线程工作的Panic钩子
-
atomic_pingpong
轻量级no_std ping-pong缓冲区,使用AtomicU8进行同步
-
water
线程安全的分布式消息发送设施,支持跨进程和机器边界的同步和异步I/O。它还使用nets,允许消息广播到所有…
-
android-wakelock
安全且人体工程学的Rust对Android WakeLock API的绑定
-
ringbuf-basedrop
基于ringbuf的crate分支,使用basedrop的Shared pointer代替Arc
-
piper
异步管道、通道、互斥锁等
-
busan
Rust的actor实现
-
async-mutex
异步互斥锁
-
atomic-memcpy
字节级别的原子memcpy
-
structured_persistent_logger
支持持久字段的有序结构日志记录器
-
thread_db
libthread_db的Rust封装
-
denog_runtime
denog运行时库
-
pawawwewism
一个用于结构化并发非常严重的工具,我保证:3
-
key-message-channel
支持按消息键排队消息的多生产者单消费者队列
-
多线程snowflake
Twitter的id生成器算法snowflake的rust-lang实现,线程安全
-
streambed模式
streambed工作模式
-
arcu
使用Arc保持读临界区,并处理清理的Rcu实现
-
fused-reader
如果写线程在持有武装的fused时死亡,则fused reader将得到BrokenPipe错误
-
atomic-story
关于原子操作和多线程上下文中的内存排序的简要概述,包括示例
-
threadpool_scope
为threadpool crate添加作用域
-
smartpool
一个高度可定制、具有未来意识的线程池
-
captain-workflow-manager
在多种后端上运行和管理相互依赖的工作项
-
lib-wc
Will的编程工具箱
-
tinypool
Rust中的线程池实现
-
para
数据流/管道并行化框架
-
有序锁
编译时死锁避免
-
try-mutex
快速非阻塞互斥锁
-
spinout
类似于
Arc<Mutex<T>>
的线程安全、可克隆和可变智能指针,使用自旋锁代替系统 futex -
waithandle
使线程间的信号更加人性化
-
atomic-destroy
一个可以原子读取和销毁的值;类似于原子 Option
-
adirector
具有有限大小的异步 tokio 任务创建器
-
shared_channel
多生产者、多消费者 FIFO 队列通信原语
-
async-datachannel-wasm
浏览器环境中的 WebRTC 数据通道的异步包装器
-
arrows
Rust 中的一个具有消息持久性和消息顺序处理的actor框架
-
key-rwlock
带键的异步读写锁
-
caring
分享就是关爱:一个用于在多个进程中对内存进行 mmap 的安全库
-
rtfm-core
Real Time For the Masses 框架的核心抽象
-
jackiechan
针对延迟批量操作的边界mpsc通道优化
-
jobpool
轻量级线程池实现
-
xio_jobset
XIO jobset 数据类型
-
flexible-locks
灵活的锁
-
mrogalski-looper
针对单线程事件循环的清晰抽象。作为 std::sync::mpsc 包的轻量级包装构建。
-
mtxgroup
mutex group 锁定所有互斥锁同时
-
base-coroutine
具有支持抢占式调度的调度器的快速且安全的栈满协程实现
-
gemino
多生产者多消费者 (MPMC) 广播通道
-
slog-json-concur
具有并发性的slog-rs JSON 排水口
-
run-them
一个用于以多个工作进程执行单个命令并序列化输出的命令行工具
-
mp2c
一个多生产者多轮询消费者库,允许多个生产者完全异步地向多个消费者发送消息
-
cpu-affinity
跨平台CPU亲和力
-
syncell
RefCell的同步替代方案
-
gaffer
具有并发排除、作业合并、周期性作业和低优先级负载限制的优先级并行作业调度器
-
maybe-sync
为希望在使用多线程和单线程版本之间切换的库提供辅助crate
-
concurrency_traits
并发原语的特性
-
verona-rt
verona运行时的惯用绑定
-
swap-arc
可交换的Arc
-
raliguard
用于异步代码频率执行的懒速率限制信号量实现
-
threadgroup
将线程组作为一个单元进行管理,加入第一个完成的线程,在加入尝试时超时
-
geese_pool
Geese网络通信的消息传递系统
-
async-liveliness-monitor
适用于异步运行时的存活度监控器
-
mth_calc
演示Cargo。包含在所有可用处理器上并行运行进程的辅助方法。
-
dashmap_with_out_t_map_trait
Rust 的超快速并发 HashMap
-
acteur
一个安全且即插即用的actor-like框架。简单、健壮、快速、文档齐全。
-
kiss-icp
kiss-icp的非官方纯Rust实现
-
simplelock
进程间同步的抽象
-
jthread
Rust的无死锁互斥锁
-
dynqueue
可动态扩展的Rayon并行迭代器
-
indigo
现代应用的框架和实用程序库
-
melodium-engine
Mélodium核心引擎和执行器实现
-
coroutines
具有原生体验的高性能协程库
-
ppipe
一个简单轻量级的库,用于使迭代器管道并发执行并达到极快的速度,因此得名ppipe(并行管道)
-
faucet
一种背压式 MPMC 队列,在信号完成之后可以排空
-
workctl
为并发工作调度提供高级控制机制的库,基于标准库的并发原语
-
yastl
作用域线程池库
-
genserver
受 Elixir 启发的异步 actor 库
-
thread_reviver
一个 Discord 机器人,可以恢复任何存档的线程(以对抗 Discord 的自动存档功能)
-
atomic-try-update
原语,可轻松实现正确的无锁算法
-
process_control
以限制的方式运行进程
-
tc-tensor
TinyChain 的 Tensor 集合类型
-
sentinel-rocket
Sentinel 中间件用于 Rocket
-
atomic-borrow
原子引用计数器
-
hv-lease-tracker
兼容 no-std 的借用来源跟踪,以在实现内部可变性原语时提供更好的诊断
-
readahead-iterator
在单独的线程上从迭代器进行预读,按顺序同步返回项目
-
lines-rs
⚡ 使用Rust编写的快速行计数器
-
thread-lock
一个将非Send和非Sync数据锁定到特定线程的包装器
-
lock_freedom
并发数据结构和 ABA 问题的解决方案,作为 hazard pointers 的替代
-
colosseum
Rust的各种竞技场分配器,包括线程安全的竞技场
-
membarrier
进程范围内的内存屏障
-
uchan
用于消息传递的多生产者单消费者通道
-
rayoff
rayon但它是map-reduce
-
semalock
以安全和高效的方式并发写入文件
-
lossyq
固定长度的并发单发布者单消费者队列,从不阻塞写入者
-
forkjoin
一个用于Rust的工作窃取fork-join并行库
-
bastion-executor
Rust 的缓存亲和 NUMA 感知执行器
-
mbarc-map
最小阻塞的原子引用计数映射
-
cas-lib
CAS 的核心库
-
spsc-buffer
单生产者单消费者无锁缓冲区
-
tasque
线程池库
-
consume
当已知编译器无法省略依赖时的内存顺序消耗
-
promissory
线程间的单次值交换
-
stretto
高性能线程安全内存绑定 Rust 缓存
-
bufchan
缓冲的 MPSC 通道
-
threadbeam
用于从新创建的线程中传输数据的专用通道类型
-
key-mutex
通过键访问互斥锁
-
rusty-variation
无死锁的会话类型通信
-
try-rwlock
快速非阻塞的读写锁
-
可共享
使用最少的同步机制实现的线程可共享对象
-
protoflow-flume
Protoflow
-
zestors
一个快速灵活的actor框架,用于构建容错鲁棒的Rust应用
-
dyn_object
Box<dyn Any>的舒适和线程安全版本
-
todc-mem
共享内存分布式系统的算法
-
channel_io
字节数据通道的读取器实现
-
rust-waitgroup
类似于Golang的WaitGroup
-
ringbuf-blocking
ringbuf的阻塞版本
-
lagoon
具有多种功能的线程池crate
-
yuki
多线程网络存档器
-
simple_event_map
基于通道的事件映射,提供阻塞或异步的接收器
-
fixed_ring_buffer
异步SPSC固定容量的无锁环形缓冲区,可用于在两个线程或两个异步任务之间传输数据
-
rush_expr_engine
规则引擎基于 rete 算法
-
nvrtc
NVIDIA® CUDA™ NVRTC 的 Rust 绑定
-
exclusion-set
一个无锁并发集合
-
parallel-event-emitter
基于 futures-rs 和 futures-cpupool 的并发监听器调用的并行事件发射器
-
double-checked-cell-async
使用双重检查锁的线程安全的懒加载 cell
-
hyaline-smr
用于无锁数据结构的垃圾收集器(Hyaline- 安全内存回收)
-
threadpool-crossbeam-channel
threadpool 的一个分支,使用 crossbeam-channel 而不是 std::mpsc
-
uppercut
小型简单actor模型实现
-
sync-cell
一组易于使用的线程安全类型,用于创建更大的线程安全系统
-
safe-lock
一个具有
const fn
构造函数且无unsafe
-
mscheduler
使用 mongodb 来安排任务运行
-
chunker
简约并行执行器
-
sea-streamer-socket
🌊 SeaStreamer 后端无关 Socket API
-
quinine
原子单调容器(Mono{Box,Arc})
-
spin-sync
使用自旋锁的同步原语。接口类似于 std::sync。公共结构的构造函数是 const;即只要 T 可以静态构建,就可以声明静态 Mutex<T>。
-
lock-free-freelist
适用于多生产者和消费者的快速无锁有限长自由列表
-
fast-threadpool
线程池实现,优化以最小化延迟
-
laststage
快速、耐用、高并发 HashMap
-
fenris-paradis
为 fenris 库并行处理不相交索引
-
workers_pool
用于并行任务执行的长运行线程池
-
rt-watchdog
Rust 的实时用户空间看门狗
-
paladin-core
分布式算法工具包。在不涉及分布式系统编程复杂性的情况下编写分布式算法。
-
maybe-async-channel
可能异步也可能不是异步的通道
-
consumable_vec
创建多个生产者和消费者共享数据库的通用方法
-
crossbeam-epoch
基于Epoch的垃圾回收
-
rs_taskflow
执行任务图
-
pacwrap-core
为pacwrap提供核心功能
-
atomic-hyperloglog
具有原子操作的线程安全hyperloglog
-
rcell
一个可以持有Arc或Weak智能指针或为空的Cell
-
thunk
Rust中通用惰性评估的原始工具。此crate需要夜间版以使用
untagged_unions
。 -
scherben-map
Rust的并发分片HashMap
-
minicoroutine
Rust中的小型协程库
-
hv-cell
将
atomic_refcell
crate的no-std端口,并增加了以Arc
为中心的功能 -
actors-rs
轻松构建快速、高并发和健壮的应用程序。Rust的Actor框架。
-
rustpool
Rust的数据和线程池库
-
lockless
可组合、无锁、轻量级分配的数据结构
-
pflock
一种减少读者最坏情况阻塞的相公平读写锁。特别适用于多处理器实时系统。
-
threadbath
线程池的最小实现
-
context-coroutine
提供堆栈协程的扩展集;它不是与context crate官方关联的
-
spin_loop
-
worker-pool
处理一组工作线程,这些线程需要将结果回传给主线程
-
fiona
针对liburing编写的并发运行时
-
more-sync
更多同步工具
-
employer
启动工作线程并在之后检查它们
-
send-cell
具有运行时发送检查的不可变内存区域
-
burstq
支持在单个操作中发送或接收多个值的多个生产者、多个消费者通道
-
bombs
高效的单一生产者多消费者通道类型
-
agner-utils
受 Erlang/OTP 启发的演员工具包(utils)
-
hytra
快速多线程更新的数据结构
-
sync-wait-group
用于同步某些计算的开始或结束的等待组
-
voluntary-servitude
具有无锁迭代器的线程安全可追加列表
-
wasefire-sync
可移植的非阻塞互斥锁
-
iterator_ilp
指令并行归约的迭代器扩展
-
concurrency_toolkit
轻松在 std::sync, tokio::sync 和 loom::sync 之间切换
-
mpmc
从旧 rust stdlib 复制粘贴
-
amadeus-types
Rust 中和谐的分布式数据分析
-
portable-atomic-util
使用 portable-atomic 构建的同步原语
-
terminate
终止线程、协程等逻辑的抽象
-
once_mut
只能获取一次的静态变量的安全可变引用
-
acto-rs
实验性actor库,正在开发中。(原名minions_rs)。
-
ach-ring
原子通道
-
concurrent-biproxy
一个并发代理,用于从一个客户端向另一个客户端传递消息
-
balter-runtime
负载/压力测试框架
-
sero
用于维护共享锁存储的轻量级库
-
thread-broadcaster
用于在线程之间广播通知的SPMC(单生产者多消费者)广播通道
-
ach-util
原子通道
-
sync_cow
线程安全的写时复制容器,用于快速并发读写
-
linux-rtic
Linux的实时中断驱动的并发(RTIC)实现
-
queue-ext
队列的扩展功能可以将队列的pop()函数转换为Stream,将push()函数转换为Sender
-
bichannel
基于std::mpsc的零依赖双向通道
-
ocl
Rust的OpenCL绑定和接口
-
closure-future
轻松在线程池中运行闭包并将它们的结果转换为Futures
-
momen
低开销线程池
-
haphazard
使用危害指针的锁免费数据结构的动态内存管理
-
stream-channel
通道中的流
-
gothack-future-parking_lot
为parking_lot提供尽可能简单的Future实现
-
locklessness
可组合、无锁、轻量级分配的数据结构
-
xarc
xarc
提供原子可交换、原子计数引用智能指针,作为比原始原子指针更安全的锁免费算法构建块。Xarc
类似于Arc
但… -
kik_sync_service
一个同步线程工作通道,用于使用所需数据生成所需结果
-
overdose
快速、面向行的、类似Kotlin/Scala的数据框
-
request-channel
异步 MPSC 请求-响应通道
-
sorted-channel
基于消息的排序通信通道
-
srmap
一个无锁的、最终一致的、并发多值映射
-
proc-lock-api
proc-lock 包的 API
-
dynpool
轻量级、灵活且可伸缩的线程管理器
-
c-map
非常快的并发哈希表
-
std-threadpool
线程池实现
-
ste
一个具有一些技巧的单线程执行器
-
mrsc
带有请求的 mpsc
-
atomic_box
一个结构,允许多个线程安全地更新和读取共享的非空指针到堆数据
-
bounded-spsc-queue
一个有界 SPSC 队列
-
pool_barrier
一个屏障,用于阻塞主线程,直到将工作卸载到工作线程完成,而不阻塞工作线程
-
rendezvous_swap
在成对线程之间高效交换数据和同步执行
-
governor
使用Rust实现的速率限制器
-
arl
与tokio一起使用的速率限制器
-
ping-pong-cell
适用于最多两个线程的原子单元
-
hurdles
基于计数的线程屏障
-
orx-pinned-concurrent-col
一种核心数据结构,专注于通过使用PinnedVec作为底层存储来启用高性能、可能无锁的并发集合
-
tasic
Tokio, Async_STD, Smol, 接口包
-
monotone
用于分布式系统中协调的计数器和队列
-
fuze
一种等待单个信号的机制,该信号可以在任何时间检查
-
mpmcpq
多生产者多消费者优先级队列
-
treiber_stack
无锁、线程安全、原子的链表
-
thread-owned-lock
只能由拥有线程解锁的互斥锁
-
work_pool
由线程池包装的工作队列
-
a_r_c_h_e_r_y
临时板条箱
-
remutex
递归互斥锁,源自Rust标准库
-
syncmap
快速、并发的缓存库,注重性能和正确性。构建syncmap的动机来自Go语言的sync.Map
-
my_threadpool
threadpool
-
movie
演员/线程编排库/宏/框架
-
user-sync
用户空间同步
-
rhythm
允许VIP的速率限制器,用Rust编写
-
oxidd-rules-zbdd
OxiDD的零抑制决策图(ZBDDs)
-
async-once-watch
异步且可共享的容器,其值仅设置一次
-
atomic_immut
原子不可变值
-
protoflow-zeromq
Protoflow
-
kernel
抽象响应式流
-
atomic-queue
用于音频应用的限界无锁队列,移植自 https://github.com/max0x7ba/atomic_queue
-
sea-streamer-redis
🌊 SeaStreamer Redis 后端
-
init_guard
防止重复初始化的同步原语
-
rcurs
氧化 RCU 实现
-
qrwlock
公平队列读写锁
-
melodium-repository
Mélodium 的存储库管理 crate,具有依赖关系解析和检索
-
polyester
接受任意迭代器的并行迭代器适配器
-
triex
简单执行器
-
jobsteal
用 Rust 编写的作业窃取 fork-join 线程池
-
boomerang
'反应器' 确定性演员模型
-
evelyn
事件分发库
-
ump-server
ump的服务器消息分发循环
-
pipeliner
使用迭代器的并行编程友好接口
-
lock-hierarchy
通过强制锁层次结构来防止死锁
-
access-queue
限制对值的并发访问数量
-
embassy-sync
无标准库,无分配的同步原语,支持异步
-
sentinel-tower
Tower的哨兵中间件
-
par-map
并行map和flat_map
-
amadeus-aws
Rust 中和谐的分布式数据分析
-
rustc-rayon-core
Rayon的核心API - rustc的分支
-
hybrid-lock
带有乐观锁的混合锁
-
llq
具有可重用节点的无等待SPSC链表队列
-
wasserglas
具有自动重新附加的固定大小线程安全对象池
-
parking_monitor
停车场的监控同步构造
-
rustix-futex-sync
基于Linux futex的同步
-
semaphorus
原子信号量
-
observable-btree
响应式观察BTree
-
sea-streamer-runtime
🌊 SeaStreamer 异步运行时抽象
-
infinitree-macros
具有分层缓存的嵌入式加密数据库
-
option-lock
Option值的互斥锁
-
dynamic-pool
一个无锁、线程安全的动态大小对象池
-
waitcell
包含可能尚未可用值的单元格类型
-
mycorrh
Rust的快速并发消息系统
-
taskpile
线程池实现
-
fibril_verifier
验证使用Fibril库实现的分布式系统的行为
-
eventbus
安全、快速且并发的事件系统,灵感来源于MinecraftForge事件总线
-
fluxion
使用Rust编写并设计用于分布式系统的actor框架
-
pairlock
具有无等待读操作的读者-写者锁
-
atomic_cell
无锁线程安全的可变内存位置
-
chashmap
具有广泛API的快速、并发哈希表
-
stoplight
可停止的任务/线程
-
hv-elastic
用于延长生命周期和“借用”非静态类型的几乎安全和不安全的抽象
-
paradis-core
paradis的核心功能
-
ccl
用于高度并发系统的高效数据结构
-
taskschd
windows taskschd演示
-
riffy
无界、无等待、多生产者单消费者队列
-
venom_log
Rust异步日志高性能异步日志
-
bound
将锁卫和其他结构体以及它们通过共享引用派生的锁或其他数据,封装在一个可以传递并存储在任何地方的结构体中
-
bondi
单生产者、多消费者无锁环形缓冲区(实验性)
-
rslint_rowan
为rslint项目提供的rowan的线程安全版本
-
lightproc
Rust的轻量级进程抽象
-
rework
基于主从模式的线程化任务处理
-
optimistic-cell
用于低开销乐观并发锁样结构
-
grizzly_scheduler
使用cron表达式运行异步任务的调度器。它建立在tokio之上。任务可以是并行或顺序的。可以给cron表达式添加模糊随机偏移量。
-
thread-safe
允许线程不安全对象线程安全的容器
-
amadeus-commoncrawl
Rust 中和谐的分布式数据分析
-
arbalest
类似于Arc
,但弱引用不会禁止可变访问 -
hiatus
通过选择特定的执行跟踪来调试并发程序
-
kiss-icp-runtime
kiss-icp的非官方纯Rust实现
-
theatre
简洁的异步actor模型实现
-
open-coroutine-core
open-coroutine 是一个简单、高效且通用的协程库
-
slock
一个不会死锁的异步互斥锁
-
locker
rust-lang 并发中的命名互斥锁/locker
-
async_ach-notify
异步原子通道
-
kai-cli
Kai - todo.txt 任务调度器
-
static_locks
parking_lot 锁,但可用于静态和 const fn
-
future-parking_lot
为parking_lot提供尽可能简单的Future实现
-
threads
抽象线程池的特质
-
hv-atom
基于
atom
crate 的智能指针/引用类型原子操作的便捷抽象 -
waitable
一个同步(原子)值容器,实现了 Mutex+Condvar 模式,以实现高效的阻塞等待
-
countdown_latch
一个同步辅助工具,允许一个或多个线程等待,直到其他线程中正在执行的一组操作完成
-
zsling
Rust 在 Zig 编写的顺序锁定(SeqLock)环形缓冲区上的包装器
-
liblightning
高性能通用堆栈协程库
-
pmpmc
优先级多生产者多消费者通道
-
rayon-core-wasm
Rayon 的核心 API
-
hybridfutex
为高争用场景设计的有效混合等待队列 futex,支持同步和异步等待和通知。支持在所有目标上使用 notify 和 notify_many。
-
storage-map
并发只增存储映射
-
logmap
使用日志作为桶的并发 hashmap
-
read-cell
只读 Cell 对应物
-
taskqueue
能够在运行任务内添加新任务的并行执行任务队列
-
unsync_channel
Rust 的 !Send/!Sync 通道
-
sstb
线程安全的 sstables 库
-
sling
顺序锁定 (SeqLock) 环形缓冲区
-
borrowed-thread
通过 thread::spawn 线程安全地传递借用
-
倒水
可选的合并基数树,以快速执行集合操作
-
waitmap
一个可等待的并发哈希表
-
tiny-actor
Rust 的一个最小化actor框架
-
run-down
Rust 中的保护
-
lft-rust
一个无锁线程池实现。我们提供了一个传统的单队列线程池和一个无锁线程池
-
tange-collection
数据流计算
-
futex-queue
基于 Linux futex 的一个高效的 MPSC 队列,具有计时器功能。适用于实时应用。
-
horde
threads
-
tokio-sync-read-stream
使用 Tokio 阻塞线程从 std::io::Read 创建流
-
fencing
令牌
-
clone-replace
通过克隆和替换引用版本来共享可变数据
-
brod
一个提供并行执行Kafka生产者API的包装库
-
namedlock
命名锁的命名空间
-
roundabout
一个面向消息的并发运行时
-
blazemap
实现了一个类似slab的基于向量的映射,具有类似于HashMap的接口,还提供了生成轻量级标识符的工具,这些标识符可以作为此映射的键安全使用
-
exit-future
向多个接收者发出退出信号的Future
-
metadata-store
用于原子批量写入的可恢复元数据的存储
-
parking_lot_core
创建自定义同步原语的先进API
-
cura
arc锁系统,应该能大量清理代码
-
protoflow-syntax
Protoflow
-
std-mel
Mélodium标准库
-
double-checked-cell
使用双重检查锁的线程安全的懒加载 cell
-
wei-task
wei任务
-
ya-ring-buf
环形缓冲区。字节/复制直接访问的SPSC通道。
-
bbq-rs
用于数据交换和性能分析的基于块的有限队列
-
prawnypool
Rust中使用线程池的接口
-
spsc-bip-buffer
具有大小预留的并发、SPSC环形缓冲区
-
lf-queue
无锁的多生产者多消费者无界队列
-
af-opencl-interop
ArrayFire是一个具有易于使用的API的高性能并行计算软件库。此crate是ArrayFire crate的扩展,使用户能够在Rust和ArrayFire中混合RAW CUDA代码。
-
work-steal-queue
使用 st3 和 crossbeam-deque 实现的并发工作窃取队列
-
refptr
固有的引用计数结构体
-
bastion-qutex
依赖于无锁和其他非阻塞(线程)技术(如Rust futures)的同步机制,以确保对数据的互斥或共享独占访问
-
ora-scheduler
Ora调度框架的一部分
-
ump-ng-server
ump-ng的消息调度循环服务器
-
syncbuf
具有无锁线程安全和常数时间索引的只追加数据结构
-
rtic-core
实时中断驱动的并发框架的核心抽象
-
sentinel-actix
Actix-Web的哨兵中间件
-
shared-mutex
一个可与其Condvar一起使用的RwLock
-
sento
一个无锁、只追加的原子池
-
cortex-m-rtfm
面向大众的实时系统(RTFM):构建实时系统的并发框架
-
tyractorsaur
类型化 Actor 系统
-
kabuki
名称预订
-
mailbox_processor_rs
受FSharp MailboxProcessor启发的Actor抽象
-
mpmc-ringbuf
队列
-
json-mel
Mélodium JSON数据处理库
-
sea-streamer-kafka
🌊 SeaStreamer Kafka / Redpanda 后端
-
datacake-sqlite
使用 SQLite 实现的 datacake 存储 trait 的预构建实现
-
conveyor_belt
队列和批量处理库
-
af-cuda-interop
ArrayFire 是一个易于使用的 API 的并行计算高性能软件库。此 crate 是在 ArrayFire crate 的基础上添加的,以使用户能够在 rust 和 ArrayFire 中混合 RAW OpenCL 代码。
-
lock-free-multi-producer-single-consumer-ring-buffer
一个无锁的、多生产者、单消费者(MPSC)环形缓冲区。针对发送和接收消息“爆发”进行了优化。也可以用作环形队列。它是 Mindaugas Rasiukevicius 的 ringbuf 的 Rust 端口。
-
provenant
Arc 的一种版本,可以通过概率性地跟踪来源来在存在弱指针时释放内存
-
macgyver-lock
基于 Memcache 的锁实现
-
rjq
Redis 作业队列
-
rolock
只读锁