jmarya/comrade
jmarya/comrade
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

⚡️ increase queue bound

Browse source
This commit is contained in:
JMARyA 2025-03-09 06:34:41 +01:00
parent b043db3f4e
commit c010cc13e8
Signed by: jmarya
GPG key ID: 901B2ADDF27C2263
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/job.rs
View file

@ -270,7 +270,7 @@ impl<I: Send + 'static, O: Send + 'static> JobDispatcher<I, O> {
/// ``` /// ```
#[must_use] #[must_use]
pub fn new() -> (Self, Receiver<JobOrder<I, O>>) { pub fn new() -> (Self, Receiver<JobOrder<I, O>>) {
let (sender, receiver) = crossbeam::channel::bounded(12); let (sender, receiver) = crossbeam::channel::bounded(8092);
(Self { sender: sender }, receiver) (Self { sender: sender }, receiver)
} }