| /third_party/python/Lib/test/ |
| D | test_sched.py | 46 scheduler = sched.scheduler(time.time, time.sleep)
48 z = scheduler.enter(x, 1, fun, (x,))
49 scheduler.run()
55 scheduler = sched.scheduler(time.time, time.sleep)
57 z = scheduler.enterabs(x, 1, fun, (x,))
58 scheduler.run()
65 scheduler = sched.scheduler(timer.time, timer.sleep)
66 scheduler.enter(1, 1, fun, (1,))
67 scheduler.enter(3, 1, fun, (3,))
68 t = threading.Thread(target=scheduler.run)
[all …]
|
| /third_party/boost/libs/statechart/test/ |
| D | FifoSchedulerTest.cpp | 153 sc::fifo_scheduler<> & scheduler, unsigned long expectedEventCount ) in RunScheduler() argument
157 if ( scheduler() != expectedEventCount ) in RunScheduler()
171 sc::fifo_scheduler<> & scheduler, in Check() argument
183 RunScheduler( scheduler, 1UL ); in Check()
187 scheduler.initiate_processor( processor ); in Check()
190 scheduler.queue_event( in Check()
193 RunScheduler( scheduler, 3UL ); in Check()
196 scheduler.queue_event( processor, MakeEvent( new EvFail() ) ); in Check()
197 RunScheduler( scheduler, 1UL ); in Check()
200 scheduler.initiate_processor( processor ); in Check()
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/src/ |
| D | scheduler_test.cpp | 25 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
30 auto scheduler = std::unique_ptr<marl::Scheduler>( in TEST_F() local
32 scheduler->bind(); in TEST_F()
34 ASSERT_EQ(scheduler.get(), got); in TEST_F()
35 scheduler->unbind(); in TEST_F()
44 auto scheduler = std::unique_ptr<marl::Scheduler>(new marl::Scheduler(cfg)); in TEST_F() local
46 auto gotCfg = scheduler->config(); in TEST_F()
57 auto scheduler = marl::Scheduler::get(); in TEST_P() local
58 scheduler->unbind(); in TEST_P()
59 delete scheduler; in TEST_P()
[all …]
|
| D | marl_test.h | 62 auto scheduler = new marl::Scheduler(cfg); in SetUp() local
63 scheduler->bind(); in SetUp()
67 auto scheduler = marl::Scheduler::get(); in TearDown() local
68 scheduler->unbind(); in TearDown()
69 delete scheduler; in TearDown() local
|
| /third_party/flutter/flutter/packages/flutter/test/scheduler/ |
| D | scheduler_test.dart | 9 import 'package:flutter/scheduler.dart';
31 bool shouldRunTaskWithPriority({ int priority, SchedulerBinding scheduler }) {
37 TestSchedulerBinding scheduler;
40 scheduler = TestSchedulerBinding();
45 scheduler.schedulingStrategy = strategy.shouldRunTaskWithPriority;
50 scheduler.scheduleTask(() { executedTasks.add(x); }, Priority.idle + x);
57 expect(scheduler.handleEventLoopCallback(), isFalse);
62 expect(scheduler.handleEventLoopCallback(), i == 0 ? isTrue : isFalse);
69 expect(scheduler.handleEventLoopCallback(), i < 2 ? isTrue : isFalse);
80 expect(scheduler.handleEventLoopCallback(), i < 2 ? isTrue : isFalse);
[all …]
|
| /third_party/boost/libs/asio/include/boost/asio/detail/impl/ |
| D | scheduler.ipp | 2 // detail/impl/scheduler.ipp
24 #include <boost/asio/detail/scheduler.hpp>
34 class scheduler::thread_function
37 explicit thread_function(scheduler* s)
49 scheduler* this_;
52 struct scheduler::task_cleanup
72 scheduler* scheduler_;
77 struct scheduler::work_cleanup
102 scheduler* scheduler_;
107 scheduler::scheduler(boost::asio::execution_context& ctx,
[all …]
|
| /third_party/boost/boost/asio/detail/impl/ |
| D | scheduler.ipp | 2 // detail/impl/scheduler.ipp
24 #include <boost/asio/detail/scheduler.hpp>
34 class scheduler::thread_function
37 explicit thread_function(scheduler* s)
49 scheduler* this_;
52 struct scheduler::task_cleanup
72 scheduler* scheduler_;
77 struct scheduler::work_cleanup
102 scheduler* scheduler_;
107 scheduler::scheduler(boost::asio::execution_context& ctx,
[all …]
|
| /third_party/boost/libs/fiber/src/ |
| D | scheduler.cpp | 26 scheduler::release_terminated_() noexcept { in release_terminated_()
52 scheduler::remote_ready2ready_() noexcept { in remote_ready2ready_()
74 scheduler::sleep2ready_() noexcept { in sleep2ready_()
111 scheduler::scheduler() noexcept : in scheduler() function in boost::fibers::scheduler
115 scheduler::~scheduler() { in ~scheduler()
138 scheduler::dispatch() noexcept { in dispatch()
195 scheduler::schedule( context * ctx) noexcept { in schedule()
214 scheduler::schedule_from_remote( context * ctx) noexcept { in schedule_from_remote()
237 scheduler::terminate( detail::spinlock_lock & lk, context * ctx) noexcept { in terminate()
263 scheduler::yield( context * ctx) noexcept { in yield()
[all …]
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/include/marl/ |
| D | blockingcall.h | 36 auto scheduler = Scheduler::get(); in call() local
39 if (scheduler != nullptr) { in call()
40 scheduler->bind(); in call()
43 if (scheduler != nullptr) { in call()
61 auto scheduler = Scheduler::get(); in call() local
64 if (scheduler != nullptr) { in call()
65 scheduler->bind(); in call()
68 if (scheduler != nullptr) { in call()
|
| /third_party/flutter/flutter/packages/flutter/lib/ |
| D | scheduler.dart | 7 /// To use, import `package:flutter/scheduler.dart`.
9 /// This library is responsible for scheduler frame callbacks, and tasks at
14 library scheduler;
16 export 'src/scheduler/binding.dart';
17 export 'src/scheduler/debug.dart';
18 export 'src/scheduler/priority.dart';
19 export 'src/scheduler/ticker.dart';
|
| /third_party/python/Doc/library/ |
| D | sched.rst | 1 :mod:`sched` --- Event scheduler
5 :synopsis: General purpose event scheduler.
16 scheduler:
18 .. class:: scheduler(timefunc=time.monotonic, delayfunc=time.sleep)
20 The :class:`scheduler` class defines a generic interface to scheduling events.
33 :class:`scheduler` class can be safely used in multi-threaded
39 >>> s = sched.scheduler(time.time, time.sleep)
63 :class:`scheduler` instances have the following methods and attributes:
66 .. method:: scheduler.enterabs(time, priority, action, argument=(), kwargs={})
87 .. method:: scheduler.enter(delay, priority, action, argument=(), kwargs={})
[all …]
|
| /third_party/skia/third_party/externals/oboe/apps/OboeTester/app/src/main/cpp/ |
| D | OboeTesterStreamCallback.cpp | 28 int scheduler = sched_getscheduler(gettid()); in printScheduler() local
29 if (scheduler != mPreviousScheduler) { in printScheduler()
30 int schedulerType = scheduler & 0xFFFF; // mask off high flags in printScheduler()
32 scheduler, in printScheduler()
37 mPreviousScheduler = scheduler; in printScheduler()
|
| /third_party/boost/boost/sort/common/ |
| D | scheduler.hpp | 52 struct scheduler struct
79 scheduler(void) : mp(), nelem(0) { }; in scheduler() argument
86 scheduler(scheduler && VT) = delete;
87 scheduler(const scheduler & VT) = delete;
93 virtual ~scheduler(void) {mp.clear();}; in ~scheduler() argument
101 scheduler & operator=(const scheduler &VT) = delete;
260 const scheduler<Func_t, Allocator> &sch) in operator <<()
|
| /third_party/skia/third_party/externals/swiftshader/third_party/marl/ |
| D | README.md | 3 Marl is a hybrid thread / fiber task scheduler written in C++ 11.
20 #include "marl/scheduler.h"
26 // Create a marl scheduler using all the logical processors available to the process.
27 // Bind this scheduler to the main thread so we can call marl::schedule()
28 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
29 scheduler.bind();
30 defer(scheduler.unbind()); // Automatically unbind before returning.
50 // The scheduler will find something else for this thread to do.
63 // All tasks are guaranteed to complete before the scheduler is destructed.
152 marl::Scheduler scheduler(marl::Scheduler::Config::allCores());
[all …]
|
| /third_party/boost/boost/thread/executors/ |
| D | scheduler.hpp | 226 class scheduler : public detail::scheduled_executor_base<Clock> class
233 scheduler() in scheduler() function in boost::executors::scheduler
237 ~scheduler() in ~scheduler()
244 scheduler_executor_wrapper<scheduler, Ex> on(Ex& ex) in on()
246 return scheduler_executor_wrapper<scheduler, Ex>(*this, ex); in on()
250 at_executor<scheduler> after(chrono::duration<Rep,Period> const& rel_time) in after()
256 at_executor<scheduler> at(chrono::time_point<clock,Duration> const& tp) in at()
258 return at_executor<scheduler>(*this, tp); in at()
273 using executors::scheduler;
|
| /third_party/boost/boost/fiber/ |
| D | scheduler.hpp | 40 class BOOST_FIBERS_DECL scheduler { class
112 scheduler() noexcept;
114 scheduler( scheduler const&) = delete;
115 scheduler & operator=( scheduler const&) = delete;
117 virtual ~scheduler();
|
| /third_party/gstreamer/gstreamer/docs/random/wtay/ |
| D | clocking | 51 Clocks and the scheduler
54 The scheduler knows about the clocks, else a clock provider and receiver
55 in the same scheduler could cause a deadlock.
57 Only one clock provider is allowed per scheduler. multiple clock
58 receivers are allowed per scheduler.
65 on every bin with a scheduler, gst_bin_use_clock (bin, clock) can be used
83 the toplevel bin with a scheduler selects the global clock and calls
87 a scheduler and another use_clock do nothing.
89 Bins with a scheduler also notify the scheduler of the clock.
97 to the scheduler of the element which can use the owner field
[all …]
|
| /third_party/boost/boost/statechart/ |
| D | processor_container.hpp | 81 Scheduler & scheduler, const processor_handle & handle in processor_context() argument
83 scheduler_( scheduler ), in processor_context()
112 WorkItem create_processor( processor_handle & handle, Scheduler & scheduler ) in create_processor() argument
122 processor_context( scheduler, handle ) ), in create_processor()
128 processor_handle & handle, Scheduler & scheduler, Arg1 arg1 ) in create_processor() argument
140 boost::bind( pImpl, this, pProcessor, processor_context( scheduler, handle ), in create_processor()
147 processor_handle & handle, Scheduler & scheduler, Arg1 arg1, Arg2 arg2 ) in create_processor() argument
160 boost::bind( pImpl, this, pProcessor, processor_context( scheduler, handle ), in create_processor()
167 processor_handle & handle, Scheduler & scheduler, in create_processor() argument
182 boost::bind( pImpl, this, pProcessor, processor_context( scheduler, handle ), in create_processor()
[all …]
|
| /third_party/boost/libs/fiber/doc/ |
| D | customization.qbk | 17 __boost_fiber__ uses its own [class_link round_robin] scheduler for each
24 when a fiber becomes ready to run is it passed to the scheduler. Of course, if
25 there are fewer than two ready fibers, the scheduler's job is trivial. Only
26 when there are two or more ready fibers does the particular scheduler
29 In this section we illustrate a simple custom scheduler that honors an integer
42 tracked an int priority for each fiber, even though the default scheduler
44 scheduler-specific fiber properties.]
51 introduce additional such wrapper functions. A custom scheduler must
55 places in the code. We discover a need to introduce a custom scheduler for a
56 particular thread. If supporting that scheduler's custom properties required
[all …]
|
| /third_party/boost/libs/asio/doc/requirements/ |
| D | Scheduler.qbk | 11 concept scheduler =
18 None of a scheduler's copy constructor, destructor, equality comparison, or
21 None of these operations, nor a scheduler type's `schedule` function, or
25 For any two (possibly const) values `x1` and `x2` of some scheduler type `X`,
31 effects. A scheduler may conceptually contain additional properties which are
33 this case, it is up to the concrete scheduler implementation to decide if these
37 A scheduler type's destructor shall not block pending completion of any
40 may be provided by the execution context that produced the scheduler.]
42 In addition to the above requirements, type `S` models `scheduler` only if it
47 * `s` denotes a (possibly const) scheduler object of type `S`,
[all …]
|
| /third_party/cef/patch/patches/ |
| D | browser_scheduler.patch | 1 diff --git content/browser/scheduler/browser_task_executor.cc content/browser/scheduler/browser_tas…
3 --- content/browser/scheduler/browser_task_executor.cc
4 +++ content/browser/scheduler/browser_task_executor.cc
|
| /third_party/mindspore/mindspore/ccsrc/ps/core/protos/ |
| D | comm.proto | 26 // The worker or server asks the scheduler for metadata
30 // The scheduler actively sends metadata to the worker and server
55 // the role of the current node: worker,server,scheduler
70 // the role of the node: worker,server,scheduler
146 // The scheduler will broadcast the worker/server numbers after scale out to all nodes.
154 // The scheduler will broadcast the worker/server numbers after scale in to all nodes.
164 // This message is sent to the scheduler to notify the completion of scale out
169 // This message is sent to the scheduler to notify the completion of scale out
174 // This message is sent by the worker/server to the scheduler, and the scheduler is broadcast the e…
180 // scheduler broadcasts the event to all other nodes through this message
|
| /third_party/boost/boost/asio/impl/ |
| D | system_context.ipp | 28 detail::scheduler* scheduler_;
49 : scheduler_(add_scheduler(new detail::scheduler(*this, 0, false)))
82 detail::scheduler& system_context::add_scheduler(detail::scheduler* s)
84 detail::scoped_ptr<detail::scheduler> scoped_impl(s);
85 boost::asio::add_service<detail::scheduler>(*this, scoped_impl.get());
|
| /third_party/boost/libs/asio/include/boost/asio/impl/ |
| D | system_context.ipp | 28 detail::scheduler* scheduler_;
49 : scheduler_(add_scheduler(new detail::scheduler(*this, 0, false)))
82 detail::scheduler& system_context::add_scheduler(detail::scheduler* s)
84 detail::scoped_ptr<detail::scheduler> scoped_impl(s);
85 boost::asio::add_service<detail::scheduler>(*this, scoped_impl.get());
|
| D | thread_pool.ipp | 30 detail::scheduler* scheduler_;
63 : scheduler_(add_scheduler(new detail::scheduler(*this, 0, false))),
88 : scheduler_(add_scheduler(new detail::scheduler(
125 detail::scheduler& thread_pool::add_scheduler(detail::scheduler* s)
127 detail::scoped_ptr<detail::scheduler> scoped_impl(s);
128 boost::asio::add_service<detail::scheduler>(*this, scoped_impl.get());
|