Searched refs:before_stop (Results 1 – 6 of 6) sorted by relevance
| /external/rust/crates/futures-executor/src/ |
| D | thread_pool.rs | 42 before_stop: Option<Arc<dyn Fn(usize) + Send + Sync>>, field
152 before_stop: Option<Arc<dyn Fn(usize) + Send + Sync>>) { in work()
164 if let Some(before_stop) = before_stop { in work()
165 before_stop(idx); in work()
197 before_stop: None, in new()
258 pub fn before_stop<F>(&mut self, f: F) -> &mut Self in before_stop() method
261 self.before_stop = Some(Arc::new(f)); in before_stop()
280 let before_stop = self.before_stop.clone(); in create() localVariable
288 thread_builder.spawn(move || state.work(counter, after_start, before_stop))?; in create()
|
| /external/rust/crates/grpcio/src/ |
| D | env.rs | 42 before_stop: Option<Arc<dyn Fn() + Send + Sync>>, field
52 before_stop: None, in new()
81 pub fn before_stop<F: Fn() + Send + Sync + 'static>(mut self, f: F) -> EnvBuilder { in before_stop() method
82 self.before_stop = Some(Arc::new(f)); in before_stop()
101 let before_stop = self.before_stop.clone(); in build() localVariable
108 if let Some(f) = before_stop { in build()
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 45 before_stop: Option<Callback>, field
126 before_stop: builder.before_stop.clone(), in new()
351 if let Some(f) = &self.before_stop { in run()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | builder.rs | 71 pub(super) before_stop: Option<Callback>, field
137 before_stop: None, in new()
373 self.before_stop = Some(std::sync::Arc::new(f)); in on_thread_stop()
|
| /external/rust/crates/tokio/tests/ |
| D | rt_threaded.rs | 225 let before_stop = Arc::new(AtomicUsize::new(0)); in start_stop_callbacks_called() localVariable
228 let before_inner = before_stop.clone(); in start_stop_callbacks_called()
251 assert!(before_stop.load(Ordering::Relaxed) > 0); in start_stop_callbacks_called()
|
| /external/rust/crates/tokio/ |
| D | CHANGELOG.md | 1243 - Provide `after_start` and `before_stop` configuration settings for
|