| /external/rust/crates/crossbeam-deque/src/ |
| D | deque.rs | 610 pub fn steal(&self) -> Steal<T> { in steal()
630 return Steal::Empty; in steal()
646 return Steal::Retry; in steal()
650 Steal::Success(task) in steal()
676 pub fn steal_batch(&self, dest: &Worker<T>) -> Steal<()> { in steal_batch() argument
679 return Steal::Empty; in steal_batch()
681 return Steal::Success(()); in steal_batch()
705 return Steal::Empty; in steal_batch()
755 return Steal::Retry; in steal_batch()
808 return Steal::Retry; in steal_batch()
[all …]
|
| D | lib.rs | 105 pub use crate::deque::{Injector, Steal, Stealer, Worker};
|
| /external/rust/crates/crossbeam-deque/ |
| D | CHANGELOG.md | 27 - Rename `Steal::Data` to `Steal::Success`.
28 - Add `Steal::or_else()` and implement `FromIterator` for `Steal`.
29 - Add `#[must_use]` to `Steal`.
|
| /external/rust/crates/rayon/src/iter/ |
| D | par_bridge.rs | 1 use crossbeam_deque::{Steal, Stealer, Worker};
153 Steal::Success(it) => { in fold_with()
159 Steal::Empty => { in fold_with()
197 Steal::Retry => (), in fold_with()
|
| /external/rust/crates/rayon-core/src/ |
| D | job.rs | 3 use crossbeam_deque::{Injector, Steal};
211 Steal::Success(job_ref) => break job_ref.execute(), in execute()
212 Steal::Empty => panic!("FIFO is empty"), in execute()
213 Steal::Retry => {} in execute()
|
| D | registry.rs | 11 use crossbeam_deque::{Injector, Steal, Stealer, Worker};
417 Steal::Success(job) => { in pop_injected_job()
423 Steal::Empty => return None, in pop_injected_job()
424 Steal::Retry => {} in pop_injected_job()
780 Steal::Success(job) => { in steal()
787 Steal::Empty => None, in steal()
788 Steal::Retry => { in steal()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | queue.rs | 19 pub(super) struct Steal<T: 'static>(Arc<Inner<T>>); struct
83 pub(super) fn local<T: 'static>() -> (Steal<T>, Local<T>) { in local()
100 let remote = Steal(inner); in local()
295 impl<T> Steal<T> { implementation
445 impl<T> Clone for Steal<T> { implementation
446 fn clone(&self) -> Steal<T> { in clone()
447 Steal(self.0.clone()) in clone()
|
| /external/eigen/unsupported/Eigen/CXX11/src/ThreadPool/ |
| D | NonBlockingThreadPool.h | 145 t = Steal(); in WorkerLoop()
155 t = Steal(); in WorkerLoop()
173 Task Steal() { in Steal() function
|
| /external/autotest/server/cros/res_resource_monitor/ |
| D | top_whitespace_ridden_ans.csv | 1 Time,UserCPU,SysCPU,NCPU,Idle,IOWait,IRQ,SoftIRQ,Steal,MemUnits,UsedMem,FreeMem,SwapUnits,UsedSwap,…
|
| D | top_field_order_changed_ans.csv | 1 Time,UserCPU,SysCPU,NCPU,Idle,IOWait,IRQ,SoftIRQ,Steal,MemUnits,UsedMem,FreeMem,SwapUnits,UsedSwap,…
|
| D | top_test_data_ans.csv | 1 Time,UserCPU,SysCPU,NCPU,Idle,IOWait,IRQ,SoftIRQ,Steal,MemUnits,UsedMem,FreeMem,SwapUnits,UsedSwap,…
|
| /external/grpc-grpc/test/cpp/util/ |
| D | slice_test.cc | 107 TEST_F(SliceTest, Steal) { in TEST_F() argument
|
| /external/rust/crates/tokio/src/runtime/tests/ |
| D | loom_queue.rs | 114 fn steal_tasks(steal: queue::Steal<Runtime>) -> usize { in multi_stealer()
|
| /external/autotest/server/cros/ |
| D | resource_monitor.py | 148 IOWait=io_wait, IRQ=irq, SoftIRQ=sirq, Steal=steal,
|
| /external/rust/crates/crossbeam-deque/tests/ |
| D | steal.rs | 1 use crossbeam_deque::Steal::Success;
|
| D | fifo.rs | 5 use crossbeam_deque::Steal::{Empty, Success};
|
| D | lifo.rs | 5 use crossbeam_deque::Steal::{Empty, Success};
|
| D | injector.rs | 5 use crossbeam_deque::Steal::{Empty, Success};
|
| /external/rust/crates/tokio/src/runtime/thread_pool/ |
| D | worker.rs | 92 steal: queue::Steal<Arc<Worker>>,
|
| /external/rust/crates/grpcio-sys/grpc/third_party/re2/ |
| D | ucs2.diff | 215 // Steal match storage (cleared but unused as of yet)
|
| /external/kotlinx.coroutines/benchmarks/src/jmh/resources/ |
| D | words.shakespeare.txt.gz | 1a
2A
3Aaron
4AARON
5abaissiez
6abandon
7abandoned
8abase
9Abase
10 ... |