Searched refs:condvar (Results 1 – 4 of 4) sorted by relevance
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | parker.rs | 30 condvar: Condvar, field
45 condvar: Condvar::new(), in new()
141 let (lock, timeout_result) = self.condvar.wait_timeout(l, duration).unwrap(); in park_on_condvar_timeout()
145 l = self.condvar.wait(l).unwrap(); in park_on_condvar_timeout()
170 self.condvar.notify_one(); in unpark()
187 self.condvar.notify_all(); in release()
|
| H A D | block_on.rs | 56 condvar: Condvar::new(), in new()
73 condvar: Condvar, field
81 guard = self.condvar.wait(guard).unwrap(); in notified()
90 self.condvar.notify_one(); in notify_one()
|
| H A D | current_thread.rs | 82 condvar: Condvar, field
92 condvar: Condvar::new(), in new()
162 lock = self.condvar.wait(lock).unwrap(); in park_on_condvar()
181 self.condvar.notify_one(); in unpark()
194 self.condvar.notify_one(); in unpark()
326 condvar: Condvar,
333 condvar: Condvar::new(),
341 guard = self.condvar.wait(guard).unwrap();
350 self.condvar.notify_one();
|
| H A D | blocking_pool.rs | 63 condvar: Condvar::new(), in new()
82 self.inner.condvar.notify_all(); in shutdown()
112 condvar: Condvar, field
221 self.inner.condvar.notify_one(); in spawn()
263 shared = self.condvar.wait(shared).unwrap(); in wait_permanent()
282 .condvar in wait_temporary()
|