skip biased semaphore
This commit is contained in:
parent
77fab86a11
commit
4fe4dab385
@ -551,16 +551,18 @@ impl App {
|
|||||||
})
|
})
|
||||||
.await;
|
.await;
|
||||||
|
|
||||||
let semaphore_permit = tokio::select! {
|
let semaphore_permit = semaphore.acquire_owned().await?;
|
||||||
biased;
|
|
||||||
|
|
||||||
p = semaphore.acquire_owned() => {
|
// let semaphore_permit = tokio::select! {
|
||||||
p
|
// biased;
|
||||||
}
|
|
||||||
p = self.bonus_ip_concurrency.clone().acquire_owned() => {
|
// p = semaphore.acquire_owned() => {
|
||||||
p
|
// p
|
||||||
}
|
// }
|
||||||
}?;
|
// p = self.bonus_ip_concurrency.clone().acquire_owned() => {
|
||||||
|
// p
|
||||||
|
// }
|
||||||
|
// }?;
|
||||||
|
|
||||||
Ok(Some(semaphore_permit))
|
Ok(Some(semaphore_permit))
|
||||||
} else {
|
} else {
|
||||||
@ -590,19 +592,21 @@ impl App {
|
|||||||
})
|
})
|
||||||
.await;
|
.await;
|
||||||
|
|
||||||
let semaphore_permit = tokio::select! {
|
let semaphore_permit = semaphore.acquire_owned().await?;
|
||||||
biased;
|
|
||||||
|
|
||||||
p = semaphore.acquire_owned() => {
|
// let semaphore_permit = tokio::select! {
|
||||||
p
|
// biased;
|
||||||
}
|
|
||||||
p = self.bonus_user_concurrency.clone().acquire_owned() => {
|
// p = semaphore.acquire_owned() => {
|
||||||
p
|
// p
|
||||||
}
|
// }
|
||||||
p = self.bonus_ip_concurrency.clone().acquire_owned() => {
|
// p = self.bonus_user_concurrency.clone().acquire_owned() => {
|
||||||
p
|
// p
|
||||||
}
|
// }
|
||||||
}?;
|
// p = self.bonus_ip_concurrency.clone().acquire_owned() => {
|
||||||
|
// p
|
||||||
|
// }
|
||||||
|
// }?;
|
||||||
|
|
||||||
Ok(Some(semaphore_permit))
|
Ok(Some(semaphore_permit))
|
||||||
} else {
|
} else {
|
||||||
|
Loading…
Reference in New Issue
Block a user