Lib.rs

› 关键字 #channel #mpsc #queue #async #future #spmc #thread #concurrency

#mpmc

  1. async-channel

    异步多生产者多消费者通道

    v2.3.1 3.9M #mpmc #mpsc #unbounded-channel #bounded-channel #future #chan #spmc

  2. 并发队列

    并发多生产者多消费者队列

    v2.5.0 3.2M #mpmc #channel #mpsc #spmc #spsc

  3. crossbeam-channel

    用于消息传递的多生产者多消费者通道

    v0.5.13 6.1M #channel #message #mpmc #golang #select

  4. flume

    一个闪电般快速的多生产者通道

    v0.11.0 2.5M #channel #thread #mpsc #mpmc #fifo

  5. futures-intrusive

    基于侵入性数据结构的基础设施——适用于 std 和 no-std 环境

    v0.5.0 1.2M #synchronization-primitive #channel #oneshot-channel #future #intrusive #async-await #mpmc

  6. disruptor

    通过环形缓冲区进行低延迟的线程间通信（受 LMAX Disruptor 启发）

    v3.2.0 550 #single-consumer #ring-buffer #mpmc #message #multi-consumer

  7. kanal

    Rust 应得的快速同步和异步通道

    v0.1.0-pre8 58K #async-channel #channel #communication-channel #oneshot-channel #data-channel #async #mpmc

  8. triggered

    任务和线程之间的一次性事件触发器

    v0.1.2 48K #event #events #mpmc #oneshot #sync #async #task

  9. watchable

    与多线程和异步代码兼容的类似于 RwLock 的类型

    v1.1.2 11K #async #mpmc #thread #asynchronous

  10. sharded_queue

    ShardedQueue 是当前最快的并发集合，可在高并发和负载下使用

    v2.0.1 #queue #concurrency #mpmc #concurrent-queue

  11. whisk

    快速的锁免费异步通道

    v0.13.0 #async-channel #channel #actor #mpmc #notifier #event-iterator

  12. loole

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

    v0.3.1 400 #channel #mpmc #mpsc #producer-consumer #async #thread #send-receive

  13. may_queue

    May的内部队列库

    v0.1.22 310 #queue #mpsc #spsc #mpmc #spmc #stackful-coroutine #multi-threading

  14. ring-channel

    基于环形缓冲区上的有界MPMC通道抽象

    v0.12.0 12K #ring-buffer #channel #mpmc #bounded-channel #lock-free #fifo

  15. command-executor

    命令执行器线程池

    v0.1.1 #thread-pool #producer-consumer #consumer #producer #mpmc #concurrency #execute-command

  16. atomicring

    AtomicRingBuffer是一个固定大小的几乎无锁的并发环形缓冲区

    v1.2.9 1.1K #ring-buffer #lock-free #concurrency #queue #memory #overhead #mpmc

  17. batch-channel

    通过一次读取和写入多个值来减少开销的异步通道

    v0.4.1 700 #async-channel #channel #async #reduce #values #reading #mpmc

  18. crosstalk

    一个极轻量级的基于主题的跨线程内存通信库

    v0.2.7 #channel #mpmc #thread #distributed #async #aerospace

  19. multiqueue2

    一个快速的mpmc广播队列

    v0.1.7 230 #queue #mpmc #broadcast #message #lockless #single-consumer

  20. atomic-bus

    原子MPMC总线

    v0.1.0 #bus #non-blocking #mpmc

  21. rc_event_queue

    类似于VecDeque的快速、无界、FIFO、并发读锁自由的消息队列

    v0.4.2 210 #message-queue #queue #lock-free-queue #lock-free #fifo-queue #mpmc #events

  22. mpmc

    从旧的rust stdlib复制而来

    v0.1.6 1.7K #queue #mpmc #no-std #multi-consumer #multi-producer #stdlib #old

  23. 塔拉里亚

    一个高性能、循环消息传递库

    v0.1.1 #channel #message #mpsc #mpmc #ring #bounded-channel

  24. async-priority-channel

    一个异步通道，待处理消息按优先级顺序传递

    v0.2.0 46K #async-channel #future #mpmc #chan #spmc #mpsc #bounded-channel

  25. multiqueue

    一个快速的mpmc广播队列

    v0.3.2 350 #queue #mpmc #message-queue #broadcast #lockless #single-consumer

  26. npnc

    无锁队列

    v0.2.1 #lock-free-queue #queue #mpmc #bounded #unbounded #spsc

  27. blinkcast

    快速、有界、多生产者、多消费者、有损耗的广播通道

    v0.2.0 100 #broadcast-channel #channel #broadcast #mpmc #no-std

  28. secc

    为 Rust 实现跳过启用并发通道（SECC）

    v0.0.10 #channel #concurrency #mpmc #concurrent #message-sent

  29. broadcaster

    广播 mpmc 通道的未来

    v1.0.0 2.9K #mpmc #future #broadcast-channel #broadcast #channel #futures

  30. gemino

    一个多生产者多消费者（MPMC）广播通道

    v0.7.0 #channel #async-channel #mpmc #multi-consumer #async #broadcast

  31. burstq

    支持在单个操作中发送或接收多个值的多个生产者、多个消费者通道

    v0.1.0 #channel #mpmc #fifo #mpsc #sender #multiple-values

    32. 尝试使用 DuckDuckGo 进行搜索。搜索.

  32. mpmcpq

    多生产者多消费者优先级队列

    v0.9.3 #priority-queue #mpmc #synchronization #messaging #channel #send-message #send-receive

  33. mpmc-scheduler

    多 mpmc、可取消、带速率限制的调度器

    v0.3.1 #scheduler #mpmc #queue #tokio #mpsc #rate-limiting #task-scheduler

  34. thread-broadcaster

    一个 SPMC（单生产者多消费者）广播通道，用于在线程之间广播通知

    v0.1.0 #channel #spmc #mpmc #parallelism #concurrency #single-producer #multi-threading

  35. pmpmc

    一个优先级多生产者多消费者通道

    v1.0.0 #channel #thread #multi-consumer #mpmc #mpsc #multi-producer #async

  36. lf-queue

    一个无锁多生产者多消费者无界队列

    v0.1.0 #lock-free-queue #mpmc #spsc #spmc #mpsc

  37. mpmc-ringbuf

    队列

    v0.1.4 #queue #mpmc #consumer #multiple #producer #ringbuf #block

  38. syncbox

    Rust 的并发工具

    v0.2.4 500 #thread-pool #queue #mpmc #concurrency

  39. faa_array_queue

    Rust 的 Fetch-And-Add 数组队列实现

    v0.1.2 #queue #lock-free-queue #lock-free #mpmc

  40. channel_pipes

    在广播队列上执行操作

    v0.2.0 #channel #mpsc #mpmc

  41. sorted-channel

    基于排序的消息通信通道

    v0.1.1 #sorting #channel #communication-channel #mpmc

  42. stochastic-queue

    一个随机顺序出队的队列和多生产者多消费者通道

    v0.2.0 #queue #order #channel #mpmc #random #pops #items

  43. barrage

    一个异步广播通道

    v0.2.3 700 #broadcast-channel #channel #broadcast #async #future #mpmc #futures

  44. mpmc-map

    针对高度并发且写操作少的异步多生产者多消费者映射实现

    v0.2.0 #map #mpmc #async

  45. two-lock-queue

    基于 Michael-Scott 两种锁队列算法的多生产者多消费者通道

    v0.1.1 240 #queue #mpmc #channel

  46. lockness

    TODO

    v0.0.2 #atomic #queue #lock-free #lockless #mpmc #lock-free-queue #atomics

  47. crtq

    一个多生产者多消费者无锁队列

    v0.1.1 #wait-free #queue #mpmc #unbounded #lock-free

  48. crosstalk-macros

    crosstalk 的过程宏 —— 一个极轻量级、基于主题、跨线程、内存通信库

    v0.2.7 800 #channel #mpmc #distributed #thread #async #aerospace #proc-macro

  49. futures-mpmc

    futures 的 MPMC 队列

    v0.1.0 #mpmc #queue #future

  50. chan

    已弃用。请使用 crossbeam-channel。

    v0.1.23 3.7K #channel #golang #mpmc #asynchronous #select