1 个不稳定版本
0.1.0 | 2024年6月26日 |
---|
#904 in 异步
68 每月下载量
用于 8 个crate(2个直接使用)
27KB
611 行
SPSC字节通道
单个生产者、单个消费者异步字节通道。通道的 ByteReader
和 ByteWriter
端点分别实现了Tokio的 tokio::io::AsyncRead
和 tokio::io::AsyncWrite
特性。
合作运行
目前,Tokio crate之外的类型无法高效地参与Tokio的协作让步机制。为了解决这个问题,字节通道有自己的可选协作机制,该机制通过coop
特性标志启用。
要使用协作机制,请将任何顶级任务futures用RunWithBudget
包装。扩展特质BudgetedFutureExt
为所有futures添加方法以分配任务预算。预算在该future中的所有字节通道之间共享。
每当这些通道之一取得进展时,它将消耗一个预算单位。耗尽预算的通道将重置预算并在重新安排自己后立即让步给运行时。
依赖
~3.5–10MB
~93K SLoC