Lines Matching refs:scheduler
43 var scheduler = new Scheduler();
44 scheduler.addIdleTask(ID_IDLE, 0, null, COUNT);
48 scheduler.addWorkerTask(ID_WORKER, 1000, queue);
53 scheduler.addHandlerTask(ID_HANDLER_A, 2000, queue);
58 scheduler.addHandlerTask(ID_HANDLER_B, 3000, queue);
60 scheduler.addDeviceTask(ID_DEVICE_A, 4000, null);
62 scheduler.addDeviceTask(ID_DEVICE_B, 5000, null);
64 scheduler.schedule();
66 if (scheduler.queueCount != EXPECTED_QUEUE_COUNT ||
67 scheduler.holdCount != EXPECTED_HOLD_COUNT) {
69 "Error during execution: queueCount = " + scheduler.queueCount +
70 ", holdCount = " + scheduler.holdCount + ".";
89 * A scheduler can be used to schedule a set of tasks based on their relative
115 * Add an idle task to this scheduler.
126 * Add a work task to this scheduler.
136 * Add a handler task to this scheduler.
146 * Add a handler task to this scheduler.
168 * Add the specified task to this scheduler.
181 * Execute the tasks managed by this scheduler.
280 * be started by the scheduler.
358 * @param {Scheduler} scheduler the scheduler that manages this task
363 function IdleTask(scheduler, v1, count) {
364 this.scheduler = scheduler;
371 if (this.count == 0) return this.scheduler.holdCurrent();
374 return this.scheduler.release(ID_DEVICE_A);
377 return this.scheduler.release(ID_DEVICE_B);
388 * @param {Scheduler} scheduler the scheduler that manages this task
391 function DeviceTask(scheduler) {
392 this.scheduler = scheduler;
398 if (this.v1 == null) return this.scheduler.suspendCurrent();
401 return this.scheduler.queue(v);
404 return this.scheduler.holdCurrent();
414 * @param {Scheduler} scheduler the scheduler that manages this task
419 function WorkerTask(scheduler, v1, v2) {
420 this.scheduler = scheduler;
427 return this.scheduler.suspendCurrent();
441 return this.scheduler.queue(packet);
451 * @param {Scheduler} scheduler the scheduler that manages this task
454 function HandlerTask(scheduler) {
455 this.scheduler = scheduler;
477 return this.scheduler.queue(v);
482 return this.scheduler.queue(v);
485 return this.scheduler.suspendCurrent();