Lines Matching full:clone
40 /// let (data, cv) = (data.clone(), cv.clone());
98 /// # let (mu2, cv2) = (mu.clone(), cv.clone());
123 self.add_waiter(waiter.clone(), guard.as_raw_mutex()); in wait()
147 self.add_waiter(waiter.clone(), guard.as_raw_mutex()); in wait_read()
515 let mu2 = mu.clone(); in notify_one()
516 let cv2 = cv.clone(); in notify_one()
537 let mu = mu.clone(); in multi_mutex()
538 let cv = cv.clone(); in multi_mutex()
561 let alt_mu2 = alt_mu.clone(); in multi_mutex()
562 let cv2 = cv.clone(); in multi_mutex()
588 let mu2 = Rc::clone(&mu); in notify_one_single_thread_async()
589 let cv2 = Rc::clone(&cv); in notify_one_single_thread_async()
607 .spawn_local(wait(mu, cv, spawner.clone())) in notify_one_single_thread_async()
621 let mu2 = Arc::clone(&mu); in notify_one_multi_thread_async()
622 let cv2 = Arc::clone(&cv); in notify_one_multi_thread_async()
639 ex.spawn_ok(wait(mu, cv, tx, ex.clone())); in notify_one_multi_thread_async()
721 Arc::clone(&mu), in notify_one_with_cancel()
722 Arc::clone(&cv), in notify_one_with_cancel()
723 Arc::clone(&alt_mu), in notify_one_with_cancel()
724 Arc::clone(&alt_cv), in notify_one_with_cancel()
725 tx.clone(), in notify_one_with_cancel()
731 Arc::clone(&mu), in notify_one_with_cancel()
732 Arc::clone(&cv), in notify_one_with_cancel()
733 Arc::clone(&alt_mu), in notify_one_with_cancel()
734 Arc::clone(&alt_cv), in notify_one_with_cancel()
735 tx.clone(), in notify_one_with_cancel()
739 ex.spawn_ok(increment(Arc::clone(&mu), Arc::clone(&cv), tx.clone())); in notify_one_with_cancel()
740 ex.spawn_ok(increment(Arc::clone(&alt_mu), Arc::clone(&alt_cv), tx)); in notify_one_with_cancel()
806 Arc::clone(&mu), in notify_all_with_cancel()
807 Arc::clone(&cv), in notify_all_with_cancel()
808 Arc::clone(&alt_mu), in notify_all_with_cancel()
809 Arc::clone(&alt_cv), in notify_all_with_cancel()
810 tx.clone(), in notify_all_with_cancel()
814 ex.spawn_ok(increment(Arc::clone(&mu), Arc::clone(&cv), tx.clone())); in notify_all_with_cancel()
815 ex.spawn_ok(increment(Arc::clone(&alt_mu), Arc::clone(&alt_cv), tx)); in notify_all_with_cancel()
840 let mu2 = mu.clone(); in notify_all()
841 let cv2 = cv.clone(); in notify_all()
842 let tx2 = tx.clone(); in notify_all()
887 .spawn_local(reset(mu.clone(), cv.clone())) in notify_all_single_thread_async()
904 .spawn_local(watcher(mu.clone(), cv.clone(), spawner.clone())) in notify_all_single_thread_async()
930 pool.spawn_ok(reset(mu.clone(), cv.clone())); in notify_all_multi_thread_async()
947 pool.spawn_ok(watcher(mu.clone(), cv.clone(), pool.clone(), tx.clone())); in notify_all_multi_thread_async()
968 Box::pin(read(mu.clone(), cv.clone())), in wake_all_readers()
969 Box::pin(read(mu.clone(), cv.clone())), in wake_all_readers()
970 Box::pin(read(mu.clone(), cv.clone())), in wake_all_readers()
971 Box::pin(read(mu.clone(), cv.clone())), in wake_all_readers()
1021 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify()
1022 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_before_notify()
1066 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify()
1067 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_notify()
1110 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer()
1111 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer()
1165 let mut fut1 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer_and_wake()
1166 let mut fut2 = Box::pin(dec(mu.clone(), cv.clone())); in cancel_after_transfer_and_wake()
1232 let mut wait = Box::pin(wait_deadline(mu.clone(), cv.clone(), rx)); in timed_wait()