| /external/ComputeLibrary/src/runtime/ |
| D | Scheduler.cpp | 41 Scheduler::Type Scheduler::_scheduler_type = Scheduler::Type::OMP;
43 Scheduler::Type Scheduler::_scheduler_type = Scheduler::Type::CPP;
45 Scheduler::Type Scheduler::_scheduler_type = Scheduler::Type::CPP;
47 Scheduler::Type Scheduler::_scheduler_type = Scheduler::Type::ST;
50 std::shared_ptr<IScheduler> Scheduler::_custom_scheduler = nullptr;
54 std::map<Scheduler::Type, std::unique_ptr<IScheduler>> init() in init()
56 std::map<Scheduler::Type, std::unique_ptr<IScheduler>> m; in init()
57 m[Scheduler::Type::ST] = std::make_unique<SingleThreadScheduler>(); in init()
59 m[Scheduler::Type::CPP] = std::make_unique<CPPScheduler>(); in init()
62 m[Scheduler::Type::OMP] = std::make_unique<OMPScheduler>(); in init()
[all …]
|
| D | Utils.cpp | 42 const std::string &string_from_scheduler_type(Scheduler::Type t) in string_from_scheduler_type()
44 static std::map<Scheduler::Type, const std::string> scheduler_type_map = in string_from_scheduler_type()
46 { Scheduler::Type::ST, "Single Thread" }, in string_from_scheduler_type()
47 { Scheduler::Type::CPP, "C++11 Threads" }, in string_from_scheduler_type()
48 { Scheduler::Type::OMP, "OpenMP Threads" }, in string_from_scheduler_type()
49 { Scheduler::Type::CUSTOM, "Custom" } in string_from_scheduler_type()
|
| /external/swiftshader/third_party/marl/src/ |
| D | scheduler.cpp | 70 inline marl::Scheduler::Config setConfigDefaults( in setConfigDefaults()
71 const marl::Scheduler::Config& cfgIn) { in setConfigDefaults()
72 marl::Scheduler::Config cfg{cfgIn}; in setConfigDefaults()
87 MARL_INSTANTIATE_THREAD_LOCAL(Scheduler*, Scheduler::bound, nullptr);
89 Scheduler* Scheduler::get() { in get()
93 void Scheduler::setBound(Scheduler* scheduler) { in setBound()
97 void Scheduler::bind() { in bind()
110 void Scheduler::unbind() { in unbind()
129 Scheduler::Scheduler(const Config& config) in Scheduler() function in marl::Scheduler
145 Scheduler::~Scheduler() { in ~Scheduler()
[all …]
|
| D | scheduler_test.cpp | 25 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F()
26 new marl::Scheduler(marl::Scheduler::Config())); in TEST_F()
30 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F()
31 new marl::Scheduler(marl::Scheduler::Config())); in TEST_F()
33 auto got = marl::Scheduler::get(); in TEST_F()
36 got = marl::Scheduler::get(); in TEST_F()
41 marl::Scheduler::Config cfg; in TEST_F()
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F()
57 auto scheduler = marl::Scheduler::get(); in TEST_P()
65 (new marl::Scheduler(marl::Scheduler::Config()))->bind(); in TEST_P()
[all …]
|
| /external/swiftshader/third_party/marl/include/marl/ |
| D | scheduler.h | 46 class Scheduler {
98 Scheduler(const Config&);
103 ~Scheduler();
107 static Scheduler* get();
225 friend class Scheduler; variable
278 Scheduler(const Scheduler&) = delete;
279 Scheduler(Scheduler&&) = delete;
280 Scheduler& operator=(const Scheduler&) = delete;
281 Scheduler& operator=(Scheduler&&) = delete;
339 Worker(Scheduler* scheduler, Mode mode, uint32_t id);
[all …]
|
| D | blockingcall.h | 36 auto scheduler = Scheduler::get(); in call()
44 Scheduler::unbind(); in call()
61 auto scheduler = Scheduler::get(); in call()
69 Scheduler::unbind(); in call()
|
| /external/openthread/src/core/common/ |
| D | timer.hpp | 105 class Scheduler : public InstanceLocator, private NonCopyable class in ot::Timer
117 explicit Scheduler(Instance &aInstance) in Scheduler() function in ot::Timer::Scheduler
159 class Scheduler : private Timer::Scheduler class in ot::TimerMilli
171 explicit Scheduler(Instance &aInstance) in Scheduler() function in ot::TimerMilli::Scheduler
172 : Timer::Scheduler(aInstance) in Scheduler()
177 void Add(TimerMilli &aTimer) { Timer::Scheduler::Add(aTimer, sAlarmMilliApi); } in Add()
178 void Remove(TimerMilli &aTimer) { Timer::Scheduler::Remove(aTimer, sAlarmMilliApi); } in Remove()
179 void RemoveAll(void) { Timer::Scheduler::RemoveAll(sAlarmMilliApi); } in RemoveAll()
180 void ProcessTimers(void) { Timer::Scheduler::ProcessTimers(sAlarmMilliApi); } in ProcessTimers()
302 class Scheduler : private Timer::Scheduler class in ot::TimerMicro
[all …]
|
| D | timer.cpp | 44 const Timer::Scheduler::AlarmApi TimerMilli::Scheduler::sAlarmMilliApi = {
94 Get<Scheduler>().Add(*this); in FireAt()
107 Get<Scheduler>().Remove(*this); in Stop()
112 aInstance.Get<Scheduler>().RemoveAll(); in RemoveAll()
115 void Timer::Scheduler::Add(Timer &aTimer, const AlarmApi &aAlarmApi) in Add()
143 void Timer::Scheduler::Remove(Timer &aTimer, const AlarmApi &aAlarmApi) in Remove()
163 void Timer::Scheduler::SetAlarm(const AlarmApi &aAlarmApi) in SetAlarm()
181 void Timer::Scheduler::ProcessTimers(const AlarmApi &aAlarmApi) in ProcessTimers()
203 void Timer::Scheduler::RemoveAll(const AlarmApi &aAlarmApi) in RemoveAll()
218 AsCoreType(aInstance).Get<TimerMilli::Scheduler>().ProcessTimers(); in otPlatAlarmMilliFired()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/MCA/HardwareUnits/ |
| D | Scheduler.cpp | 22 void Scheduler::initializeStrategy(std::unique_ptr<SchedulerStrategy> S) { in initializeStrategy()
32 void Scheduler::dump() const { in dump()
40 Scheduler::Status Scheduler::isAvailable(const InstRef &IR) { in isAvailable()
47 return Scheduler::SC_BUFFERS_FULL; in isAvailable()
49 return Scheduler::SC_DISPATCH_GROUP_STALL; in isAvailable()
60 return Scheduler::SC_LOAD_QUEUE_FULL; in isAvailable()
62 return Scheduler::SC_STORE_QUEUE_FULL; in isAvailable()
64 return Scheduler::SC_AVAILABLE; in isAvailable()
70 void Scheduler::issueInstructionImpl( in issueInstructionImpl()
99 void Scheduler::issueInstruction( in issueInstruction()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/Support/ |
| D | TaskQueue.h | 69 TaskQueue(ThreadPool &Scheduler) : Scheduler(Scheduler) { (void)Scheduler; } in TaskQueue() argument
73 Scheduler.wait(); in ~TaskQueue()
97 Scheduler.async(std::move(T)); in async()
120 Scheduler.async(std::move(Continuation)); in completeTask()
124 ThreadPool &Scheduler; variable
|
| /external/swiftshader/third_party/marl/docs/ |
| D | scheduler.md | 1 # `marl::Scheduler`
5 - [`marl::Scheduler`](#marlscheduler)
10 - [`marl::Scheduler::Worker::run()`](#marlschedulerworkerrun)
11 - [`marl::Scheduler::Worker::runUntilIdle()`](#marlschedulerworkerrununtilidle)
12 - [`marl::Scheduler::Worker::waitForWork()`](#marlschedulerworkerwaitforwork)
13 - [`marl::Scheduler::Worker::spinForWork()`](#marlschedulerworkerspinforwork)
14 - [`marl::Scheduler::Worker::suspend()`](#marlschedulerworkersuspend)
19 The `marl::Scheduler` is the most complex part of marl and is responsible for executing tasks and k…
28 Binding is made using the `marl::Scheduler::bind()` and `marl::Scheduler::unbind()` methods.
32 …rious synchronization primitives to be called without requiring a pointer to the `marl::Scheduler`.
[all …]
|
| /external/armnn/src/backends/neon/ |
| D | NeonTimer.cpp | 18 …cal auto g_Interceptor = std::make_shared<NeonInterceptorScheduler>(arm_compute::Scheduler::get());
27 m_RealSchedulerType = arm_compute::Scheduler::get_type(); in Start()
29 if(m_RealSchedulerType != arm_compute::Scheduler::Type::CUSTOM) in Start()
32 m_RealScheduler = &arm_compute::Scheduler::get(); in Start()
33 …arm_compute::Scheduler::set(armnn::PolymorphicPointerDowncast<arm_compute::IScheduler>(g_Intercept… in Start()
41 arm_compute::Scheduler::set(m_RealSchedulerType); in Stop()
|
| /external/rust/crates/tokio/src/runtime/ |
| D | runtime.rs | 55 scheduler: Scheduler,
78 pub(super) enum Scheduler { enum
89 scheduler: Scheduler, in from_parts() argument
282 Scheduler::CurrentThread(exec) => exec.block_on(&self.handle.inner, future), in block_on()
284 Scheduler::MultiThread(exec) => exec.block_on(&self.handle.inner, future), in block_on()
400 Scheduler::CurrentThread(current_thread) => { in drop()
407 Scheduler::MultiThread(multi_thread) => { in drop()
|
| /external/guava/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractScheduledServiceTest.java | 20 import static com.google.common.util.concurrent.AbstractScheduledService.Scheduler.newFixedDelaySch…
27 import com.google.common.util.concurrent.AbstractScheduledService.Scheduler;
54 volatile Scheduler configuration = newFixedDelaySchedule(0, 10, MILLISECONDS);
83 protected Scheduler scheduler() { in scheduler()
211 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
243 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceFails()
280 protected Scheduler scheduler() { in testTimeout()
281 return Scheduler.newFixedDelaySchedule(0, 1, NANOSECONDS); in testTimeout()
361 protected Scheduler scheduler() { in scheduler()
393 Scheduler schedule = Scheduler.newFixedRateSchedule(INITIAL_DELAY, DELAY, UNIT); in testFixedRateSchedule()
[all …]
|
| /external/guava/android/guava-tests/test/com/google/common/util/concurrent/ |
| D | AbstractScheduledServiceTest.java | 20 import static com.google.common.util.concurrent.AbstractScheduledService.Scheduler.newFixedDelaySch…
27 import com.google.common.util.concurrent.AbstractScheduledService.Scheduler;
54 volatile Scheduler configuration = newFixedDelaySchedule(0, 10, MILLISECONDS);
83 protected Scheduler scheduler() { in scheduler()
211 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceIsStopped()
243 protected Scheduler scheduler() { in testDefaultExecutorIsShutdownWhenServiceFails()
280 protected Scheduler scheduler() { in testTimeout()
281 return Scheduler.newFixedDelaySchedule(0, 1, NANOSECONDS); in testTimeout()
361 protected Scheduler scheduler() { in scheduler()
393 Scheduler schedule = Scheduler.newFixedRateSchedule(INITIAL_DELAY, DELAY, UNIT); in testFixedRateSchedule()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/lib/CodeGen/ |
| D | PostRASchedulerList.cpp | 314 SchedulePostRATDList Scheduler(Fn, MLI, AA, RegClassInfo, AntiDepMode, in runOnMachineFunction() local
331 Scheduler.startBlock(&MBB); in runOnMachineFunction()
344 Scheduler.enterRegion(&MBB, I, Current, CurrentCount - Count); in runOnMachineFunction()
345 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
346 Scheduler.schedule(); in runOnMachineFunction()
347 Scheduler.exitRegion(); in runOnMachineFunction()
348 Scheduler.EmitSchedule(); in runOnMachineFunction()
351 Scheduler.Observe(MI, CurrentCount); in runOnMachineFunction()
360 Scheduler.enterRegion(&MBB, MBB.begin(), Current, CurrentCount); in runOnMachineFunction()
361 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
[all …]
|
| /external/llvm/lib/CodeGen/ |
| D | PostRASchedulerList.cpp | 314 SchedulePostRATDList Scheduler(Fn, MLI, AA, RegClassInfo, AntiDepMode, in runOnMachineFunction() local
331 Scheduler.startBlock(&MBB); in runOnMachineFunction()
344 Scheduler.enterRegion(&MBB, I, Current, CurrentCount - Count); in runOnMachineFunction()
345 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
346 Scheduler.schedule(); in runOnMachineFunction()
347 Scheduler.exitRegion(); in runOnMachineFunction()
348 Scheduler.EmitSchedule(); in runOnMachineFunction()
351 Scheduler.Observe(MI, CurrentCount); in runOnMachineFunction()
360 Scheduler.enterRegion(&MBB, MBB.begin(), Current, CurrentCount); in runOnMachineFunction()
361 Scheduler.setEndIndex(CurrentCount); in runOnMachineFunction()
[all …]
|
| /external/tensorflow/tensorflow/core/kernels/batching_util/ |
| D | adaptive_shared_batch_scheduler_test.cc | 71 using Scheduler = AdaptiveSharedBatchScheduler<FakeTask>; in TEST() typedef
72 std::shared_ptr<Scheduler> scheduler; in TEST()
73 Scheduler::Options options; in TEST()
75 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
76 options = Scheduler::Options(); in TEST()
78 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
79 options = Scheduler::Options(); in TEST()
82 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
83 options = Scheduler::Options(); in TEST()
85 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
[all …]
|
| D | serial_device_batch_scheduler_test.cc | 68 using Scheduler = SerialDeviceBatchScheduler<FakeTask>; in TEST() typedef
69 std::shared_ptr<Scheduler> scheduler; in TEST()
70 Scheduler::Options default_options; in TEST()
72 Scheduler::Options options = default_options; in TEST()
74 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
77 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
81 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
84 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
87 EXPECT_FALSE(Scheduler::Create(options, &scheduler).ok()); in TEST()
88 options = Scheduler::Options(); in TEST()
[all …]
|
| /external/swiftshader/third_party/llvm-10.0/llvm/include/llvm/MCA/HardwareUnits/ |
| D | Scheduler.h | 70 class Scheduler : public HardwareUnit {
157 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu) in Scheduler() function
158 : Scheduler(Model, Lsu, nullptr) {} in Scheduler()
160 Scheduler(const MCSchedModel &Model, LSUnitBase &Lsu, in Scheduler() function
162 : Scheduler(std::make_unique<ResourceManager>(Model), Lsu, in Scheduler()
165 Scheduler(std::unique_ptr<ResourceManager> RM, LSUnitBase &Lsu, in Scheduler() function
|
| /external/robolectric-shadows/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowLooperTest.java | 25 import org.robolectric.util.Scheduler;
208 Scheduler old = sLooper.getScheduler(); in shouldSetNewScheduler_whenLooperIsReset()
248 Scheduler scheduler = shadowOf(mainLooper).getScheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
251 Scheduler s = new Scheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
282 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_byDefault()
292 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_withAdvancedScheduling()
302 Scheduler old = sLooper.getScheduler(); in reset_setsNewScheduler_forNonMainLooper_byDefault()
312 Scheduler s = new Scheduler(); in reset_setsSchedulerToMaster_forNonMainLooper_withAdvancedScheduling()
414 Scheduler s = ShadowLooper.getShadowMainLooper().getScheduler(); in withAdvancedScheduling_shouldDispatchMessagesOnBothLoopers_whenAdvancingForegroundThread()
|
| /external/swiftshader/third_party/marl/ |
| D | README.md | 28 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
153 #### Create one instance of `marl::Scheduler`, use it for the lifetime of the process
155 The `marl::Scheduler` constructor can be expensive as it may spawn a number of hardware threads. \
156 Destructing the `marl::Scheduler` requires waiting on all tasks to complete.
158 Multiple `marl::Scheduler`s may fight each other for hardware thread utilization.
160 For these reasons, it is recommended to create a single `marl::Scheduler` for the lifetime of your …
166 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
178 …marl::Scheduler` may be simultaneously bound to any number of threads, and the scheduler can be re…
185 marl::Scheduler* scheduler = marl::Scheduler::get();
200 … terminating the thread. Forgetting to unbind will result in the `marl::Scheduler` destructor bloc…
[all …]
|
| /external/guava/guava/src/com/google/common/util/concurrent/ |
| D | AbstractScheduledService.java | 120 public abstract static class Scheduler { class in AbstractScheduledService
130 public static Scheduler newFixedDelaySchedule(Duration initialDelay, Duration delay) { in newFixedDelaySchedule()
145 public static Scheduler newFixedDelaySchedule( in newFixedDelaySchedule()
149 return new Scheduler() { in newFixedDelaySchedule()
167 public static Scheduler newFixedRateSchedule(Duration initialDelay, Duration period) { in newFixedRateSchedule()
181 public static Scheduler newFixedRateSchedule( in newFixedRateSchedule()
185 return new Scheduler() { in newFixedRateSchedule()
199 private Scheduler() {}
354 protected abstract Scheduler scheduler();
522 public abstract static class CustomScheduler extends Scheduler {
|
| /external/robolectric/robolectric/src/test/java/org/robolectric/shadows/ |
| D | ShadowLegacyLooperTest.java | 36 import org.robolectric.util.Scheduler;
250 Scheduler old = sLooper.getScheduler(); in shouldSetNewScheduler_whenLooperIsReset()
292 Scheduler scheduler = shadowOf(mainLooper).getScheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
298 Scheduler s = new Scheduler(); in soStaticRefsToLoopersInAppWorksAcrossTests_shouldRetainSameLooperForMainThreadBetweenResetsButGiveItAFreshScheduler()
335 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_byDefault()
345 Scheduler s = new Scheduler(); in reset_setsGlobalScheduler_forMainLooper_withAdvancedScheduling()
355 Scheduler old = sLooper.getScheduler(); in reset_setsNewScheduler_forNonMainLooper_byDefault()
365 Scheduler s = new Scheduler(); in reset_setsSchedulerToMaster_forNonMainLooper_withAdvancedScheduling()
483 Scheduler s = ShadowLooper.getShadowMainLooper().getScheduler(); in withAdvancedScheduling_shouldDispatchMessagesOnBothLoopers_whenAdvancingForegroundThread()
|
| /external/robolectric/shadows/framework/src/main/java/org/robolectric/shadows/ |
| D | ShadowMessageQueue.java | 6 import org.robolectric.util.Scheduler;
30 public abstract Scheduler getScheduler(); in getScheduler()
37 public abstract void setScheduler(Scheduler scheduler); in setScheduler()
|