Searched refs:after_start (Results 1 – 6 of 6) sorted by relevance
| /external/rust/crates/futures-executor/src/ |
| D | thread_pool.rs | 41 after_start: Option<Arc<dyn Fn(usize) + Send + Sync>>, field
151 after_start: Option<Arc<dyn Fn(usize) + Send + Sync>>, in work()
154 if let Some(after_start) = after_start { in work()
155 after_start(idx); in work()
196 after_start: None, in new()
243 pub fn after_start<F>(&mut self, f: F) -> &mut Self in after_start() method
246 self.after_start = Some(Arc::new(f)); in after_start()
279 let after_start = self.after_start.clone(); in create() localVariable
288 thread_builder.spawn(move || state.work(counter, after_start, before_stop))?; in create()
375 .after_start(move |_| tx.send(1).unwrap()).create().unwrap(); in test_drop_after_start()
|
| /external/rust/crates/grpcio/src/ |
| D | env.rs | 41 after_start: Option<Arc<dyn Fn() + Send + Sync>>, field
51 after_start: None, in new()
75 pub fn after_start<F: Fn() + Send + Sync + 'static>(mut self, f: F) -> EnvBuilder { in after_start() method
76 self.after_start = Some(Arc::new(f)); in after_start()
100 let after_start = self.after_start.clone(); in build() localVariable
104 if let Some(f) = after_start { in build()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | builder.rs | 68 pub(super) after_start: Option<Callback>, field
136 after_start: None, in new()
347 self.after_start = Some(std::sync::Arc::new(f)); in on_thread_start()
589 .field("after_start", &self.after_start.as_ref().map(|_| "...")) in fmt()
590 .field("before_stop", &self.after_start.as_ref().map(|_| "...")) in fmt()
|
| /external/rust/crates/tokio/src/runtime/blocking/ |
| D | pool.rs | 42 after_start: Option<Callback>, field
125 after_start: builder.after_start.clone(), in new()
267 if let Some(f) = &self.after_start { in run()
|
| /external/rust/crates/tokio/tests/ |
| D | rt_threaded.rs | 224 let after_start = Arc::new(AtomicUsize::new(0)); in start_stop_callbacks_called() localVariable
227 let after_inner = after_start.clone(); in start_stop_callbacks_called()
250 assert!(after_start.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
|