summaryrefslogtreecommitdiffstats
path: root/tokio/src/sync/rwlock.rs
diff options
context:
space:
mode:
authorCarl Lerche <me@carllerche.com>2020-05-06 19:02:07 -0700
committerGitHub <noreply@github.com>2020-05-06 19:02:07 -0700
commit4748b2571fc02d5ebbfe59e457f0e8d8ef0eb5f3 (patch)
tree73da1e3baba02bad5411a222ff62490304932fe7 /tokio/src/sync/rwlock.rs
parent66fef4a9bcccd944e3b72b1e83f789e4131d4e52 (diff)
rt: simplify coop implementation (#2498)
Simplifies coop implementation. Prunes unused code, create a `Budget` type to track the current budget.
Diffstat (limited to 'tokio/src/sync/rwlock.rs')
-rw-r--r--tokio/src/sync/rwlock.rs3
1 files changed, 1 insertions, 2 deletions
diff --git a/tokio/src/sync/rwlock.rs b/tokio/src/sync/rwlock.rs
index 68cf710e..4e2fb74d 100644
--- a/tokio/src/sync/rwlock.rs
+++ b/tokio/src/sync/rwlock.rs
@@ -1,4 +1,3 @@
-use crate::coop::CoopFutureExt;
use crate::sync::batch_semaphore::{AcquireError, Semaphore};
use std::cell::UnsafeCell;
use std::ops;
@@ -116,7 +115,7 @@ impl<'a, T> ReleasingPermit<'a, T> {
lock: &'a RwLock<T>,
num_permits: u16,
) -> Result<ReleasingPermit<'a, T>, AcquireError> {
- lock.s.acquire(num_permits).cooperate().await?;
+ lock.s.acquire(num_permits).await?;
Ok(Self { num_permits, lock })
}
}