zesterer flume issues - Githubissues

zesterer / flume

A safe and fast multi-producer, multi-consumer channel.

https://crates.io/crates/flume

Apache License 2.0

2.37k stars 84 forks source link

issues

Newest

Newest Most commented Recently updated Oldest Least commented Least recently updated

Update dev dependencies

#153 jayvdb opened 1 week ago
0
Performance with many senders on multi-threaded runtime

#152 Frando opened 2 months ago
0
Threads waiting for data go to the front of the queue

#151 fulara closed 2 months ago
2
chan.waiting `push_front` instead of `push_back`? Thread scheduling

#150 fulara closed 2 months ago
1
Add missing const _IS_BIASED in test/mpsc.rs

#149 rikkaka closed 3 months ago
1
[feat] add shrink_to_fit() to Sender<T> and Receiver<T>

#148 rakbladsvalsen opened 4 months ago
2
[feat] add shrink_to_fit() to Sender<T> and Receiver<T>

#147 rakbladsvalsen closed 4 months ago
3
Memory leak in unbounded channels

#146 rakbladsvalsen opened 4 months ago
1
Clarify behavior rendezvous channels

#145 orlp closed 4 months ago
10
Resize the capacity of bounded channels

#144 Frando opened 4 months ago
2
Add `Sender::force_send`

#143 BTOdell opened 6 months ago
2
Add a `force_send()` function to `flume::Sender`?

#142 BTOdell opened 6 months ago
0
recv on an empty unbounded channel keeps the task busy.

#141 fulmicoton closed 7 months ago
1
`SendFut::poll` should return `Poll::Pending` for rendezvous channels when no item is queued

#140 thomaseizinger opened 8 months ago
0
Do we need to add a timeout for `recv_async`?

#139 zhuxiujia closed 8 months ago
1
Add spinlock implementation without `std::thread::sleep`

#138 white-axe closed 1 month ago
12
Senders and receivers are both unusable in browser main thread in WASM

#137 white-axe closed 1 month ago
0
Add `Clone` conformance to `WeakSender`

#136 bwoods closed 9 months ago
2
Lost message when selecing on MPMC in loop from multiple threads

#135 asonix opened 9 months ago
2
Semantic violation that involves rendezvous channel and selector

#134 sgdxbc opened 11 months ago
4
async selector

#133 vortex314 closed 11 months ago
2
MPMC Not working or no Broadcasting

#132 lsabi closed 11 months ago
3
Generic over backing storage / statically allocated bounded channels

#131 kyrias opened 1 year ago
1
Make remaining core channel spinlock opt-in

#130 kyrias closed 1 year ago
3
Document features

#129 kyrias closed 1 year ago
1
Question: Fairness when multiple receivers are doing work-stealing

#128 GermanCoding closed 1 year ago
2
Update Cargo.toml

#127 Dylan-DPC closed 1 year ago
1
Add `SendFut::into_inner`.

#126 NathanSWard opened 1 year ago
6
`async`: `send_timeout` & `send_deadline`

#125 NathanSWard opened 1 year ago
3
The last messge won't be triggered in async code block.

#124 SethWen closed 1 year ago
8
feat: add same_channel() method

#123 Sherlock-Holo closed 1 year ago
4
`flume::Sender<T>` stops to send messages to `flume::Receiver<T>` when passed through `.await` point

#122 vikulikov closed 1 year ago
2
Fix a race condition in the async code

#121 inetic closed 1 year ago
1
Race condition in the async code when sender drops too quickly

#120 inetic closed 1 year ago
1
Awaiting disconnection of Receiver or Sender

#119 Kijewski opened 1 year ago
2
Update actions/checkout in GitHub Actions workflows to v3

#118 striezel opened 1 year ago
0
Allow Non 'static items for use of async types

#117 ericmcbride closed 1 year ago
1
SendError cannot be sent between threads?

#116 stevefan1999-personal opened 1 year ago
1
Add 'documentation' field to Cargo.toml

#115 Stonks3141 closed 1 year ago
1
Update benchmarks to reflect current performance

#114 TimonPost opened 1 year ago
2
Remove lifetime constraint on Reciever.drain()

#113 wyatt-herkamp closed 1 year ago
2
Clean up some of the async code + remove pin_project

#112 coolreader18 closed 1 year ago
1
Add {Sender,Receiver}::{sender,receiver}_count()

#111 coolreader18 closed 1 year ago
3
Expose sender_count / receiver_count to the user

#110 coolreader18 closed 1 year ago
0
Create a `WeakSender` type that does not keep the channel open

#109 phil-opp closed 1 year ago
5
Implement Debug for async futures/streams

#108 jf2048 opened 1 year ago
4
Add a `WeakSender`?

#107 phil-opp closed 1 year ago
4
Allow using `into_stream()` with non-`'static` items

#106 Seeker14491 closed 1 year ago
4
Slow results with Multi Consumer, Single Producer

#105 Bobonium opened 2 years ago
3
Document cancel safety

#104 madadam opened 2 years ago
16