diff options
Diffstat (limited to 'src/runtime/thread_pool/idle.rs')
| -rw-r--r-- | src/runtime/thread_pool/idle.rs | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/runtime/thread_pool/idle.rs b/src/runtime/thread_pool/idle.rs index ae87ca4..6e692fd 100644 --- a/src/runtime/thread_pool/idle.rs +++ b/src/runtime/thread_pool/idle.rs @@ -55,7 +55,7 @@ impl Idle { } // Acquire the lock - let mut sleepers = self.sleepers.lock().unwrap(); + let mut sleepers = self.sleepers.lock(); // Check again, now that the lock is acquired if !self.notify_should_wakeup() { @@ -77,7 +77,7 @@ impl Idle { /// work. pub(super) fn transition_worker_to_parked(&self, worker: usize, is_searching: bool) -> bool { // Acquire the lock - let mut sleepers = self.sleepers.lock().unwrap(); + let mut sleepers = self.sleepers.lock(); // Decrement the number of unparked threads let ret = State::dec_num_unparked(&self.state, is_searching); @@ -112,7 +112,7 @@ impl Idle { /// Unpark a specific worker. This happens if tasks are submitted from /// within the worker's park routine. pub(super) fn unpark_worker_by_id(&self, worker_id: usize) { - let mut sleepers = self.sleepers.lock().unwrap(); + let mut sleepers = self.sleepers.lock(); for index in 0..sleepers.len() { if sleepers[index] == worker_id { @@ -128,7 +128,7 @@ impl Idle { /// Returns `true` if `worker_id` is contained in the sleep set pub(super) fn is_parked(&self, worker_id: usize) -> bool { - let sleepers = self.sleepers.lock().unwrap(); + let sleepers = self.sleepers.lock(); sleepers.contains(&worker_id) } |