Lib.rs

› 关键词 #spsc #环形缓冲区 #无锁 #kafka #异步 #单消费者 #先进先出

生产者-消费者

  1. rdkafka

    Rust 对 librdkafka 的封装

    v0.36.2 567K #生产者-消费者 #apache-kafka #kafka #消息 #偏移量 #分区 #代理

  2. oneshot

    具有（可能）无锁非阻塞发送的 spsc 通道，以及支持线程阻塞接收操作以及基于 Future 的异步轮询的接收器

    v0.1.8 566K #一次性通道 #通道 #spsc #异步 #单消费者 #同步 #生产者-消费者

  3. crossbeam-queue

    并发队列

    v0.3.11 3.1M #队列 #无锁队列 #mpmc #无锁 #生产者-消费者 #消费者 #生产者

  4. ringbuf

    无锁 SPSC FIFO 环形缓冲区，可直接访问内部数据

    v0.4.4 128K #环形缓冲区 #无锁 #fifo #spsc #生产者-消费者 #内存访问

  5. embassy-sync

    无 std，无 alloc 的同步原语，支持异步

    v0.6.0 72K #异步通道 #同步原语 #消费者 #互斥锁 #多个 #生产者-消费者 #embassy

  6. triple_buffer

    三级缓冲，用于在线程之间共享频繁更新的数据

    v8.0.0 3.2K #生产者-消费者 #多线程 #同步 #非阻塞 #无等待 #spsc #多线程

  7. samsa

    Rust 本地 Kafka/Redpanda 协议和客户端实现

    v0.1.7 130 #生产者-消费者 #apache-kafka #kafka #redpanda #confluent #内存安全 #API 绑定

  8. reactive-mutiny

    异步事件驱动反应式库，具有高级和优化的容器（通道）和流执行器

    v1.1.26 1.0K #事件驱动 #微服务 #异步流 #反应式 #异步 #性能 #生产者-消费者

  9. datafusion-substrait

    DataFusion Substrait 生产者和消费者

    v41.0.0 5.8K #数据融合 #生产者-消费者 #substrait #apache-arrow #大数据 #计划 #查询引擎

  10. bbqueue

    一个基于BipBuffers的SPSC（单生产者单消费者）、无锁、非标准、线程安全的队列

    v0.5.1 5.0K #线程安全 #单生产者 #队列 #无锁队列 #生产者-消费者 #内存 #SPSC

  11. async-ringbuf

    异步SPSC FIFO环形缓冲区

    v0.3.1 750 #环形缓冲区 #fifo #SPSC #异步 #生产者-消费者 #rb

  12. gstreamer-utils

    提供对象以使用一个生产者和多个消费者构建多个Gst管道

    v0.23.0 2.5K #gstreamer #视频 #多媒体 #音频-视频 #gnome #生产者-消费者 #音频

  13. loole

    一个安全的异步/同步多生产者、多消费者通道

    v0.3.1 400 #通道 #mpmc #mpsc #生产者-消费者 #异步 #线程 #发送-接收

  14. command-executor

    命令执行线程池

    v0.1.1 #线程池 #生产者-消费者 #消费者 #生产者 #mpmc #并发 #执行命令

  15. atomic-queue

    用于音频应用的带界无锁队列，移植自https://github.com/max0x7ba/atomic_queue

    v2.2.0 300 #无锁队列 #生产者-消费者 #音频 #多生产者 #带界 #实时 #多个

  16. direct_ring_buffer

    适用于单生产者、单消费者场景的高性能、无锁环形缓冲区

    v0.2.0 #环形缓冲区 #无锁 #SPSC #环形缓冲区 #生产者-消费者 #数据结构 #数据访问

  17. mpsc_requests

    具有响应的mpsc通道

    v0.3.4 230 #生产者-消费者 #响应 #线程 #消息 #请求 #多个 #请求接收器

  18. atomx

    基于原子数据类型的线程安全数据结构

    v0.2.6 180 #线程安全 #线程 #原子 #并行 #单生产者 #并发 #生产者-消费者

  19. high-level-kafka

    Rust的 高级Kafka客户端

    v0.2.4 #kafka #高级 #rdkafka #客户端 #异步 #消息解析器 #生产者-消费者

  20. sea-streamer-examples

    🌊 Rust的流处理工具包

    v0.5.0 200 #stream-processing #processor #producer #producer-consumer #data-processing #data-stream #batch

  21. sod-mpsc

    面向服务的架构 - 多生产者单消费者

    v0.3.4 #service-oriented #multi-producer #single-consumer #pattern #service #producer-consumer #design-pattern

  22. mspc_ipc

    用于进程间通信的多生产者单消费者环形缓冲区

    v0.1.3 290 #ipc #single-consumer #ring-buffer #producer-consumer #inter-process #communication #crash

  23. rdkafka-wrap

    rdkafka封装

    v0.1.12 #kafka #rdkafka #producer-consumer #kafka-wrap #kafka-cli #api-bindings

  24. ringbuf-blocking

    ringbuf的阻塞版本

    v0.1.0-rc.3 410 #ring-buffer #blocking #spsc #fifo #producer-consumer #rb #memory-access

  25. spmc

    通道

    v0.3.0 9.9K #channel #queue #producer-consumer #single-producer #thread #multiple

  26. nscldaq_ringmaster

    NSCLDAQ RingMaster 的 RUST 替代品 - 只需 ring2stdout

    v0.2.7 #ring-buffer #data #nscldaq #producer-consumer #replacement #client #ringmaster

  27. magnetic

    低延迟无锁队列

    v2.4.1 #lock-free-queue #fifo-queue #queue #lock-free #fifo #producer-consumer

  28. ringbuf-basedrop

    基于 basedrop 的共享指针而不是 Arc 的 ringbuf 的分支

    v0.1.1 #ring-buffer #lock-free #fifo #spsc #producer-consumer #shared-ptr #shared-data

  29. rt-history

    带有错误检查的 RT 安全历史日志

    v3.0.0 #history #real-time #log-error #wait-free #synchronization #lock-free #producer-consumer

  30. tiny_kafka

    具有生产者和消费者功能的小型 Kafka 客户端库

    v1.0.4 #producer-consumer #kafka #producer #consumer #streaming #rust-client

  31. disrustor

    该项目是将 LMAX Disruptor 移植到 Rust 的项目

    v0.4.0 #disruptor #lmax #producer-consumer #port #wait #blocking #strategy

  32. avassa-client

    集成 Avassa API

    v0.5.0 #avassa #client #api-bindings #producer-consumer #information #volga #integrating

  33. spsc-ringbuf-core

    无内存堆栈环形缓冲区

    v0.1.0 #ring-buffer #single-consumer #single-producer #producer-consumer #heapless #spsc #indices

  34. simple-kafka

    更易使用的 Kafka 消息

    v0.0.8 #kafka #producer-consumer #message #topic #broker

  35. 市场

    生产者和消费者基础设施

    v0.30.1 200 #producer-consumer #consumer #producer #stock #agent #goods #infrastructure

  36. bounded-spsc-queue

    有界 SPSC 队列

    v0.4.0 #queue #producer-consumer #bounded #spsc #thread #data-structures #buffer

  37. uchan

    多生产者单消费者消息传递通道

    v0.1.4 #channel #thread #mpsc #fifo #producer-consumer

  38. atomic_pingpong

    轻量级无_std ping-pong 缓冲区，使用 AtomicU8 进行同步

    v0.2.3 #buffer #producer-consumer #element #single-consumer #ping-pong #synchronization #size

    39. 尝试使用 DuckDuckGo 搜索 搜索.

  39. bombs

    高效的单生产者多消费者通道类型

    v0.2.1 #non-blocking #lock-free #spmc #atomic #producer-consumer

  40. mp2c

    一个多生产者多轮询消费者库，允许多个生产者异步地向多个消费者发送消息

    v0.1.2 #send-message #consumer #producer-consumer #multi-consumer #multiple #polling #thread

  41. lock-free-multi-producer-single-consumer-ring-buffer

    一个无锁的多生产者单消费者 (MPSC) 环形缓冲区。针对发送和接收消息“突发”进行了优化。也可以用作环形队列。这是 Mindaugas Rasiukevicius 的 ringbuf 的 Rust 版本。

    v0.4.0 #ring-buffer #ring #buffer #lock-free #queue #mpsc #producer-consumer

  42. ya-ring-buf

    环形缓冲区。具有直接访问字节的 SPSC 通道。

    v0.1.0 #ring-buffer #ring #spsc #channel #producer-consumer

  43. lock-free-freelist

    一个快速的无锁限长空闲列表，适用于多生产者和消费者

    v0.1.0 #lock-free #list #producer-consumer #usize #limited #length #bitmap

  44. 可消费的向量

    创建多个生产者和消费者共享数据库的通用方法

    v0.4.0 #producer-consumer #utility #generic #mutual #approach #create #multiple

  45. oyashio

    spmc流

    v0.0.4 #stream #consumer #spmc #producer-consumer #iterator #functions

  46. tokio-by-hand

    future

    v0.0.0 #future #producer-consumer #sink #consume #standard #task #stream